- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 585 for clientLeft (0.64 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/max_seats_test.go
expectedMaxSeats: 5, }, } for _, testcase := range testcases { t.Run(testcase.name, func(t *testing.T) { clientset := clientsetfake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(clientset, time.Second) flowcontrolClient := clientset.FlowcontrolV1() startTime := time.Now() clk, _ := eventclock.NewFake(startTime, 0, nil) c := newTestableController(TestableConfig{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/controlplane/controller/apiserverleasegc/gc_controller_test.go
} for _, test := range tests { t.Run(test.name, func(t *testing.T) { clientset := fake.NewSimpleClientset(test.lease) controller := NewAPIServerLeaseGC(clientset, 100*time.Millisecond, metav1.NamespaceSystem, "apiserver.kubernetes.io/identity=kube-apiserver") go controller.Run(nil) time.Sleep(time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 13 20:37:22 UTC 2023 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/scheme/register.go
apiextensionsv1beta1.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: Mon May 08 21:36:26 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go
package fixtures import ( "context" "fmt" "time" "k8s.io/utils/pointer" apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1" "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/util/wait"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 02:01:40 UTC 2021 - 21.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/fake/fake_apiextensions_client.go
limitations under the License. */ // Code generated by client-gen. DO NOT EDIT. package fake import ( v1 "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1" rest "k8s.io/client-go/rest" testing "k8s.io/client-go/testing" ) type FakeApiextensionsV1 struct { *testing.Fake }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 16 17:13:40 UTC 2019 - 1.2K bytes - Viewed (0) -
internal/event/target/nats.go
} if n.CertAuthority != "" { connOpts = append(connOpts, nats.RootCAs(n.CertAuthority)) } if n.ClientCert != "" && n.ClientKey != "" { connOpts = append(connOpts, nats.ClientCert(n.ClientCert, n.ClientKey)) } return nats.Connect(n.Address.String(), connOpts...) } // To obtain a streaming connection from args.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0) -
cmd/kubemark/app/hollow_node.go
} if config.Morph == "kubelet" { clientConfig.UserAgent = "hollow-kubelet" client, err := clientset.NewForConfig(clientConfig) if err != nil { return fmt.Errorf("Failed to create a ClientSet, error: %w. Exiting", err) } f, c := kubemark.GetHollowKubeletConfig(config.createHollowKubeletOptions()) heartbeatClientConfig := *clientConfig
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 11K bytes - Viewed (0) -
tools/bug-report/pkg/cluster/cluster.go
reg += ".*" } reg += regexp.QuoteMeta(literal) } return reg } // GetClusterResources returns cluster resources for the given REST config and k8s Clientset. func GetClusterResources(ctx context.Context, clientset *kubernetes.Clientset, config *config2.BugReportConfig) (*Resources, error) { out := &Resources{ Labels: make(map[string]map[string]string), Annotations: make(map[string]map[string]string),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 14 02:11:31 UTC 2023 - 10.9K bytes - Viewed (1) -
pilot/pkg/xds/workload_test.go
clienttest.NewWriter[*securityclient.AuthorizationPolicy](s.T(), s.KubeClient()).Create(&securityclient.AuthorizationPolicy{ ObjectMeta: metav1.ObjectMeta{ Name: name, Namespace: ns, }, Spec: v1beta1.AuthorizationPolicy{}, }) } func deletePeerAuthentication(s *xds.FakeDiscoveryServer, name string, ns string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go
t.Errorf("expected authorizer to be initialized but found nil") } } // TestWantsExternalKubeClientSet ensures that the clientset is injected // when the WantsExternalKubeClientSet interface is implemented by a plugin. func TestWantsExternalKubeClientSet(t *testing.T) { cs := &fake.Clientset{} target := initializer.New(cs, nil, nil, &TestAuthorizer{}, nil, nil, nil) wantExternalKubeClientSet := &WantExternalKubeClientSet{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0)