- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for endpointsstore (0.22 sec)
-
pkg/controller/endpoint/endpoints_controller_test.go
return } if req.Method == "POST" { controller.endpointsStore.Add(endpoint) blockNextAction <- struct{}{} } if req.Method == "DELETE" { go func() { // Delay the deletion of endoints to make endpoint cache out of sync <-blockDelete controller.endpointsStore.Delete(endpoint) controller.onEndpointsDelete(endpoint) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
// Tests here primarily focus on unique controller functionality before the reconciler begins var alwaysReady = func() bool { return true } type endpointSliceMirroringController struct { *Controller endpointsStore cache.Store endpointSliceStore cache.Store serviceStore cache.Store } func newController(ctx context.Context, batchPeriod time.Duration) (*fake.Clientset, *endpointSliceMirroringController) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 13.9K bytes - Viewed (0) -
pkg/registry/core/rest/storage_core.go
} persistentVolumeClaimStorage, persistentVolumeClaimStatusStorage, err := pvcstore.NewREST(restOptionsGetter) if err != nil { return genericapiserver.APIGroupInfo{}, err } endpointsStorage, err := endpointsstore.NewREST(restOptionsGetter) if err != nil { return genericapiserver.APIGroupInfo{}, err } nodeStorage, err := nodestore.NewStorage(restOptionsGetter, p.Proxy.KubeletClientConfig, p.Proxy.Transport)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 19.1K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage.go
"sigs.k8s.io/structured-merge-diff/v4/fieldpath" ) type EndpointsStorage interface { rest.Getter rest.GracefulDeleter } type PodStorage interface { rest.Getter } type REST struct { *genericregistry.Store primaryIPFamily api.IPFamily secondaryIPFamily api.IPFamily alloc Allocators endpoints EndpointsStorage pods PodStorage proxyTransport http.RoundTripper
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:33 UTC 2024 - 22.3K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage_test.go
for ix := range endpoints { key, _ := endpointsStorage.KeyFunc(ctx, endpoints[ix].Name) if err := endpointsStorage.Store.Storage.Create(ctx, key, endpoints[ix], nil, 0, false); err != nil { t.Fatalf("Couldn't create endpoint: %v", err) } } } serviceStorage, statusStorage, _, err := NewREST(restOptions, ipFamilies[0], ipAllocs, portAlloc, endpointsStorage, podStorage.Pod, nil) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 440.2K bytes - Viewed (0)