Fixing typos

This commit is contained in:
Dan McPherson 2014-07-28 15:15:50 +02:00
parent f91bfe2e00
commit 7bbc5e2a19
5 changed files with 6 additions and 6 deletions

View File

@ -366,7 +366,7 @@ func (server *APIServer) readBody(req *http.Request) ([]byte, error) {
} }
// finishReq finishes up a request, waiting until the operation finishes or, after a timeout, creating an // finishReq finishes up a request, waiting until the operation finishes or, after a timeout, creating an
// Operation to recieve the result and returning its ID down the writer. // Operation to receive the result and returning its ID down the writer.
func (server *APIServer) finishReq(out <-chan interface{}, sync bool, timeout time.Duration, w http.ResponseWriter) { func (server *APIServer) finishReq(out <-chan interface{}, sync bool, timeout time.Duration, w http.ResponseWriter) {
op := server.ops.NewOperation(out) op := server.ops.NewOperation(out)
if sync { if sync {

View File

@ -82,7 +82,7 @@ type SimpleRESTStorage struct {
requestedID string requestedID string
// If non-nil, called inside the WorkFunc when answering update, delete, create. // If non-nil, called inside the WorkFunc when answering update, delete, create.
// obj recieves the original input to the update, delete, or create call. // obj receives the original input to the update, delete, or create call.
injectedFunction func(obj interface{}) (returnObj interface{}, err error) injectedFunction func(obj interface{}) (returnObj interface{}, err error)
} }

View File

@ -121,7 +121,7 @@ func (proxier Proxier) addServiceCommon(service string, l net.Listener) {
go proxier.AcceptHandler(service, l) go proxier.AcceptHandler(service, l)
} }
// OnUpdate recieves update notices for the updated services and start listening newly added services. // OnUpdate receives update notices for the updated services and start listening newly added services.
// It implements "github.com/GoogleCloudPlatform/kubernetes/pkg/proxy/config".ServiceConfigHandler.OnUpdate. // It implements "github.com/GoogleCloudPlatform/kubernetes/pkg/proxy/config".ServiceConfigHandler.OnUpdate.
func (proxier Proxier) OnUpdate(services []api.Service) { func (proxier Proxier) OnUpdate(services []api.Service) {
glog.Infof("Received update notice: %+v", services) glog.Infof("Received update notice: %+v", services)

View File

@ -53,7 +53,7 @@ func TestEventListeners(t *testing.T) {
for { for {
select { select {
case msg := <-listener: case msg := <-listener:
t.Logf("Recieved: %s", *msg) t.Logf("Received: %s", *msg)
count++ count++
err = checkEvent(count, msg) err = checkEvent(count, msg)
if err != nil { if err != nil {

View File

@ -49,10 +49,10 @@ func cadvisorTestClient(path string, expectedPostObj, expectedPostObjEmpty, repl
decoder := json.NewDecoder(r.Body) decoder := json.NewDecoder(r.Body)
err := decoder.Decode(expectedPostObjEmpty) err := decoder.Decode(expectedPostObjEmpty)
if err != nil { if err != nil {
t.Errorf("Recieved invalid object: %v", err) t.Errorf("Received invalid object: %v", err)
} }
if !reflect.DeepEqual(expectedPostObj, expectedPostObjEmpty) { if !reflect.DeepEqual(expectedPostObj, expectedPostObjEmpty) {
t.Errorf("Recieved unexpected object: %+v", expectedPostObjEmpty) t.Errorf("Received unexpected object: %+v", expectedPostObjEmpty)
} }
} }
encoder := json.NewEncoder(w) encoder := json.NewEncoder(w)