Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for reconcile (0.06 sec)

  1. cni/pkg/nodeagent/informers.go

    	"istio.io/istio/pkg/monitoring"
    )
    
    var (
    	eventTypeTag = monitoring.CreateLabel("type")
    	EventTotals  = monitoring.NewSum(
    		"nodeagent_reconcile_events_total",
    		"The total number of node agent reconcile events.",
    	)
    )
    
    type K8sHandlers interface {
    	GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error)
    	GetActiveAmbientPodSnapshot() []*corev1.Pod
    	Start()
    }
    
    type InformerHandlers struct {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/informers_test.go

    		types.MergePatchType, labelsPatch, metav1.PatchOptions{})
    	assert.NoError(t, err)
    
    	// wait for another two update events
    	// total 3 update at before unlabel point: 1. init ns reconcile 2. ns label reconcile 3. pod annotation update
    	mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(5))
    
    	waitForMockCalls()
    
    	assertPodNotAnnotated(t, client, pod)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. cni/pkg/repair/repaircontroller.go

    		controllers.WithReconciler(c.Reconcile),
    		controllers.WithMaxAttempts(5))
    	c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))
    
    	return c, nil
    }
    
    func (c *Controller) Run(stop <-chan struct{}) {
    	kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced)
    	c.queue.Run(stop)
    	c.pods.ShutdownHandlers()
    }
    
    func (c *Controller) Reconcile(key types.NamespacedName) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  4. istioctl/pkg/tag/generate_test.go

    		ObjectMeta: metav1.ObjectMeta{
    			Name: "istio-sidecar-injector-revision",
    			Labels: map[string]string{
    				label.IoIstioRev.Name: "revision",
    				operatorManaged:       "Reconcile",
    			},
    		},
    		Webhooks: []admitv1.MutatingWebhook{
    			{
    				Name: fmt.Sprintf("namespace.%s", istioInjectionWebhookSuffix),
    				ClientConfig: admitv1.WebhookClientConfig{
    					Service: &admitv1.ServiceReference{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  5. cni/pkg/install/install.go

    		}
    		hint := ""
    		switch detectedCNI {
    		case "cilium":
    			hint = " Hint: Cilium CNI was detected; ensure 'cni.exclusive=false' in the Cilium configuration."
    		}
    		log.Warnf("Configuration has been reconciled multiple times in a short period of time. "+
    			"This may be due to a conflicting component constantly reverting our work.%s", hint)
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  6. LICENSE

        executable containing the modified Library.  (It is understood
        that the user who changes the contents of definitions files in the
        Library will not necessarily be able to recompile the application
        to use the modified definitions.)
    
        b) Use a suitable shared library mechanism for linking with the
        Library.  A suitable mechanism is one that (1) uses at run time a
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Jan 18 20:25:38 UTC 2016
    - 25.8K bytes
    - Viewed (0)
Back to top