- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for endpointsList (0.18 sec)
-
cmd/endpoint-ellipses.go
} for _, list := range pools { var endpointsList endpointsList for _, arg := range list.args { switch { case ellipses.HasList(arg): patterns, err := ellipses.FindListPatterns(arg) if err != nil { return layout, err } for _, exp := range patterns.Expand() { for _, ep := range exp { if err := endpointsList.add(ep); err != nil { return layout, err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
return r.GetLease(serverId) } func (r *peerEndpointLeaseReconciler) getIpInfoList(storageOpts storage.ListOptions) (*corev1.EndpointsList, error) { ipInfoList := &corev1.EndpointsList{} if err := r.serverLeases.storage.GetList(apirequest.NewDefaultContext(), r.serverLeases.baseKey, storageOpts, ipInfoList); err != nil { return nil, err } return ipInfoList, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
t.Cleanup(func() { server.Terminate(t) }) newFunc := func() runtime.Object { return &corev1.Endpoints{} } newListFunc := func() runtime.Object { return &corev1.EndpointsList{} } sc.Codec = apitesting.TestStorageCodec(codecs, corev1.SchemeGroupVersion) s, dFunc, err := factory.Create(*sc.ForResource(schema.GroupResource{Resource: "endpoints"}), newFunc, newListFunc, "") if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0) -
pkg/apis/core/v1/zz_generated.defaults.go
scheme.AddTypeDefaultingFunc(&v1.Endpoints{}, func(obj interface{}) { SetObjectDefaults_Endpoints(obj.(*v1.Endpoints)) }) scheme.AddTypeDefaultingFunc(&v1.EndpointsList{}, func(obj interface{}) { SetObjectDefaults_EndpointsList(obj.(*v1.EndpointsList)) }) scheme.AddTypeDefaultingFunc(&v1.LimitRange{}, func(obj interface{}) { SetObjectDefaults_LimitRange(obj.(*v1.LimitRange)) })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 14:49:26 UTC 2023 - 37.8K bytes - Viewed (0) -
pkg/api/testing/defaulting_test.go
{Group: "", Version: "v1", Kind: "Endpoints"}: {}, {Group: "", Version: "v1", Kind: "EndpointsList"}: {}, {Group: "", Version: "v1", Kind: "EphemeralContainers"}: {},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 20.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease.go
leaseTime time.Duration } var _ Leases = &storageLeases{} // ListLeases retrieves a list of the current master IPs from storage func (s *storageLeases) ListLeases() ([]string, error) { ipInfoList := &corev1.EndpointsList{} storageOpts := storage.ListOptions{ ResourceVersion: "0", ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan, Predicate: storage.Everything, Recursive: true, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/zz_generated.prerelease-lifecycle.go
// It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go. func (in *EndpointsList) APILifecycleIntroduced() (major, minor int) { return 1, 0 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 15K bytes - Viewed (0)