Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for Registries (0.31 sec)

  1. pilot/pkg/serviceregistry/aggregate/controller.go

    		for i, r := range c.registries {
    			if r.Provider() != provider.Kubernetes {
    				// insert the registry in the position of the first non kubernetes registry
    				c.registries = slices.Insert(c.registries, i, &registryEntry{Instance: registry, stop: stop})
    				added = true
    				break
    			}
    		}
    	}
    	if !added {
    		c.registries = append(c.registries, &registryEntry{Instance: registry, stop: stop})
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/aggregate/controller_test.go

    		})
    		ctrl.AddRegistry(r)
    	}
    	if l := len(ctrl.registries); l != 3 {
    		t.Fatalf("Expected length of the registries slice should be 3, got %d", l)
    	}
    
    	if ctrl.registries[0].Instance.Provider() != provider.Kubernetes {
    		t.Errorf("expected first registry should be %s, but got %s", provider.Kubernetes,
    			ctrl.registries[0].Instance.Provider())
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  3. pilot/test/xds/fake.go

    			if opts.DisableSecretAuthorization {
    				DisableAuthorizationForSecret(defaultKubeClient.Kube().(*fake.Clientset))
    			}
    			defaultKubeController = k8s
    		} else {
    			client.RunAndWait(stop)
    		}
    		registries = append(registries, k8s)
    		mc.Add(k8sCluster, client, stop)
    	}
    
    	stop := test.NewStop(t)
    	ingr := ingress.NewController(defaultKubeClient, mesh.NewFixedWatcher(m), kube.Options{
    		DomainSuffix: "cluster.local",
    	})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 16:08:52 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  4. platforms/extensibility/plugin-use/src/main/java/org/gradle/plugin/internal/PluginUseServices.java

            }
    
            @Provides
            AutoAppliedPluginHandler createAutoAppliedPluginHandler(List<AutoAppliedPluginRegistry> registries) {
                return new DefaultAutoAppliedPluginHandler(new CompositeAutoAppliedPluginRegistry(registries));
            }
    
            @Provides
            SoftwareTypeRegistry createSoftwareTypeRegistry(PluginScheme pluginScheme) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  5. pilot/pkg/bootstrap/servicecontroller.go

    		s.environment.Watcher,
    		serviceentry.WithClusterID(s.clusterID),
    	)
    	serviceControllers.AddRegistry(s.serviceEntryController)
    
    	registered := sets.New[provider.ID]()
    	for _, r := range args.RegistryOptions.Registries {
    		serviceRegistry := provider.ID(r)
    		if registered.Contains(serviceRegistry) {
    			log.Warnf("%s registry specified multiple times.", r)
    			continue
    		}
    		registered.Insert(serviceRegistry)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/fake.go

    	Gateways  []model.NetworkGateway
    
    	// If provided, this mesh config will be used
    	MeshConfig      *meshconfig.MeshConfig
    	NetworksWatcher mesh.NetworksWatcher
    
    	// Additional service registries to use. A ServiceEntry and memory registry will always be created.
    	ServiceRegistries []serviceregistry.Instance
    
    	// Base ConfigController to use. If not set, a in-memory store will be used
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  7. platforms/extensibility/plugin-development/src/main/java/org/gradle/plugin/devel/tasks/internal/PropertyValidationAccess.java

            ServiceRegistryBuilder builder = ServiceRegistryBuilder.builder().displayName("Global services");
            // Should reuse `GlobalScopeServices` here, however this requires a bunch of stuff in order to discover the plugin service registries
            // For now, re-implement the discovery here
            builder.provider(new ServiceRegistrationProvider() {
                @SuppressWarnings("unused")
                void configure(ServiceRegistration registration) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/multicluster.go

    	// serverID of this pilot instance used for leader election
    	serverID string
    
    	// options to use when creating kube controllers
    	opts Options
    
    	// client for reading remote-secrets to initialize multicluster registries
    	client kubernetes.Interface
    	s      server.Instance
    
    	serviceEntryController *serviceentry.Controller
    	configController       model.ConfigStoreController
    	XDSUpdater             model.XDSUpdater
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. pilot/pkg/bootstrap/options.go

    // purposes). Otherwise, a CRD client is created based on the configuration.
    type RegistryOptions struct {
    	// If FileDir is set, the below kubernetes options are ignored
    	FileDir string
    
    	Registries []string
    
    	// Kubernetes controller options
    	KubeOptions kubecontroller.Options
    	// ClusterRegistriesNamespace specifies where the multi-cluster secret resides
    	ClusterRegistriesNamespace string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. pilot/pkg/model/endpointshards.go

    	"istio.io/istio/pilot/pkg/serviceregistry/provider"
    	"istio.io/istio/pkg/cluster"
    	"istio.io/istio/pkg/config/schema/kind"
    	"istio.io/istio/pkg/util/sets"
    )
    
    // shardRegistry is a simplified interface for registries that can produce a shard key
    type shardRegistry interface {
    	Cluster() cluster.ID
    	Provider() provider.ID
    }
    
    // ShardKeyFromRegistry computes the shard key based on provider type and cluster id.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top