Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Registries (0.18 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/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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top