Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for BuildMultiClusterKclientComponent (0.39 sec)

  1. pkg/kube/multicluster/component.go

    	k.client.ShutdownHandlers()
    }
    
    func (k kclientInternalComponent[T]) HasSynced() bool {
    	return k.client.HasSynced()
    }
    
    // BuildMultiClusterKclientComponent builds a simple Component that just wraps a single kclient.Client
    func BuildMultiClusterKclientComponent[T controllers.ComparableObject](c ComponentBuilder, filter kubetypes.Filter) *KclientComponent[T] {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 06 02:13:10 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. pkg/kube/inject/inject_test.go

    				webhook := &Webhook{
    					Config:       sidecarTemplate,
    					meshConfig:   mc,
    					env:          env,
    					valuesConfig: valuesConfig,
    					revision:     "default",
    					namespaces:   multicluster.BuildMultiClusterKclientComponent[*corev1.Namespace](multi, kubetypes.Filter{}),
    				}
    
    				stop := test.NewStop(t)
    				multi.Add(constants.DefaultClusterName, client, stop)
    				client.RunAndWait(stop)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  3. pkg/kube/inject/webhook.go

    		meshConfig: p.Env.Mesh(),
    		env:        p.Env,
    		revision:   p.Revision,
    	}
    
    	if p.MultiCluster != nil {
    		if platform.IsOpenShift() {
    			wh.namespaces = multicluster.BuildMultiClusterKclientComponent[*corev1.Namespace](p.MultiCluster, kubetypes.Filter{})
    		}
    	}
    
    	mc := NewMulticast(p.Watcher, wh.GetConfig)
    	mc.AddHandler(wh.updateConfig)
    	wh.MultiCast = mc
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 42.2K bytes
    - Viewed (0)
Back to top