- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for push (0.14 sec)
-
cni/pkg/plugin/cnieventclient.go
} return eventC } func PushCNIEvent(cniClient CNIEventClient, event *skel.CmdArgs, prevResIps []*cniv1.IPConfig, podName, podNamespace string) error { if event == nil { return fmt.Errorf("unable to push CNI event, CmdArgs event was nil") } var ncconfigs []nodeagent.IPConfig for _, ipc := range prevResIps {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
client.RunAndWait(ctx.Done()) payload, _ := json.Marshal(valid) // serialize our fake plugin event addEvent, err := processAddEvent(payload) assert.Equal(t, err, nil) // Push it thru the handler pluginServer.ReconcileCNIAddEvent(ctx, addEvent) waitForMockCalls() assertPodAnnotated(t, client, pod) // Assert expected calls actually made fs.AssertExpectations(t) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
err := PushCNIEvent(cniC, fakeCmdArgs, []*cniv1.IPConfig{&fakePrevResultIPConfig}, "testpod", "testns") assert.Error(t, err) assert.Equal(t, strings.Contains(err.Error(), fmt.Sprintf("unable to push CNI event, error was %d", http.StatusInternalServerError)), true) } func TestPushCNIAddEventGoodPayload(t *testing.T) { testPod := "testpod" testNS := "testns"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 4.2K bytes - Viewed (0)