mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-03 09:22:44 +00:00
commit
7ab785dc5f
@ -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 {
|
||||||
|
@ -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)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -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)
|
||||||
|
@ -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 {
|
||||||
|
@ -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)
|
||||||
|
Loading…
Reference in New Issue
Block a user