- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for Registries (0.21 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) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
Registries current = registries.get(); Registries next = current.startProjectExecution(parallel); setProjectExecutionState(current, next); } @Override public void finishProjectExecution() { // TODO - check no locks are currently held Registries current = registries.get(); Registries next = current.finishProjectExecution();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
platforms/extensibility/plugin-use/src/main/java/org/gradle/plugin/management/internal/autoapply/CompositeAutoAppliedPluginRegistry.java
private final List<AutoAppliedPluginRegistry> registries; public CompositeAutoAppliedPluginRegistry(List<AutoAppliedPluginRegistry> registries) { this.registries = registries; } @Override public PluginRequests getAutoAppliedPlugins(Project target) { return registries.stream().map(r -> r.getAutoAppliedPlugins(target))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 22:36:52 UTC 2023 - 1.6K bytes - Viewed (0) -
tests/fuzz/aggregate_controller_fuzzer.go
func runDeleteRegistry(f *fuzz.ConsumeFuzzer, c *aggregate.Controller) error { registries := c.GetRegistries() if len(registries) == 0 { return fmt.Errorf("no registries") } index, err := f.GetInt() if err != nil { return err } selectedRegistry := registries[index%len(registries)] c.DeleteRegistry(selectedRegistry.Cluster(), selectedRegistry.Provider()) return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 18:40:05 UTC 2023 - 2.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/BuildScopeServiceRegistryFactory.java
registries.add(gradleServices); return gradleServices; } throw new IllegalArgumentException(String.format("Cannot create services for unknown domain object of type %s.", domainObject.getClass().getSimpleName())); } @Override public void close() { registries.stop(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Dec 11 09:02:18 UTC 2022 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/api_enablement.go
// Validate validates RuntimeConfig with a list of registries. // Usually this list only has one element, the apiserver registry of the process. // But in the advanced (and usually not recommended) case of delegated apiservers there can be more. // Validate will filter out the known groups of each registry. // If anything is left over after that, an error is returned. func (s *APIEnablementOptions) Validate(registries ...GroupRegistry) []error { if s == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 09:22:37 UTC 2023 - 4K bytes - Viewed (0) -
pilot/pkg/bootstrap/util.go
package bootstrap import ( "istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/serviceregistry/provider" "istio.io/istio/pkg/ledger" ) func hasKubeRegistry(registries []string) bool { for _, r := range registries { if provider.ID(r) == provider.Kubernetes { return true } } return false } func buildLedger(ca RegistryOptions) ledger.Ledger { var result ledger.Ledger
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 1.1K bytes - Viewed (0) -
pilot/cmd/pilot-discovery/app/cmd.go
InjectionDirectory: "./var/lib/istio/inject", } }) // Process commandline args. c.PersistentFlags().StringSliceVar(&serverArgs.RegistryOptions.Registries, "registries", []string{string(provider.Kubernetes)}, fmt.Sprintf("Comma separated list of platform service registries to read from (choose one or more from {%s, %s})", provider.Kubernetes, provider.Mock))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 8.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)