Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 440 for servicestore (0.24 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top