- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 440 for servicestore (0.24 sec)
-
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/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) -
cmd/kubeadm/app/util/initsystem/initsystem_unix.go
// OpenRCInitSystem defines openrc type OpenRCInitSystem struct{} // ServiceStart tries to start a specific service func (openrc OpenRCInitSystem) ServiceStart(service string) error { args := []string{service, "start"} return exec.Command("rc-service", args...).Run() } // ServiceStop tries to stop a specific service func (openrc OpenRCInitSystem) ServiceStop(service string) error { args := []string{service, "stop"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 03:15:07 UTC 2023 - 5.9K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/injected-services-should-have-service-scope-applied.txt
Class <org.gradle.api.Project> is not annotated with @ServiceScope in (Project.java:0) Class <org.gradle.api.artifacts.dsl.DependencyFactory> is not annotated with @ServiceScope in (DependencyFactory.java:0) Class <org.gradle.api.artifacts.dsl.DependencyHandler> is not annotated with @ServiceScope in (DependencyHandler.java:0) Class <org.gradle.api.artifacts.dsl.DependencyLockingHandler> is not annotated with @ServiceScope in (DependencyLockingHandler.java:0)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 08:43:33 UTC 2024 - 10.5K bytes - Viewed (0)