- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 421 for Cfg (0.02 sec)
-
cmd/kubeadm/app/cmd/phases/join/controlplanejoin.go
} if data.Cfg().ControlPlane == nil { return nil } // gets access to the cluster using the identity defined in admin.conf client, err := data.Client() if err != nil { return errors.Wrap(err, "couldn't create Kubernetes client") } cfg, err := data.InitCfg() if err != nil { return err } // in case of external etcd if cfg.Etcd.External != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 03:09:42 UTC 2024 - 5.7K bytes - Viewed (0) -
internal/config/callhome/callhome.go
func LookupConfig(kvs config.KVS) (cfg Config, err error) { if err = config.CheckValidKeys(config.CallhomeSubSys, kvs, DefaultKVS); err != nil { return cfg, err } cfg.Enable = env.Get(config.EnvMinIOCallhomeEnable, kvs.GetWithDefault(Enable, DefaultKVS)) == config.EnableOn cfg.Frequency, err = time.ParseDuration(env.Get(config.EnvMinIOCallhomeFrequency,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.6K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
) func createCNIConfigFile(ctx context.Context, cfg *config.InstallConfig) (string, error) { pluginConfig := plugin.Config{ PluginLogLevel: cfg.PluginLogLevel, LogUDSAddress: cfg.LogUDSAddress, CNIEventAddress: cfg.CNIEventAddress, AmbientEnabled: cfg.AmbientEnabled, Kubernetes: plugin.Kubernetes{ Kubeconfig: filepath.Join(cfg.CNINetDir, cfg.KubeconfigFilename),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 8.3K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/certs.go
cfg := data.Cfg() cfg.CertificatesDir = data.CertificateWriteDir() defer func() { cfg.CertificatesDir = data.CertificateDir() }() // create the new certificate authority (or use existing) return certsphase.CreateCACertAndKeyFiles(ca, cfg) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 06:35:45 UTC 2024 - 9.8K bytes - Viewed (0) -
internal/config/lambda/parse.go
// TestSubSysLambdaTargets - tests notification targets of given subsystem func TestSubSysLambdaTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) error { if err := checkValidLambdaKeysForSubSys(subSys, cfg[subSys]); err != nil { return err } targetList, err := fetchSubSysTargets(ctx, cfg, subSys, transport) if err != nil { return err } for _, target := range targetList {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/hpacontroller.go
// ApplyTo fills up HPAController config with options. func (o *HPAControllerOptions) ApplyTo(cfg *poautosclerconfig.HPAControllerConfiguration) error { if o == nil { return nil } cfg.ConcurrentHorizontalPodAutoscalerSyncs = o.ConcurrentHorizontalPodAutoscalerSyncs cfg.HorizontalPodAutoscalerSyncPeriod = o.HorizontalPodAutoscalerSyncPeriod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 19 09:49:23 UTC 2024 - 3.8K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/addons.go
} cfg := data.Cfg() var client clientset.Interface var err error if !printManifest { client, err = data.Client() if err != nil { return nil, nil, "", nil, err } } out := data.OutputWriter() patchesDir := data.PatchesDir() return cfg, client, patchesDir, out, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait_test.go
) func TestGetControlPlaneComponents(t *testing.T) { testcases := []struct { name string cfg *kubeadmapi.ClusterConfiguration expected []controlPlaneComponent }{ { name: "port values from config", cfg: &kubeadmapi.ClusterConfiguration{ APIServer: kubeadmapi.APIServer{ ControlPlaneComponent: kubeadmapi.ControlPlaneComponent{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 2.3K bytes - Viewed (0) -
tools/istio-iptables/pkg/capture/run_linux.go
func configureTProxyRoutes(cfg *config.Config) error { if cfg.InboundPortsInclude != "" { if cfg.InboundInterceptionMode == constants.TPROXY { link, err := netlink.LinkByName("lo") if err != nil { return fmt.Errorf("failed to find 'lo' link: %v", err) } tproxyTable, err := strconv.Atoi(cfg.InboundTProxyRouteTable) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 3.1K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/settings.go
return fmt.Errorf("invalid config name") } cfg := currentConfig() if err := cfg.applyURL(q); err != nil { return err } return editSettings(fname, func(s *settings) error { for i, c := range s.Configs { if c.Name == name { s.Configs[i].config = cfg return nil } } s.Configs = append(s.Configs, namedConfig{Name: name, config: cfg}) return nil }) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 4.2K bytes - Viewed (0)