Merge pull request #12441 from vlajos/typofixes-vlajos-20150807

typofix - https://github.com/vlajos/misspell_fixer

pkg/client/cache/delta_fifo.go

@@ -277,7 +277,7 @@ func (f *DeltaFIFO) GetByKey(key string) (item interface{}, exists bool, err err
 // Pop blocks until an item is added to the queue, and then returns it.  If
 // multiple items are ready, they are returned in the order in which they were
 // added/updated. The item is removed from the queue (and the store) before it
-// is returned, so if you don't succesfully process it, you need to add it back
+// is returned, so if you don't successfully process it, you need to add it back
 // with AddIfNotPresent().
 //
 // Pop returns a 'Deltas', which has a complete list of all the things

pkg/client/cache/expiration_cache_test.go

@@ -118,7 +118,7 @@ func TestTTLPolicy(t *testing.T) {
 	}
 	fakeTimestampedEntry.timestamp = fakeTime
 	if policy.IsExpired(fakeTimestampedEntry) {
-		t.Errorf("TTL Cache should not expire entires before ttl")
+		t.Errorf("TTL Cache should not expire entries before ttl")
 	}
 	fakeTimestampedEntry.timestamp = expiredTime
 	if !policy.IsExpired(fakeTimestampedEntry) {

pkg/client/cache/fifo.go

@@ -163,7 +163,7 @@ func (f *FIFO) GetByKey(key string) (item interface{}, exists bool, err error) {
 // Pop waits until an item is ready and returns it. If multiple items are
 // ready, they are returned in the order in which they were added/updated.
 // The item is removed from the queue (and the store) before it is returned,
-// so if you don't succesfully process it, you need to add it back with
+// so if you don't successfully process it, you need to add it back with
 // AddIfNotPresent().
 func (f *FIFO) Pop() interface{} {
 	f.lock.Lock()

pkg/client/cache/poller.go

@@ -30,7 +30,7 @@ type Enumerator interface {
 	Get(index int) (object interface{})
 }
 
-// GetFunc should return an enumerator that you wish the Poller to proccess.
+// GetFunc should return an enumerator that you wish the Poller to process.
 type GetFunc func() (Enumerator, error)
 
 // Poller is like Reflector, but it periodically polls instead of watching.

pkg/client/chaosclient/chaosclient.go

@@ -103,7 +103,7 @@ type pIntercept struct {
 	p float64
 }
 
-// P returns a ChaosFunc that fires with a probabilty of p (p between 0.0
+// P returns a ChaosFunc that fires with a probability of p (p between 0.0
 // and 1.0 with 0.0 meaning never and 1.0 meaning always).
 func (s Seed) P(p float64, c Chaos) Chaos {
 	return pIntercept{c, s, p}

pkg/client/flags.go

@@ -32,7 +32,7 @@ type FlagSet interface {
 }
 
 // BindClientConfigFlags registers a standard set of CLI flags for connecting to a Kubernetes API server.
-// TODO this method is superceded by pkg/client/clientcmd/client_builder.go
+// TODO this method is superseded by pkg/client/clientcmd/client_builder.go
 func BindClientConfigFlags(flags FlagSet, config *Config) {
 	flags.StringVar(&config.Host, "master", config.Host, "The address of the Kubernetes API server")
 	flags.StringVar(&config.Version, "api_version", config.Version, "The API version to use when talking to the server")

pkg/client/record/event.go

@@ -68,16 +68,16 @@ type EventRecorder interface {
 
 // EventBroadcaster knows how to receive events and send them to any EventSink, watcher, or log.
 type EventBroadcaster interface {
-	// StartEventWatcher starts sending events recieved from this EventBroadcaster to the given
+	// StartEventWatcher starts sending events received from this EventBroadcaster to the given
 	// event handler function. The return value can be ignored or used to stop recording, if
 	// desired.
 	StartEventWatcher(eventHandler func(*api.Event)) watch.Interface
 
-	// StartRecordingToSink starts sending events recieved from this EventBroadcaster to the given
+	// StartRecordingToSink starts sending events received from this EventBroadcaster to the given
 	// sink. The return value can be ignored or used to stop recording, if desired.
 	StartRecordingToSink(sink EventSink) watch.Interface
 
-	// StartLogging starts sending events recieved from this EventBroadcaster to the given logging
+	// StartLogging starts sending events received from this EventBroadcaster to the given logging
 	// function. The return value can be ignored or used to stop recording, if desired.
 	StartLogging(logf func(format string, args ...interface{})) watch.Interface
 
@@ -95,7 +95,7 @@ type eventBroadcasterImpl struct {
 	*watch.Broadcaster
 }
 
-// StartRecordingToSink starts sending events recieved from the specified eventBroadcaster to the given sink.
+// StartRecordingToSink starts sending events received from the specified eventBroadcaster to the given sink.
 // The return value can be ignored or used to stop recording, if desired.
 // TODO: make me an object with parameterizable queue length and retry interval
 func (eventBroadcaster *eventBroadcasterImpl) StartRecordingToSink(sink EventSink) watch.Interface {
@@ -195,7 +195,7 @@ func recordEvent(sink EventSink, event *api.Event, updateExistingEvent bool) boo
 	return false
 }
 
-// StartLogging starts sending events recieved from this EventBroadcaster to the given logging function.
+// StartLogging starts sending events received from this EventBroadcaster to the given logging function.
 // The return value can be ignored or used to stop recording, if desired.
 func (eventBroadcaster *eventBroadcasterImpl) StartLogging(logf func(format string, args ...interface{})) watch.Interface {
 	return eventBroadcaster.StartEventWatcher(
@@ -204,7 +204,7 @@ func (eventBroadcaster *eventBroadcasterImpl) StartLogging(logf func(format stri
 		})
 }
 
-// StartEventWatcher starts sending events recieved from this EventBroadcaster to the given event handler function.
+// StartEventWatcher starts sending events received from this EventBroadcaster to the given event handler function.
 // The return value can be ignored or used to stop recording, if desired.
 func (eventBroadcaster *eventBroadcasterImpl) StartEventWatcher(eventHandler func(*api.Event)) watch.Interface {
 	watcher := eventBroadcaster.Watch()

pkg/client/record/event_test.go

@@ -318,7 +318,7 @@ func validateEvent(actualEvent *api.Event, expectedEvent *api.Event, t *testing.
 	}
 	if actualEvent.FirstTimestamp.Equal(actualEvent.LastTimestamp) {
 		if expectCompression {
-			t.Errorf("FirstTimestamp (%q) and LastTimestamp (%q) must be equal to indicate only one occurance of the event, but were different. Actual Event: %#v", actualEvent.FirstTimestamp, actualEvent.LastTimestamp, *actualEvent)
+			t.Errorf("FirstTimestamp (%q) and LastTimestamp (%q) must be equal to indicate only one occurrence of the event, but were different. Actual Event: %#v", actualEvent.FirstTimestamp, actualEvent.LastTimestamp, *actualEvent)
 		}
 	} else {
 		if !expectCompression {

pkg/client/record/events_cache.go

@@ -25,13 +25,13 @@ import (
 )
 
 type history struct {
-	// The number of times the event has occured since first occurance.
+	// The number of times the event has occurred since first occurrence.
 	Count int
 
 	// The time at which the event was first recorded.
 	FirstTimestamp util.Time
 
-	// The unique name of the first occurance of this event
+	// The unique name of the first occurrence of this event
 	Name string
 
 	// Resource version returned from previous interaction with server

pkg/client/request.go

@@ -641,7 +641,7 @@ func (r *Request) Upgrade(config *Config, newRoundTripperFunc func(*tls.Config)
 
 // request connects to the server and invokes the provided function when a server response is
 // received. It handles retry behavior and up front validation of requests. It wil invoke
-// fn at most once. It will return an error if a problem occured prior to connecting to the
+// fn at most once. It will return an error if a problem occurred prior to connecting to the
 // server - the provided function is responsible for handling server errors.
 func (r *Request) request(fn func(*http.Request, *http.Response)) error {
 	if r.err != nil {