Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for ekvs (0.05 sec)

  1. cmd/common-main.go

    	}
    	defer f.Close()
    	var ekvs []envKV
    	scanner := bufio.NewScanner(f)
    	for scanner.Scan() {
    		ekv, err := parsEnvEntry(scanner.Text())
    		if err != nil {
    			return nil, err
    		}
    		if ekv.Skip {
    			// Skips empty lines
    			continue
    		}
    		ekvs = append(ekvs, ekv)
    	}
    	if err = scanner.Err(); err != nil {
    		return nil, err
    	}
    	return ekvs, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  2. internal/config/config.go

    	}
    	return s.String()
    }
    
    // KVS - is a shorthand for some wrapper functions
    // to operate on list of key values.
    type KVS []KV
    
    // 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...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  3. internal/logger/config.go

    			cfg.HTTP[target] = http.Config{
    				Enabled:  true,
    				Endpoint: url,
    			}
    		}
    
    	case config.AuditWebhookSubSys:
    		// List legacy audit ENVs if any.
    		var loggerAuditTargets []string
    		envs := env.List(legacyEnvAuditLoggerHTTPEndpoint)
    		for _, k := range envs {
    			target := strings.TrimPrefix(k, legacyEnvAuditLoggerHTTPEndpoint+config.Default)
    			if target == legacyEnvAuditLoggerHTTPEndpoint {
    				target = config.Default
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  4. internal/config/identity/ldap/config.go

    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(ServerAddr) != ""
    }
    
    // Lookup - initializes LDAP config, overrides config, if any ENV values are set.
    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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 07 12:59:47 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. internal/config/api/api.go

    	gzipObjects := env.Get(EnvAPIGzipObjects, kvs.Get(apiGzipObjects)) == config.EnableOn
    	rootAccess := env.Get(EnvAPIRootAccess, kvs.Get(apiRootAccess)) == config.EnableOn
    
    	cfg = Config{
    		EnableODirect: enableODirect || !disableODirect,
    		GzipObjects:   gzipObjects,
    		RootAccess:    rootAccess,
    	}
    
    	var corsAllowOrigin []string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. cmd/config-current.go

    	}
    	for k, v := range notify.DefaultNotificationKVS {
    		kvs[k] = v
    	}
    	for k, v := range lambda.DefaultLambdaKVS {
    		kvs[k] = v
    	}
    	if globalIsErasure {
    		kvs[config.StorageClassSubSys] = storageclass.DefaultKVS
    		kvs[config.HealSubSys] = heal.DefaultKVS
    	}
    	config.RegisterDefaultKVS(kvs)
    
    	// Captures help for each sub-system
    	helpSubSys := config.HelpKVS{
    		config.HelpKV{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  7. internal/config/notify/parse.go

    		},
    	}
    )
    
    // GetNotifyES - returns a map of registered notification 'elasticsearch' targets
    func GetNotifyES(esKVS map[string]config.KVS, transport *http.Transport) (map[string]target.ElasticsearchArgs, error) {
    	esTargets := make(map[string]target.ElasticsearchArgs)
    	for k, kv := range config.Merge(esKVS, target.EnvElasticEnable, DefaultESKVS) {
    		enableEnv := target.EnvElasticEnable
    		if k != config.Default {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  8. internal/s3select/json/preader.go

    						// order)
    						kvs = mv.Value.(jstream.KVS)
    					} else {
    						// To be AWS S3 compatible Select for JSON needs to
    						// output non-object JSON as single column value
    						// i.e. a map with `_1` as key and value as the
    						// non-object.
    						kvs = jstream.KVS{jstream.KV{Key: "_1", Value: mv.Value}}
    					}
    					all = append(all, kvs)
    				}
    				// We don't need the input any more.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. internal/s3select/json/record.go

    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    		other = &Record{}
    	}
    	if len(other.KVS) > 0 {
    		other.KVS = other.KVS[:0]
    	}
    	other.KVS = append(other.KVS, r.KVS...)
    	return other
    }
    
    // Set - sets the value for a column name.
    func (r *Record) Set(name string, value *sql.Value) (sql.Record, error) {
    	var v interface{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  10. internal/s3select/json/reader.go

    		}
    		return nil, io.EOF
    	}
    
    	var kvs jstream.KVS
    	if v.ValueType == jstream.Object {
    		// This is a JSON object type (that preserves key
    		// order)
    		kvs = v.Value.(jstream.KVS)
    	} else {
    		// To be AWS S3 compatible Select for JSON needs to
    		// output non-object JSON as single column value
    		// i.e. a map with `_1` as key and value as the
    		// non-object.
    		kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v.Value}}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top