- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 610 for clientset (0.2 sec)
-
pkg/client/tests/listwatch_test.go
*/ package tests import ( "net/http/httptest" "net/url" "testing" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/runtime/schema" clientset "k8s.io/client-go/kubernetes" restclient "k8s.io/client-go/rest" . "k8s.io/client-go/tools/cache" utiltesting "k8s.io/client-go/util/testing" ) func parseSelectorOrDie(s string) fields.Selector {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 02 17:08:23 UTC 2022 - 5.6K 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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller_test.go
"github.com/stretchr/testify/require" apidiscoveryv2 "k8s.io/api/apidiscovery/v2" v1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1" "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset" "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake" "k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime/schema"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 12K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
} // NewController creates a new Controller to ensure system namespaces exist. func NewController(systemNamespaces []string, clientset kubernetes.Interface, namespaceInformer coreinformers.NamespaceInformer) *Controller { interval := 1 * time.Minute return &Controller{ client: clientset, namespaceLister: namespaceInformer.Lister(), namespaceSynced: namespaceInformer.Informer().HasSynced,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client.go
Event(eventtype, message string) } func newRecyclerClient(client clientset.Interface, recorder RecycleEventRecorder) recyclerClient { return &realRecyclerClient{ client, recorder, } } type realRecyclerClient struct { client clientset.Interface recorder RecycleEventRecorder } func (c *realRecyclerClient) CreatePod(pod *v1.Pod) (*v1.Pod, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (0) -
pkg/kubelet/pod/mirror_client.go
// the kubelet directly because they need to be in sync with the internal // pods. type basicMirrorClient struct { apiserverClient clientset.Interface nodeGetter nodeGetter nodeName string } // NewBasicMirrorClient returns a new MirrorClient. func NewBasicMirrorClient(apiserverClient clientset.Interface, nodeName string, nodeGetter nodeGetter) MirrorClient { return &basicMirrorClient{ apiserverClient: apiserverClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 21 11:38:40 UTC 2021 - 5.5K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
// or returns an error. func NewKubeletServerCertificateManager(kubeClient clientset.Interface, kubeCfg *kubeletconfig.KubeletConfiguration, nodeName types.NodeName, getAddresses func() []v1.NodeAddress, certDirectory string) (certificate.Manager, error) { var clientsetFn certificate.ClientsetFunc if kubeClient != nil { clientsetFn = func(current *tls.Certificate) (clientset.Interface, error) { return kubeClient, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/kube/client_factory.go
rESTClientGetter // DynamicClient returns a dynamic client ready for use DynamicClient() (dynamic.Interface, error) // KubernetesClientSet gives you back an external clientset KubernetesClientSet() (*kubernetes.Clientset, error) // Returns a RESTClient for accessing Kubernetes resources or an error. RESTClient() (*rest.RESTClient, error)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 21:30:37 UTC 2023 - 5.8K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
name string kubeClient clientset.Interface csrLister certificateslisters.CertificateSigningRequestLister csrsSynced cache.InformerSynced handler func(context.Context, *certificates.CertificateSigningRequest) error queue workqueue.TypedRateLimitingInterface[string] } func NewCertificateController( ctx context.Context, name string, kubeClient clientset.Interface,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/join/waitcontrolplane.go
See the License for the specific language governing permissions and limitations under the License. */ package phases import ( "io" "time" "github.com/pkg/errors" clientset "k8s.io/client-go/kubernetes" "k8s.io/klog/v2" "k8s.io/kubernetes/cmd/kubeadm/app/cmd/phases/workflow" "k8s.io/kubernetes/cmd/kubeadm/app/features" "k8s.io/kubernetes/cmd/kubeadm/app/util/apiclient"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 2.8K bytes - Viewed (0)