- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for clientLeft (0.3 sec)
-
pkg/kube/kclient/client_test.go
wt := clienttest.NewWriter[*istioclient.WasmPlugin](t, c) tracker := assert.NewTracker[string](t) wasm.AddEventHandler(clienttest.TrackerHandler(tracker)) go constantlyAccessForRaceDetection(stop, wasm) // CRD and Delayed client are ready to go by the time we start informers clienttest.MakeCRD(t, c, gvr.WasmPlugin) c.RunAndWait(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubeconfig/kubeconfig.go
} } return nil } // EnsureRBACFunc defines a function type that can be passed to EnsureAdminClusterRoleBinding(). type EnsureRBACFunc func(context.Context, clientset.Interface, clientset.Interface, time.Duration, time.Duration) (clientset.Interface, error) // EnsureAdminClusterRoleBinding constructs a client from admin.conf and optionally // constructs a client from super-admin.conf if the file exists. It then proceeds
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 27K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubeconfig/kubeconfig_test.go
}, } for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { ensureRBACFunc := func(_ context.Context, adminClient clientset.Interface, superAdminClient clientset.Interface, _ time.Duration, _ time.Duration) (clientset.Interface, error) { if tc.expectedRBACError { return nil, errors.New("ensureRBACFunc error") } return adminClient, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 39.5K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
clientSet := clientset.NewForConfigOrDie(&restclient.Config{Host: "", ContentConfig: restclient.ContentConfig{GroupVersion: &schema.GroupVersion{Group: "", Version: "v1"}}}) manager, _ := newControllerFromClientWithClock(ctx, t, clientSet, controller.NoResyncPeriodFunc, fakeClock) fakePodControl := controller.FakePodControl{Err: tc.podControlErr}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control_test.go
"k8s.io/utils/ptr" ) func TestStatefulPodControlCreatesPods(t *testing.T) { recorder := record.NewFakeRecorder(10) set := newStatefulSet(3) pod := newStatefulSetPod(set, 0) fakeClient := &fake.Clientset{} claimIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) claimLister := corelisters.NewPersistentVolumeClaimLister(claimIndexer)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pkg/kubemark/hollow_kubelet.go
allPlugins = append(allPlugins, csi.ProbeVolumePlugins()...) return allPlugins } func NewHollowKubelet( flags *options.KubeletFlags, config *kubeletconfig.KubeletConfiguration, client *clientset.Clientset, heartbeatClient *clientset.Clientset, cadvisorInterface cadvisor.Interface, imageService internalapi.ImageManagerService, runtimeService internalapi.RuntimeService, containerManager cm.ContainerManager) *HollowKubelet {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:10:54 UTC 2024 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
package integration import ( "context" "fmt" "sync" "testing" "time" apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1" "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset" "k8s.io/apiextensions-apiserver/test/integration/fixtures" apierrors "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/util/wait"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
limitations under the License. */ package nodeipam import ( "context" "fmt" utilruntime "k8s.io/apimachinery/pkg/util/runtime" coreinformers "k8s.io/client-go/informers/core/v1" clientset "k8s.io/client-go/kubernetes" v1core "k8s.io/client-go/kubernetes/typed/core/v1" corelisters "k8s.io/client-go/listers/core/v1" "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/record"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
utilfeature "k8s.io/apiserver/pkg/util/feature" clientset "k8s.io/client-go/kubernetes" corelisters "k8s.io/client-go/listers/core/v1" "k8s.io/client-go/tools/record" "k8s.io/client-go/util/retry" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/features" ) // StatefulPodControlObjectManager abstracts the manipulation of Pods and PVCs. The real controller implements this
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controlplane/apiserver/config.go
if err != nil { return nil, nil, err } } } clientCAProvider, err := opts.Authentication.ClientCert.GetClientCAContentProvider() if err != nil { return nil, nil, err } config.ClusterAuthenticationInfo.ClientCA = clientCAProvider
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 14.9K bytes - Viewed (0)