- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for BuildMultiClusterKclientComponent (0.39 sec)
-
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) -
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) -
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)