Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for newOption (0.25 sec)

  1. pkg/bootstrap/option/instances.go

    	return newOption("gcp_project_number", value)
    }
    
    func Metadata(meta *model.BootstrapNodeMetadata) Instance {
    	return newOption("metadata", meta)
    }
    
    func STSEnabled(value bool) Instance {
    	return newOption("sts", value)
    }
    
    func DiscoveryHost(value string) Instance {
    	return newOption("discovery_host", value)
    }
    
    func MetadataDiscovery(value bool) Instance {
    	return newOption("metadata_discovery", value)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:02:38 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. pkg/bootstrap/option/instance.go

    	if len(value) == 0 {
    		return skipOption(name)
    	}
    	return newOption(name, value)
    }
    
    func newOptionOrSkipIfZero(name Name, value any) *instance {
    	v := reflect.ValueOf(value)
    	if v.IsZero() {
    		return skipOption(name)
    	}
    	return newOption(name, value)
    }
    
    func newDurationOption(name Name, value *durationpb.Duration) *instance {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 25 19:30:47 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  3. pkg/kubelet/network/dns/dns.go

    func appendOptions(options []string, newOption ...string) []string {
    	var optionMap = make(map[string]string)
    	for _, option := range options {
    		optName := strings.Split(option, ":")[0]
    		optionMap[optName] = option
    	}
    	for _, option := range newOption {
    		optName := strings.Split(option, ":")[0]
    		optionMap[optName] = option
    	}
    
    	options = []string{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 04 11:37:10 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  4. cmd/kube-scheduler/app/options/options_test.go

    					}
    					return cfg
    				}(),
    				Logs: logs.NewOptions(),
    			},
    			expectedError: "no kind \"KubeSchedulerConfiguration\" is registered for version \"componentconfig/v1alpha1\"",
    		},
    		{
    			name: "unknown version kubescheduler.config.k8s.io/unknown",
    			options: &Options{
    				ConfigFile: unknownVersionConfig,
    				Logs:       logs.NewOptions(),
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  5. cmd/kube-scheduler/app/options/options.go

    	WriteConfigTo string
    
    	Master string
    
    	// Flags hold the parsed CLI flags.
    	Flags *cliflag.NamedFlagSets
    }
    
    // NewOptions returns default scheduler app options.
    func NewOptions() *Options {
    	o := &Options{
    		SecureServing:  apiserveroptions.NewSecureServingOptions().WithLoopback(),
    		Authentication: apiserveroptions.NewDelegatingAuthenticationOptions(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 17 17:06:29 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. pkg/controlplane/apiserver/options/options.go

    	Options
    }
    
    type CompletedOptions struct {
    	// Embed a private pointer that cannot be instantiated outside of this package.
    	*completedOptions
    }
    
    // NewOptions creates a new ServerRunOptions object with default parameters
    func NewOptions() *Options {
    	s := Options{
    		GenericServerRunOptions: genericoptions.NewServerRunOptions(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 12:19:56 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  7. pkg/controlplane/apiserver/config_test.go

    	"k8s.io/kubernetes/pkg/controlplane/apiserver/options"
    	generatedopenapi "k8s.io/kubernetes/pkg/generated/openapi"
    	netutils "k8s.io/utils/net"
    )
    
    func TestBuildGenericConfig(t *testing.T) {
    	opts := options.NewOptions()
    	s := (&apiserveroptions.SecureServingOptions{
    		BindAddress: netutils.ParseIPSloppy("127.0.0.1"),
    	}).WithLoopback()
    	ln, err := net.Listen("tcp", "127.0.0.1:0")
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 12:14:06 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  8. pkg/controlplane/apiserver/options/options_test.go

    	netutils "k8s.io/utils/net"
    
    	kubeoptions "k8s.io/kubernetes/pkg/kubeapiserver/options"
    )
    
    func TestAddFlags(t *testing.T) {
    	fs := pflag.NewFlagSet("addflagstest", pflag.PanicOnError)
    	s := NewOptions()
    	var fss cliflag.NamedFlagSets
    	s.AddFlags(&fss)
    	for _, f := range fss.FlagSets {
    		fs.AddFlagSet(f)
    	}
    
    	args := []string{
    		"--enable-admission-plugins=AlwaysDeny",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. cmd/kube-proxy/app/server_test.go

    				Format:         "text",
    				FlushFrequency: logsapi.TimeOrMetaDuration{Duration: metav1.Duration{Duration: 5 * time.Second}, SerializeAsString: true},
    			},
    		}
    
    		options := NewOptions()
    
    		baseYAML := fmt.Sprintf(
    			yamlTemplate, tc.bindAddress, tc.clusterCIDR,
    			tc.healthzBindAddress, tc.metricsBindAddress, tc.mode)
    
    		// Append additional configuration to the base yaml template
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  10. cmd/kube-scheduler/app/testing/testserver.go

    	result.TmpDir, err = os.MkdirTemp("", "kube-scheduler")
    	if err != nil {
    		return result, fmt.Errorf("failed to create temp dir: %v", err)
    	}
    
    	fs := pflag.NewFlagSet("test", pflag.PanicOnError)
    
    	opts := options.NewOptions()
    	nfs := opts.Flags
    	for _, f := range nfs.FlagSets {
    		fs.AddFlagSet(f)
    	}
    	fs.Parse(customFlags)
    
    	if opts.SecureServing.BindPort != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 10:35:59 UTC 2023
    - 5.2K bytes
    - Viewed (0)
Back to top