- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 243 for clientset (0.27 sec)
-
pkg/volume/testing/volume_host.go
var _ FakeVolumeHost = &fakeVolumeHost{} func NewFakeVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) FakeVolumeHost { return newFakeVolumeHost(t, rootDir, kubeClient, plugins, nil, "", nil, nil) } func NewFakeVolumeHostWithCloudProvider(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) FakeVolumeHost {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K 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/nodeipam/nolegacyprovider.go
limitations under the License. */ package nodeipam import ( "context" "errors" "net" coreinformers "k8s.io/client-go/informers/core/v1" clientset "k8s.io/client-go/kubernetes" cloudprovider "k8s.io/cloud-provider" ) type fakeController struct { } func (f *fakeController) Run(ctx context.Context) { <-ctx.Done() } func createLegacyIPAM(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 1.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) -
cmd/kubeadm/app/phases/addons/dns/dns.go
rbac "k8s.io/api/rbac/v1" apierrors "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" kuberuntime "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/types" clientset "k8s.io/client-go/kubernetes" clientsetscheme "k8s.io/client-go/kubernetes/scheme" "k8s.io/klog/v2" "sigs.k8s.io/yaml" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 16.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/health.go
type healthCheck struct { name string client clientset.Interface cfg *kubeadmapi.ClusterConfiguration // f is invoked with a k8s client and a kubeadm ClusterConfiguration passed to it. Should return an optional error f func(clientset.Interface, *kubeadmapi.ClusterConfiguration) error } // Check is part of the preflight.Checker interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 09:18:02 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
} testServer := httptest.NewServer(&fakeHandler) defer testServer.Close() clientset := clientset.NewForConfigOrDie(&restclient.Config{Host: testServer.URL, ContentConfig: restclient.ContentConfig{GroupVersion: &schema.GroupVersion{Group: "", Version: "v1"}}}) podControl := RealPodControl{ KubeClient: clientset, Recorder: &record.FakeRecorder{}, } err := test.podCreationFunc(podControl)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
cmd/kubemark/app/hollow_node.go
} if config.Morph == "kubelet" { clientConfig.UserAgent = "hollow-kubelet" client, err := clientset.NewForConfig(clientConfig) if err != nil { return fmt.Errorf("Failed to create a ClientSet, error: %w. Exiting", err) } f, c := kubemark.GetHollowKubeletConfig(config.createHollowKubeletOptions()) heartbeatClientConfig := *clientConfig
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 11K 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)