- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for Registries (0.31 sec)
-
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, ®istryEntry{Instance: registry, stop: stop}) added = true break } } } if !added { c.registries = append(c.registries, ®istryEntry{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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)