Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for push (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top