- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for NewWriteClient (0.24 sec)
-
pkg/kube/kclient/clienttest/direct.go
// NewWriter returns a new client for the given type. // Any errors will call t.Fatal. func NewWriter[T controllers.ComparableObject](t test.Failer, c kube.Client) TestWriter[T] { return TestWriter[T]{t: t, c: kclient.NewWriteClient[T](c)} } // NewDirectClient returns a new client for the given type. Reads are directly to the API server. // Any errors will call t.Fatal.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 3K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
client.Kube().Discovery().(*fakediscovery.FakeDiscovery).FakedServerVersion = &kubeVersion.Info{Major: "1", Minor: "28"} kclient.NewWriteClient[*k8sbeta.GatewayClass](client).Create(customClass) kclient.NewWriteClient[*k8sbeta.Gateway](client).Create(tt.gw.DeepCopy()) stop := test.NewStop(t) env := model.NewEnvironment() env.PushContext().ProxyConfigs = tt.pcs
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/kube/kclient/client.go
opts.InformerType = kubetypes.MetadataInformer inf := kubeclient.GetInformerFilteredFromGVR(c, opts, gvr) return newInformerClient[*metav1.PartialObjectMetadata](gvr, inf, filter) } // NewWriteClient is exposed for testing. func NewWriteClient[T controllers.ComparableObject](c kube.Client) Writer[T] { return &writeClient[T]{client: c} } func newDelayedInformer[T controllers.ComparableObject]( gvr schema.GroupVersionResource,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
// which impacts only the fake client. // Basically if the Create happens between the List and Watch it is lost. But we don't know when // this occurs, so we just retry cl := kclient.NewWriteClient[*istioclient.WasmPlugin](c) retry.UntilSuccessOrFail(t, func() error { cl.Create(&istioclient.WasmPlugin{ ObjectMeta: metav1.ObjectMeta{Name: "name", Namespace: "default"}, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0)