clientset - Code Search

pilot/pkg/config/kube/gateway/controller_test.go

	return true
}

func TestListInvalidGroupVersionKind(t *testing.T) {
	g := NewWithT(t)
	clientSet := kube.NewFakeClient()
	clientSet.RunAndWait(test.NewStop(t))
	store := memory.NewController(memory.Make(collections.All))
	controller := NewController(clientSet, store, AlwaysReady, nil, controller.Options{})

	typ := config.GroupVersionKind{Kind: "wrong-kind"}
	c := controller.List(typ, "ns1")

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Tue Apr 02 16:47:06 UTC 2024

- 5.6K bytes

- Viewed (0)

github.com/istio/istio

pilot/pkg/serviceregistry/kube/controller/multicluster_test.go

	return sc
}

func Test_KubeSecretController(t *testing.T) {
	mockserviceController := newMockserviceController()
	clientset := kube.NewFakeClient()
	stop := test.NewStop(t)
	s := server.New()
	mcc := initController(clientset, testSecretNameSpace, stop)
	mc := NewMulticluster("pilot-abc-123", clientset.Kube(), testSecretNameSpace, Options{
		ClusterID:             "cluster-1",
		DomainSuffix:          DomainSuffix,

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Fri Apr 12 16:44:32 UTC 2024

- 6.7K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

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)

github.com/kubernetes/kubernetes

cmd/kubeadm/app/phases/upgrade/preflight.go

	"k8s.io/apimachinery/pkg/util/sets"
	clientset "k8s.io/client-go/kubernetes"
	"k8s.io/klog/v2"

	kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants"
	"k8s.io/kubernetes/cmd/kubeadm/app/phases/addons/dns"
	"k8s.io/kubernetes/cmd/kubeadm/app/preflight"
)

// CoreDNSCheck validates installed kubelet version
type CoreDNSCheck struct {
	name   string
	client clientset.Interface
	f      func(clientset.Interface) error

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Sat Feb 25 13:53:28 UTC 2023

- 4.1K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/scheme/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

- 2K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1/customresourcedefinition.go

// Code generated by informer-gen. DO NOT EDIT.

package v1

import (
	"context"
	time "time"

	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
	clientset "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
	internalinterfaces "k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/internalinterfaces"
	v1 "k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Sat Feb 08 02:16:47 UTC 2020

- 3.8K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1beta1/customresourcedefinition.go

package v1beta1

import (
	"context"
	time "time"

	apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
	clientset "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
	internalinterfaces "k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/internalinterfaces"
	v1beta1 "k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1beta1"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Sat Feb 08 02:16:47 UTC 2020

- 3.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/register.go

	crv1.AddToScheme,
}

// 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: Tue Jul 26 17:14:05 UTC 2022

- 1.8K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

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)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme/register.go

	crv1.AddToScheme,
}

// 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: Tue Jul 26 17:14:05 UTC 2022

- 1.9K bytes

- Viewed (0)

Search Options