- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 443 for servicestore (0.32 sec)
-
pkg/controlplane/controller/kubernetesservice/controller_test.go
serviceStore := serviceInformer.GetIndexer() err := serviceStore.Add(test.service) if err != nil { t.Fatalf("unexpected error adding service %v to the store: %v", test.service, err) } master.serviceLister = v1listers.NewServiceLister(serviceStore) master.client = fakeClient
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 10:41:06 UTC 2023 - 15.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/store.go
out = append(out, svcs...) } return model.SortServicesByCreationTime(out) } func (s *serviceStore) getServices(key types.NamespacedName) []*model.Service { return s.servicesBySE[key] } func (s *serviceStore) deleteServices(key types.NamespacedName) { delete(s.servicesBySE, key) } func (s *serviceStore) updateServices(key types.NamespacedName, services []*model.Service) { s.servicesBySE[key] = services
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
Ports: nil, }, } controller.serviceStore.Add(svc) controller.onServiceUpdate(svc) // blockNextAction should eventually unblock once server gets endpoint request. waitForChanReceive(t, 1*time.Second, blockNextAction, "Service Add should have caused a request to be sent to the test server") controller.serviceStore.Delete(svc) controller.onServiceDelete(svc)
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/endpointslice/endpointslice_controller_test.go
existingServiceKey := endpointsliceutil.ServiceKey{Name: existingServiceName, Namespace: namespace} esController.triggerTimeTracker.ServiceStates[existingServiceKey] = endpointsliceutil.ServiceState{} esController.serviceStore.Add(&v1.Service{ ObjectMeta: metav1.ObjectMeta{Name: existingServiceName, Namespace: namespace}, Spec: v1.ServiceSpec{ Ports: []v1.ServicePort{{TargetPort: intstr.FromInt32(80)}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip_test.go
"k8s.io/kubernetes/pkg/registry/core/service/ipallocator" ) var ( serviceCIDRv4 = "10.0.0.0/16" serviceCIDRv6 = "2001:db8::/64" ) type fakeRepair struct { *RepairIPAddress serviceStore cache.Store ipAddressStore cache.Store serviceCIDRStore cache.Store } func newFakeRepair() (*fake.Clientset, *fakeRepair) { fakeClient := fake.NewSimpleClientset()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 20.3K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
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) { client := newClientset()
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
"k8s.io/kubernetes/pkg/registry/core/service/portallocator" portallocatorcontroller "k8s.io/kubernetes/pkg/registry/core/service/portallocator/controller" servicestore "k8s.io/kubernetes/pkg/registry/core/service/storage" serviceaccountstore "k8s.io/kubernetes/pkg/registry/core/serviceaccount/storage" kubeschedulerconfig "k8s.io/kubernetes/pkg/scheduler/apis/config"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 19.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/store_test.go
gotInstances = store.getAll() if len(gotInstances) != 0 { t.Errorf("got unexpected instances %v", gotSeInstances) } } func TestServiceStore(t *testing.T) { store := serviceStore{ servicesBySE: map[types.NamespacedName][]*model.Service{}, } expectedServices := []*model.Service{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 8.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
serviceInstances serviceInstancesStore // NOTE: historically, one index for both WorkloadEntry(s) and Pod(s); // beware of naming collisions workloadInstances workloadinstances.Index services serviceStore // To make sure the eds update run in serial to prevent stale ones can override new ones // when edsUpdate is called concurrently.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/service/scopes/ServiceScope.java
* for their scope and its children. * * @see Scope */ @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.TYPE) @Inherited public @interface ServiceScope { /** * One or more scopes in which the service is declared, * from the longest lifecycle to the shortest. */ Class<? extends Scope>[] value();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 1.7K bytes - Viewed (0)