Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 610 for clientset (0.15 sec)

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

    }
    
    // NewForConfigOrDie creates a new Clientset for the given config and
    // panics if there is an error in the config.
    func NewForConfigOrDie(c *rest.Config) *Clientset {
    	cs, err := NewForConfig(c)
    	if err != nil {
    		panic(err)
    	}
    	return cs
    }
    
    // New creates a new Clientset for the given RESTClient.
    func New(c rest.Interface) *Clientset {
    	var cs Clientset
    	cs.crV1 = crv1.New(c)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 23 18:26:20 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/clientset.go

    limitations under the License.
    */
    
    // Code generated by client-gen. DO NOT EDIT.
    
    package clientset
    
    import (
    	"fmt"
    	"net/http"
    
    	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1"
    	apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1"
    	discovery "k8s.io/client-go/discovery"
    	rest "k8s.io/client-go/rest"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 21:36:26 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake/clientset_generated.go

    package fake
    
    import (
    	clientset "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
    	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1"
    	fakeapiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/fake"
    	apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 21:36:26 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  4. cmd/kube-controller-manager/app/core_test.go

    	fakediscovery "k8s.io/client-go/discovery/fake"
    	"k8s.io/client-go/informers"
    	clientset "k8s.io/client-go/kubernetes"
    	fakeclientset "k8s.io/client-go/kubernetes/fake"
    	restclient "k8s.io/client-go/rest"
    )
    
    // TestClientBuilder inherits ClientBuilder and can accept a given fake clientset.
    type TestClientBuilder struct {
    	clientset clientset.Interface
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 11:28:01 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/clientset_generated.go

    func (c *Clientset) Tracker() testing.ObjectTracker {
    	return c.tracker
    }
    
    var (
    	_ clientset.Interface = &Clientset{}
    	_ testing.FakeClient  = &Clientset{}
    )
    
    // CrV1 retrieves the CrV1Client
    func (c *Clientset) CrV1() crv1.CrV1Interface {
    	return &fakecrv1.FakeCrV1{Fake: &c.Fake}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 09 06:03:32 UTC 2021
    - 2.7K bytes
    - Viewed (0)
  6. 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)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go

    package internalinterfaces
    
    import (
    	time "time"
    
    	clientset "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
    	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	runtime "k8s.io/apimachinery/pkg/runtime"
    	cache "k8s.io/client-go/tools/cache"
    )
    
    // NewInformerFunc takes clientset.Interface and time.Duration to return a SharedIndexInformer.
    type NewInformerFunc func(clientset.Interface, time.Duration) cache.SharedIndexInformer
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 16 22:25:28 UTC 2018
    - 1.4K bytes
    - Viewed (0)
  8. 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)
  9. cmd/kubeadm/app/util/kubeconfig/kubeconfig.go

    func ClientSetFromFile(path string) (clientset.Interface, error) {
    	config, err := clientcmd.LoadFromFile(path)
    	if err != nil {
    		return nil, errors.Wrap(err, "failed to load admin kubeconfig")
    	}
    	return ToClientSet(config)
    }
    
    // ToClientSet converts a KubeConfig object to a client
    func ToClientSet(config *clientcmdapi.Config) (clientset.Interface, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 21 10:21:33 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  10. 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)
Back to top