Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for processAddEvent (0.1 sec)

  1. cni/pkg/nodeagent/cni-watcher_test.go

    	valid := CNIPluginAddEvent{
    		Netns:        "/var/netns/foo",
    		PodName:      "pod-bingo",
    		PodNamespace: "funkyns",
    	}
    
    	payload, _ := json.Marshal(valid)
    
    	addEvent, err := processAddEvent(payload)
    
    	assert.NoError(t, err)
    	assert.Equal(t, valid, addEvent)
    }
    
    func TestProcessAddEventBadPayload(t *testing.T) {
    	valid := CNIPluginAddEvent{
    		Netns:        "/var/netns/foo",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/cni-watcher.go

    	data, err := io.ReadAll(req.Body)
    	if err != nil {
    		log.Errorf("failed to read event report from cni plugin: %v", err)
    		http.Error(w, err.Error(), http.StatusInternalServerError)
    		return
    	}
    	msg, err := processAddEvent(data)
    	if err != nil {
    		log.Errorf("failed to process CNI event payload: %v", err)
    		http.Error(w, err.Error(), http.StatusBadRequest)
    		return
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top