- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 610 for clientset (0.26 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake/register.go
} // AddToScheme adds all types of this clientset into the given scheme. This allows composition // of clientsets, like in: // // import ( // "k8s.io/client-go/kubernetes" // clientsetscheme "k8s.io/client-go/kubernetes/scheme" // aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" // ) // // kclientset, _ := kubernetes.NewForConfig(c)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 1.9K 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) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller_test.go
&v1.Namespace{ ObjectMeta: metav1.ObjectMeta{ Name: ns, Namespace: "", }, }, ) } clientset := fake.NewSimpleClientset(objs...) informerFactory := informers.NewSharedInformerFactory(clientset, 0) namespaceInformer := informerFactory.Core().V1().Namespaces() for _, obj := range objs { namespaceInformer.Informer().GetIndexer().Add(obj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 4.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/clientbacked_dryrun.go
if err != nil { fmt.Printf("error after decode: %v %v\n", unstructuredList, err) return true, nil, err } return true, newObj, err } // Client gets the backing clientset.Interface func (clg *ClientBackedDryRunGetter) Client() clientset.Interface { return clg.client } // decodeUnstructuredIntoAPIObject converts the *unversioned.Unversioned object returned from the dynamic client
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 16 10:29:45 UTC 2023 - 4.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) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/server.go
} // StartDefaultServerWithClients starts a test server and returns clients for it. func StartDefaultServerWithClients(t servertesting.Logger, extraFlags ...string) (func(), clientset.Interface, dynamic.Interface, error) { tearDown, config, _, err := StartDefaultServer(t, extraFlags...) if err != nil { return nil, nil, nil, err } apiExtensionsClient, err := clientset.NewForConfig(config) if err != nil { tearDown()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/etcd.go
apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1" apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1" "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" genericapirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/client-go/dynamic" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 3K 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/phases/bootstraptoken/node/tlsbootstrap_test.go
"testing" rbac "k8s.io/api/rbac/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" clientset "k8s.io/client-go/kubernetes" clientsetfake "k8s.io/client-go/kubernetes/fake" "k8s.io/kubernetes/cmd/kubeadm/app/constants" ) func TestAllowBootstrapTokensToPostCSRs(t *testing.T) { tests := []struct { name string client clientset.Interface }{ { name: "ClusterRoleBindings is empty",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 04:16:31 UTC 2023 - 8.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/bootstraptoken/node/tlsbootstrap.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" clientset "k8s.io/client-go/kubernetes" "k8s.io/kubernetes/cmd/kubeadm/app/constants" "k8s.io/kubernetes/cmd/kubeadm/app/util/apiclient" ) // AllowBootstrapTokensToPostCSRs creates RBAC rules in a way the makes Node Bootstrap Tokens able to post CSRs func AllowBootstrapTokensToPostCSRs(client clientset.Interface) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Oct 15 10:49:52 UTC 2023 - 4.2K bytes - Viewed (0)