- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 306 for clientset (0.24 sec)
-
pkg/registry/flowcontrol/rest/storage_flowcontrol.go
func removeDanglingBootstrapConfiguration(ctx context.Context, clientset flowcontrolclient.FlowcontrolV1Interface, fsLister flowcontrollisters.FlowSchemaLister, plcLister flowcontrollisters.PriorityLevelConfigurationLister) error { if err := removeDanglingBootstrapFlowSchema(ctx, clientset, fsLister); err != nil { return err } return removeDanglingBootstrapPriorityLevel(ctx, clientset, plcLister) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 12.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/idempotency_test.go
os.Exit(exitVal) } func TestCreateOrUpdateConfigMap(t *testing.T) { tests := []struct { name string setupClient func(*clientsetfake.Clientset) expectedError bool }{ { name: "create configmap success", setupClient: func(client *clientsetfake.Clientset) { client.PrependReactor("create", "configmaps", func(clientgotesting.Action) (bool, runtime.Object, error) { return true, nil, nil }) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller_test.go
) func setupController(ctx context.Context, clientset kubernetes.Interface) { informerFactory := informers.NewSharedInformerFactory(clientset, 100*time.Millisecond) leaseInformer := informerFactory.Coordination().V1().Leases() storageVersionInformer := informerFactory.Internal().V1alpha1().StorageVersions() controller := NewStorageVersionGC(ctx, clientset, leaseInformer, storageVersionInformer)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:43 UTC 2023 - 12.1K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator_test.go
fakeNodeHandler: &testutil.FakeNodeHandler{ Existing: []*v1.Node{ { ObjectMeta: metav1.ObjectMeta{ Name: "node0", }, }, }, Clientset: fake.NewSimpleClientset(), }, allocatorParams: CIDRAllocatorParams{ ClusterCIDRs: func() []*net.IPNet { _, clusterCIDRv4, _ := netutils.ParseCIDRSloppy("10.10.0.0/16") return []*net.IPNet{clusterCIDRv4}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0) -
pkg/volume/util/resize_util.go
pvc *v1.PersistentVolumeClaim, newSize resource.Quantity, kubeClient clientset.Interface) (*v1.PersistentVolumeClaim, error) { return MarkFSResizeFinished(pvc, newSize, kubeClient) } // MarkFSResizeFinished marks file system resizing as done func MarkFSResizeFinished( pvc *v1.PersistentVolumeClaim, newSize resource.Quantity, kubeClient clientset.Interface) (*v1.PersistentVolumeClaim, error) { newPVC := pvc.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 14.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/idempotency.go
apierrors "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/strategicpatch" "k8s.io/apimachinery/pkg/util/wait" clientset "k8s.io/client-go/kubernetes" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" "k8s.io/kubernetes/cmd/kubeadm/app/constants" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 18.4K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/dryrunclient.go
} // NewDryRunClient is a wrapper for NewDryRunClientWithOpts using some default values func NewDryRunClient(drg DryRunGetter, w io.Writer) clientset.Interface { return NewDryRunClientWithOpts(GetDefaultDryRunClientOptions(drg, w)) } // NewDryRunClientWithOpts returns a clientset.Interface that can be used normally for talking to the Kubernetes API.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 21 09:49:59 UTC 2022 - 10.3K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/configset.go
} return componentCfg, nil } // FromCluster loads a component from a config map in the cluster func (h *handler) FromCluster(clientset clientset.Interface, clusterCfg *kubeadmapi.ClusterConfiguration) (kubeadmapi.ComponentConfig, error) { return h.fromCluster(h, clientset, clusterCfg) } // known holds the known component config handlers. Add new component configs here. var known = []*handler{ &kubeProxyHandler,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 04 15:36:00 UTC 2024 - 10.8K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/common.go
} // Get the fake clientset dryRunOpts := apiclient.GetDefaultDryRunClientOptions(dryRunGetter, os.Stdout) // Print GET and LIST requests dryRunOpts.PrintGETAndLIST = true fakeclient := apiclient.NewDryRunClientWithOpts(dryRunOpts) // As we know the return of Discovery() of the fake clientset is of type *fakediscovery.FakeDiscovery // we can convert it to that struct.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10.1K bytes - Viewed (0) -
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)