- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for Registries (0.18 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/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) -
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/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) -
cmd/kubeadm/app/phases/upgrade/staticpods.go
func convertImageTagMetadataToSemver(tag string) string { // Container registries do not support `+` characters in tag names. This prevents imagetags from // correctly representing semantic versions which use the plus symbol to delimit build metadata. // Kubernetes uses the convention of using an underscore in image registries to preserve // build metadata information in imagetags. return strings.Replace(tag, "_", "+", 1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 10:07:41 UTC 2024 - 30.7K bytes - Viewed (0) -
pilot/pkg/model/context.go
// network. Each network provides information about the endpoints in a // routable L3 network. A single routable L3 network can have one or more // service registries. NetworksWatcher mesh.NetworksWatcher NetworkManager *NetworkManager // mutex used for protecting Environment.pushContext mutex sync.RWMutex
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
pilot/pkg/bootstrap/server.go
} return jwtAuthn, nil } func getClusterID(args *PilotArgs) cluster.ID { clusterID := args.RegistryOptions.KubeOptions.ClusterID if clusterID == "" { if hasKubeRegistry(args.RegistryOptions.Registries) { clusterID = cluster.ID(provider.Kubernetes) } } return clusterID }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0)