- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for clientset (0.17 sec)
-
pkg/kubelet/configmap/configmap_manager.go
// simpleConfigMapManager implements ConfigMap Manager interface with // simple operations to apiserver. type simpleConfigMapManager struct { kubeClient clientset.Interface } // NewSimpleConfigMapManager creates a new ConfigMapManager instance. func NewSimpleConfigMapManager(kubeClient clientset.Interface) Manager { return &simpleConfigMapManager{kubeClient: kubeClient} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager.go
} // simpleSecretManager implements SecretManager interfaces with // simple operations to apiserver. type simpleSecretManager struct { kubeClient clientset.Interface } // NewSimpleSecretManager creates a new SecretManager instance. func NewSimpleSecretManager(kubeClient clientset.Interface) Manager { return &simpleSecretManager{kubeClient: kubeClient} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K 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/kubelet/util/manager/cache_based_manager_test.go
return time.Duration(0), false } func getSecret(fakeClient clientset.Interface) GetObjectFunc { return func(namespace, name string, opts metav1.GetOptions) (runtime.Object, error) { return fakeClient.CoreV1().Secrets(namespace).Get(context.TODO(), name, opts) } } func newSecretStore(fakeClient clientset.Interface, clock clock.Clock, getTTL GetObjectTTLFunc, ttl time.Duration) *objectStore {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K 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) -
cmd/kubeadm/app/phases/kubeconfig/kubeconfig.go
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 // to pass the clients to EnsureAdminClusterRoleBindingImpl. The function returns a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 27K 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)