Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for trigger (0.28 sec)

  1. cni/pkg/nodeagent/informers_test.go

    	// wait for an update event
    	mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(2))
    
    	// wait for the pod to be annotated
    	// after Pod annotated, another update event will be triggered.
    	assertPodAnnotated(t, client, pod)
    
    	// Assert expected calls actually made
    	fs.AssertExpectations(t)
    
    	// unlabelling the namespace should cause only one RemovePodFromMesh to happen
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  2. cni/pkg/install/install.go

    		return copiedFiles, fmt.Errorf("copy binaries: %v", err)
    	}
    
    	// Install kubeconfig (if needed) - we write/update this in the shared node CNI netdir,
    	// which may be watched by other CNIs, and so we don't want to trigger writes to this file
    	// unless it's missing or the contents are not what we expect.
    	if err := maybeWriteKubeConfigFile(in.cfg); err != nil {
    		cniInstalls.With(resultLabel.Value(resultCreateKubeConfigFailure)).Increment()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  3. cni/pkg/repair/repaircontroller.go

    	}
    	return nil
    }
    
    // repairPod actually dynamically repairs a pod. This is done by entering the pods network namespace and setting up rules.
    // This differs from the general CNI plugin flow, which triggers before the pod fully starts.
    // Additionally, we need to jump through hoops to find the network namespace.
    func (c *Controller) repairPod(pod *corev1.Pod) error {
    	m := podsRepaired.With(typeLabel.Value(repairType))
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  4. operator/cmd/mesh/test-util_test.go

    	"istio.io/istio/pkg/log"
    	"istio.io/istio/pkg/test"
    )
    
    // PathValue is a path/value type.
    type PathValue struct {
    	path  string
    	value any
    }
    
    // String implements the Stringer interface.
    func (pv *PathValue) String() string {
    	return fmt.Sprintf("%s:%v", pv.path, pv.value)
    }
    
    // ObjectSet is a set of objects maintained both as a slice (for ordering) and map (for speed).
    type ObjectSet struct {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Oct 31 14:48:28 GMT 2023
    - 15.3K bytes
    - Viewed (0)
Back to top