- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for registryOptions (0.24 sec)
-
pilot/pkg/bootstrap/servicecontroller.go
func (s *Server) initKubeRegistry(args *PilotArgs) (err error) { args.RegistryOptions.KubeOptions.ClusterID = s.clusterID args.RegistryOptions.KubeOptions.Revision = args.Revision args.RegistryOptions.KubeOptions.Metrics = s.environment args.RegistryOptions.KubeOptions.XDSUpdater = s.XDSServer args.RegistryOptions.KubeOptions.MeshNetworksWatcher = s.environment.NetworksWatcher args.RegistryOptions.KubeOptions.MeshWatcher = s.environment.Watcher
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/bootstrap/options.go
p.PodName = PodName p.Revision = Revision p.JwtRule = JwtRule p.KeepaliveOptions = keepalive.DefaultOption() p.RegistryOptions.DistributionTrackingEnabled = features.EnableDistributionTracking p.RegistryOptions.DistributionCacheRetention = features.DistributionHistoryRetention p.RegistryOptions.ClusterRegistriesNamespace = p.Namespace } func (p *PilotArgs) Complete() error {
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/cmd/pilot-discovery/app/cmd.go
"Duration the discovery server needs to terminate gracefully") // RegistryOptions Controller options c.PersistentFlags().StringVar(&serverArgs.RegistryOptions.FileDir, "configDir", "", "Directory to watch for updates to config yaml files. If specified, the files will be used as the source of config, rather than a CRD client.") c.PersistentFlags().StringVar(&serverArgs.RegistryOptions.KubeOptions.DomainSuffix, "domain", constants.DefaultClusterLocalDomain,
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/pkg/bootstrap/configcontroller.go
if err := s.initConfigSources(args); err != nil { return err } } else if args.RegistryOptions.FileDir != "" { // Local files - should be added even if other options are specified store := memory.Make(collections.Pilot) configController := memory.NewController(store) err := s.makeFileMonitor(args.RegistryOptions.FileDir, args.RegistryOptions.KubeOptions.DomainSuffix, configController) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
pilot/pkg/bootstrap/server_test.go
// Dynamically assign all ports. HTTPAddr: ":0", MonitoringAddr: ":0", GRPCAddr: ":0", SecureGRPCAddr: ":0", TLSOptions: *c.tlsOptions, } p.RegistryOptions = RegistryOptions{ FileDir: configDir, } p.ShutdownDuration = 1 * time.Millisecond }) g := NewWithT(t) s, err := NewServer(args, func(s *Server) { s.kubeClient = kube.NewFakeClient()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 23.1K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
} // Option configures a framework.Registry. type Option func(runtime.Registry) error // NewSchedulerCommand creates a *cobra.Command object with default parameters and registryOptions func NewSchedulerCommand(registryOptions ...Option) *cobra.Command { opts := options.NewOptions() cmd := &cobra.Command{ Use: "kube-scheduler", Long: `The Kubernetes scheduler is a control plane process which assigns
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
// Used by validation kubeRestConfig, err := kubelib.DefaultRestConfig(args.RegistryOptions.KubeConfig, "", func(config *rest.Config) { config.QPS = args.RegistryOptions.KubeOptions.KubernetesAPIQPS config.Burst = args.RegistryOptions.KubeOptions.KubernetesAPIBurst }) if err != nil { return fmt.Errorf("failed creating kube config: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
cmd/kube-scheduler/app/server_test.go
leaderElection: leaseDuration: 1h `, configKubeconfig)), os.FileMode(0600)); err != nil { t.Fatal(err) } testcases := []struct { name string flags []string registryOptions []Option restoreFeatures map[featuregate.Feature]bool wantPlugins map[string]*config.Plugins wantLeaderElection *componentbaseconfig.LeaderElectionConfiguration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/util.go
) 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 if ca.DistributionTrackingEnabled { result = ledger.Make(ca.DistributionCacheRetention) } else { result = &model.DisabledLedger{} } return result
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 1.1K bytes - Viewed (0) -
tests/fuzz/bootstrap_fuzzer.go
return 0 } defer os.Remove(kubeConfigFile) args := &bootstrap.PilotArgs{} err = f.GenerateStruct(args) if err != nil { return 0 } args.MeshConfigFile = meshConfigFile args.RegistryOptions.KubeConfig = kubeConfigFile args.ShutdownDuration = 1 * time.Millisecond stop := make(chan struct{}) s, err := bootstrap.NewServer(args) if err != nil { return 0 } err = s.Start(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 20 06:17:08 UTC 2022 - 1.8K bytes - Viewed (0)