- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for endpointstore (0.14 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/registry/core/service/storage/storage_test.go
epstest "k8s.io/kubernetes/pkg/api/endpoints/testing" svctest "k8s.io/kubernetes/pkg/api/service/testing" api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/features" endpointstore "k8s.io/kubernetes/pkg/registry/core/endpoint/storage" podstore "k8s.io/kubernetes/pkg/registry/core/pod/storage" "k8s.io/kubernetes/pkg/registry/core/service/ipallocator"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 440.2K 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
api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/cluster/ports" "k8s.io/kubernetes/pkg/features" kubeletclient "k8s.io/kubernetes/pkg/kubelet/client" "k8s.io/kubernetes/pkg/registry/core/componentstatus" endpointsstore "k8s.io/kubernetes/pkg/registry/core/endpoint/storage" limitrangestore "k8s.io/kubernetes/pkg/registry/core/limitrange/storage" nodestore "k8s.io/kubernetes/pkg/registry/core/node/storage"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 19.1K bytes - Viewed (0) -
operator/pkg/name/name.go
ClusterRoleBindingStr = "ClusterRoleBinding" CMStr = "ConfigMap" DaemonSetStr = "DaemonSet" DeploymentStr = "Deployment" EndpointStr = "Endpoints" HPAStr = "HorizontalPodAutoscaler" IstioOperator = "IstioOperator" MutatingWebhookConfigurationStr = "MutatingWebhookConfiguration"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 7.9K bytes - Viewed (0) -
operator/cmd/mesh/test-util_test.go
} // mustGetEndpoint returns the endpoint tree with the given name in the deployment with the given name. func mustGetEndpoint(g *WithT, objs *ObjectSet, endpointName string) *object.K8sObject { obj := objs.kind(name2.EndpointStr).nameEquals(endpointName) if obj == nil { return nil } g.Expect(obj).Should(Not(BeNil())) return obj }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 15.3K bytes - Viewed (0) -
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
{Group: "", Version: "v1", Kind: name.ServiceStr}, // Endpoints should not be pruned because these are generated and not in the manifest. // {Group: "", Version: "v1", Kind: name.EndpointStr}, {Group: "", Version: "v1", Kind: name.CMStr}, {Group: "", Version: "v1", Kind: name.PodStr}, {Group: "", Version: "v1", Kind: name.SecretStr}, {Group: "", Version: "v1", Kind: name.SAStr},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0)