- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for KC (0.02 sec)
-
pkg/kubelet/apis/config/validation/validation.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager_test.go
"k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/tools/cache" ) func TestBeforeSynced(t *testing.T) { kc := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactoryWithOptions(kc, 0) ctbInformer := informerFactory.Certificates().V1alpha1().ClusterTrustBundles() ctbManager, _ := NewInformerManager(ctbInformer, 256, 5*time.Minute)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 15.5K bytes - Viewed (0) -
security/pkg/k8s/configutil_test.go
var objs []runtime.Object if tc.existingConfigMap != nil { objs = []runtime.Object{tc.existingConfigMap} } kc := kube.NewFakeClient(objs...) fake := kc.Kube().(*fake.Clientset) configmaps := kclient.New[*v1.ConfigMap](kc) if tc.clientMod != nil { tc.clientMod(fake) } kc.RunAndWait(test.NewStop(t)) fake.ClearActions() err := InsertDataToConfigMap(configmaps, tc.meta, tc.caBundle)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:25 UTC 2024 - 13K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller_test.go
}) return gatewayError } func TestGreenfield(t *testing.T) { controllerStop := make(chan struct{}) clientStop := test.NewStop(t) kc := kube.NewFakeClient() gatewayError := setupGatewayError(kc) c := unstartedTestController(kc) kc.RunAndWait(clientStop) go c.Run(controllerStop) webhooks := clienttest.Wrap(t, c.webhooks) fetch := func(name string) func() *admission.ValidatingWebhookConfiguration {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 05 03:21:04 UTC 2024 - 11.8K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
var kc kclient.Untyped if s.IsBuiltin() { kc = kclient.NewUntypedInformer(cl.client, gvr, filter) } else { kc = kclient.NewDelayedInformer[controllers.Object]( cl.client, gvr, kubetypes.StandardInformer, filter, ) } kind := s.Kind() kc.AddEventHandler(controllers.EventHandler[controllers.Object]{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
func NewController( kc kube.Client, c model.ConfigStoreController, waitForCRD func(class schema.GroupVersionResource, stop <-chan struct{}) bool, credsController credentials.MulticlusterController, options controller.Options, ) *Controller { var ctl *status.Controller namespaces := kclient.NewFiltered[*corev1.Namespace](kc, kubetypes.Filter{ObjectFilter: kc.ObjectFilter()}) gatewayController := &Controller{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/credentials/kube/secrets.go
} type authorizationKey string type authorizationResponse struct { expiration time.Time authorized error } var _ credentials.Controller = &CredentialsController{} func NewCredentialsController(kc kube.Client, handlers []func(name string, namespace string)) *CredentialsController { // We only care about TLS certificates and docker config for Wasm image pulling.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 10K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/conversion_test.go
} } func createFakeClient(t test.Failer, objects ...runtime.Object) kclient.Client[*corev1.Service] { kc := kube.NewFakeClient(objects...) stop := test.NewStop(t) services := kclient.New[*corev1.Service](kc) kc.RunAndWait(stop) kube.WaitForCacheSync("test", stop, services.HasSynced) return services
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 19 18:20:34 UTC 2023 - 14.9K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
g := withContext(ictx) // copy nameflag to avoid race nf := nameflag g.Go(func(result chan string) error { // retrieve latest generation from Kubernetes kc, err := cliCtx.CLIClient() if err != nil { return err } dclient := kc.Dynamic() r := dclient.Resource(targetSchema.GroupVersionResource()).Namespace(cliCtx.Namespace())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (1) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
secretNamespace string component *multicluster.Component[*kubeController] } // NewMulticluster initializes data structure to store multicluster information func NewMulticluster( serverID string, kc kubernetes.Interface, secretNamespace string, opts Options, serviceEntryController *serviceentry.Controller, configController model.ConfigStoreController, caBundleWatcher *keycertbundle.Watcher, revision string,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0)