Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ReconcileCNIAddEvent (0.15 sec)

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

    	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)
    }
    
    func TestGetPodWithRetry(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/cni-watcher.go

    	}
    	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
    	}
    
    	if err := s.ReconcileCNIAddEvent(req.Context(), msg); err != nil {
    		log.Errorf("Failed to handle add event: %v", err)
    		http.Error(w, err.Error(), http.StatusInternalServerError)
    		return
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top