Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for Len (0.14 sec)

  1. istioctl/pkg/config/config.go

    			root.Scope.Debugf("Config file %q", root.IstioConfig)
    			return runList(c.OutOrStdout())
    		},
    	}
    	return listCmd
    }
    
    func runList(writer io.Writer) error {
    	// Sort flag names
    	keys := make([]string, len(settableFlags))
    	i := 0
    	for key := range settableFlags {
    		keys[i] = key
    		i++
    	}
    	sort.Strings(keys)
    	w := new(tabwriter.Writer).Init(writer, 0, 8, 5, ' ', 0)
    	fmt.Fprintf(w, "FLAG\tVALUE\tFROM\n")
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sun Jul 30 12:16:07 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  2. internal/logger/config.go

    		if err != nil {
    			return cfg, err
    		}
    		if !enabled {
    			continue
    		}
    		var brokers []xnet.Host
    		kafkaBrokers := getCfgVal(EnvKafkaBrokers, k, kv.Get(KafkaBrokers))
    		if len(kafkaBrokers) == 0 {
    			return cfg, config.Errorf("kafka 'brokers' cannot be empty")
    		}
    		for _, s := range strings.Split(kafkaBrokers, config.ValueSeparator) {
    			var host *xnet.Host
    			host, err = xnet.ParseHost(s)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  3. internal/event/config.go

    	if err := d.DecodeElement(&parsedConfig, &start); err != nil {
    		return err
    	}
    
    	// Empty queue list means user wants to delete the notification configuration.
    	if len(parsedConfig.QueueList) > 0 {
    		for i, q1 := range parsedConfig.QueueList[:len(parsedConfig.QueueList)-1] {
    			for _, q2 := range parsedConfig.QueueList[i+1:] {
    				// Removes the region from ARN if server region is not set
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 16 17:28:29 GMT 2021
    - 8.4K bytes
    - Viewed (0)
  4. internal/config/config.go

    // Empty - return if kv is empty
    func (kvs KVS) Empty() bool {
    	return len(kvs) == 0
    }
    
    // Clone - returns a copy of the KVS
    func (kvs KVS) Clone() KVS {
    	return append(make(KVS, 0, len(kvs)), kvs...)
    }
    
    // GetWithDefault - returns default value if key not set
    func (kvs KVS) GetWithDefault(key string, defaultKVS KVS) string {
    	v := kvs.Get(key)
    	if len(v) == 0 {
    		return defaultKVS.Get(key)
    	}
    	return v
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  5. internal/config/subnet/config.go

    	BaseURL string
    }
    
    var configLock sync.RWMutex
    
    // Registered indicates if cluster is registered or not
    func (c *Config) Registered() bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return len(c.APIKey) > 0
    }
    
    // ApplyEnv - applies the current subnet config to Console UI specific environment variables.
    func (c *Config) ApplyEnv() {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.License != "" {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Nov 24 17:59:35 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  6. internal/config/identity/ldap/config.go

    func Lookup(s config.Config, rootCAs *x509.CertPool) (l Config, err error) {
    	l = Config{}
    
    	// Purge all removed keys first
    	kvs := s[config.IdentityLDAPSubSys][config.Default]
    	if len(kvs) > 0 {
    		for _, k := range removedKeys {
    			kvs.Delete(k)
    		}
    		s[config.IdentityLDAPSubSys][config.Default] = kvs
    	}
    
    	if err := s.CheckValidKeys(config.IdentityLDAPSubSys, removedKeys); err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 7.9K bytes
    - Viewed (2)
  7. cmd/config.go

    }
    
    // data is optional. If nil it will be loaded from backend.
    func readServerConfig(ctx context.Context, objAPI ObjectLayer, data []byte) (config.Config, error) {
    	srvCfg := config.New()
    	var err error
    	if len(data) == 0 {
    		configFile := path.Join(minioConfigPrefix, minioConfigFile)
    		data, err = readConfig(ctx, objAPI, configFile)
    		if err != nil {
    			if errors.Is(err, errConfigNotFound) {
    				lookupConfigs(srvCfg, objAPI)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
Back to top