Fixed typos

container/samplermngr.go

@@ -54,7 +54,7 @@ func (self *reservoirSamplerFactory) String() string {
 func (self *reservoirSamplerFactory) NewSampler(param *StatsParameter) (sampling.Sampler, error) {
 	s := sampling.NewReservoirSampler(param.NumSamples)
 	if param.ResetPeriod.Seconds() > 1.0 {
-		s = sampling.NewPeriodcallyResetSampler(param.ResetPeriod, s)
+		s = sampling.NewPeriodicallyResetSampler(param.ResetPeriod, s)
 	}
 	return s, nil
 }
@@ -74,7 +74,7 @@ func (self *esSamplerFactory) NewSampler(param *StatsParameter) (sampling.Sample
 		return delta.Seconds()
 	})
 	if param.ResetPeriod.Seconds() > 1.0 {
-		s = sampling.NewPeriodcallyResetSampler(param.ResetPeriod, s)
+		s = sampling.NewPeriodicallyResetSampler(param.ResetPeriod, s)
 	}
 	return s, nil
 }
@@ -89,7 +89,7 @@ func (self *chainSamplerFactory) String() string {
 func (self *chainSamplerFactory) NewSampler(param *StatsParameter) (sampling.Sampler, error) {
 	s := sampling.NewChainSampler(param.NumSamples, param.WindowSize)
 	if param.ResetPeriod.Seconds() > 1.0 {
-		s = sampling.NewPeriodcallyResetSampler(param.ResetPeriod, s)
+		s = sampling.NewPeriodicallyResetSampler(param.ResetPeriod, s)
 	}
 	return s, nil
 }

container/statssum.go

@@ -115,7 +115,7 @@ func (self *percentilesContainerHandlerWrapper) StatsSummary() (*info.ContainerS
 		samples = append(samples, stats)
 	})
 	self.containerPercentiles.Samples = samples
-	// XXX(dengnan): propabily add to StatsParameter?
+	// XXX(dengnan): probably add to StatsParameter?
 	self.containerPercentiles.FillPercentiles(
 		[]int{50, 80, 90, 95, 99},
 		[]int{50, 80, 90, 95, 99},

container/statssum_test.go

@@ -150,7 +150,7 @@ func TestSampleCpuUsage(t *testing.T) {
 		t.Error(err)
 	}
 
-	// request stats/obervation N+1 times, so that there will be N samples
+	// request stats/observation N+1 times, so that there will be N samples
 	for i := 0; i < N+1; i++ {
 		_, err = handler.GetStats()
 		if err != nil {

info/container.go

@@ -135,7 +135,7 @@ type MemoryStats struct {
 	Usage uint64 `json:"usage,omitempty"`
 
 	// The amount of working set memory, this includes recently accessed memory,
-	// dirty memory, and kernel memmory. Working set is <= "usage".
+	// dirty memory, and kernel memory. Working set is <= "usage".
 	// Units: Bytes.
 	WorkingSet uint64 `json:"working_set,omitempty"`
 
@@ -206,7 +206,7 @@ func NewSample(prev, current *ContainerStats) (*ContainerStatsSample, error) {
 		return nil, fmt.Errorf("current CPU usage is less than prev CPU usage (cumulative).")
 	}
 	sample := new(ContainerStatsSample)
-	// Caculate the diff to get the CPU usage within the time interval.
+	// Calculate the diff to get the CPU usage within the time interval.
 	sample.Cpu.Usage = current.Cpu.Usage.Total - prev.Cpu.Usage.Total
 	// Memory usage is current memory usage
 	sample.Memory.Usage = current.Memory.Usage

sampling/autoreset.go

@@ -44,7 +44,7 @@ func (self *autoResetSampler) Update(d interface{}) {
 	self.sampler.Update(d)
 }
 
-func NewPeriodcallyResetSampler(period time.Duration, sampler Sampler) Sampler {
+func NewPeriodicallyResetSampler(period time.Duration, sampler Sampler) Sampler {
 	lastRest := time.Now()
 	shouldReset := func(d interface{}) bool {
 		if time.Now().Sub(lastRest) > period {

sampling/chainsample.go

@@ -21,7 +21,7 @@ func randInt64Except(start, end int64, except map[int64]empty) int64 {
 }
 
 // Basic idea:
-// Every obervation will have a sequence number as its id.
+// Every observation will have a sequence number as its id.
 // Suppose we want to sample k observations within latest n observations
 // At first, we generated k random numbers in [0,n). These random numbers
 // will be used as ids of observations that will be sampled.

sampling/reservoir.go

@@ -51,7 +51,7 @@ func (self *reservoirSampler) Update(d interface{}) {
 		self.samples = append(self.samples, d)
 		return
 	}
-	// Randomly generates a number between [0, numInances).
+	// Randomly generates a number between [0, numInstances).
 	// Use this random number, j, as an index.  If j is larger than the
 	// reservoir size, we will ignore the current new data.
 	// Otherwise replace the jth element in reservoir with the new data.

sampling/sampler.go

@@ -36,7 +36,7 @@ type Sampler interface {
 
 	// Filter() should update in place. Removing elements may or may not
 	// affect the statistical behavior of the sampler, i.e. the probability
-	// that an obervation will be sampled after removing some elements is
+	// that an observation will be sampled after removing some elements is
 	// implementation defined.
 	Filter(filter func(interface{}) bool)
 }