Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 66 for servicestore (0.29 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/service/ScopedServiceRegistryTest.groovy

            return new ScopedServiceRegistry(scope, strict, "test service registry")
        }
    
        @ServiceScope(Scope.BuildTree)
        static class BuildTreeScopedService {}
    
        @ServiceScope([Scope.Global, Scope.Build])
        static class GlobalAndBuildScopedService {}
    
        static class UnscopedService {}
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  8. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/service/ServiceRegistryBuilder.java

         * validate all registered services for being annotated with the given scope.
         * <p>
         * However, this still allows to register services without the
         * {@link org.gradle.internal.service.scopes.ServiceScope @ServiceScope} annotation.
         *
         * @see #scopeStrictly(Class)
         */
        public ServiceRegistryBuilder scope(Class<? extends Scope> scope) {
            this.scope = scope;
            this.strict = false;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  9. platforms/core-runtime/instrumentation-agent-services/src/main/java/org/gradle/internal/instrumentation/agent/AgentInitializer.java

     */
    
    package org.gradle.internal.instrumentation.agent;
    
    import org.gradle.internal.service.scopes.Scope;
    import org.gradle.internal.service.scopes.ServiceScope;
    
    /**
     * Initializes the instrumenting agent.
     */
    @ServiceScope(Scope.Global.class)
    public class AgentInitializer {
        private final AgentStatus agentStatus;
    
        public AgentInitializer(AgentStatus agentStatus) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  10. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/service/ServiceRegistryBuilderTest.groovy

        }
    
        @ServiceScope(Scope.BuildTree)
        static class BuildTreeScopedService {}
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 1.8K bytes
    - Viewed (0)
Back to top