Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 79 for ekvs (0.06 sec)

  1. 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)
  2. 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)
  3. internal/config/compress/compress.go

    		}
    	}
    	return includes, nil
    }
    
    // LookupConfig - lookup compression config.
    func LookupConfig(kvs config.KVS) (Config, error) {
    	var err error
    	cfg := Config{}
    	if err = config.CheckValidKeys(config.CompressionSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	compress := env.Get(EnvCompressState, kvs.Get(config.Enable))
    	if compress == "" {
    		compress = env.Get(EnvCompress, "")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. 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)
  5. internal/config/browser/browser.go

    		return cfg, err
    	}
    
    	hstsIncludeSubdomains := env.Get(EnvBrowserHSTSIncludeSubdomains, kvs.GetWithDefault(browserHSTSIncludeSubdomains, DefaultKVS)) == config.EnableOn
    	hstsPreload := env.Get(EnvBrowserHSTSPreload, kvs.Get(browserHSTSPreload)) == config.EnableOn
    
    	hstsSeconds, err := strconv.Atoi(env.Get(EnvBrowserHSTSSeconds, kvs.GetWithDefault(browserHSTSSeconds, DefaultKVS)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. internal/config/batch/batch.go

    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	if err = config.CheckValidKeys(config.BatchSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	cfg.ReplicationWorkersWait = 0
    	cfg.KeyRotationWorkersWait = 0
    	cfg.ExpirationWorkersWait = 0
    
    	rduration, err := time.ParseDuration(env.Get(EnvReplicationWorkersWait, kvs.GetWithDefault(ReplicationWorkersWait, DefaultKVS)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. internal/config/heal/heal.go

    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	if err = config.CheckValidKeys(config.HealSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	bitrot := env.Get(EnvBitrot, kvs.GetWithDefault(Bitrot, DefaultKVS))
    	if _, err = parseBitrotConfig(bitrot); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. internal/config/identity/tls/config.go

    		return 0, auth.ErrInvalidDuration
    	}
    	return dur, nil
    }
    
    // Lookup returns a new Config by merging the given K/V config
    // system with environment variables.
    func Lookup(kvs config.KVS) (Config, error) {
    	if err := config.CheckValidKeys(config.IdentityTLSSubSys, kvs, DefaultKVS); err != nil {
    		return Config{}, err
    	}
    	cfg := Config{}
    	var err error
    	v := env.Get(EnvIdentityTLSEnabled, "")
    	if v == "" {
    		return cfg, nil
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. internal/s3select/sql/statement.go

    		return nil, errDataSource(errors.New("path not supported"))
    	}
    	switch rec := rawVal.(type) {
    	case jstream.KVS:
    		txedRec, _, err := jsonpathEval(e.selectAST.From.Table.PathExpr[1:], rec)
    		if err != nil {
    			return nil, err
    		}
    
    		var kvs jstream.KVS
    		switch v := txedRec.(type) {
    		case jstream.KVS:
    			kvs = v
    
    		case []interface{}:
    			recs := make([]*Record, len(v))
    			for i, val := range v {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. internal/config/ilm/ilm.go

    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    	cfg = Config{
    		TransitionWorkers: 100,
    		ExpirationWorkers: 100,
    	}
    
    	if err = config.CheckValidKeys(config.ILMSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	tw, err := strconv.Atoi(env.Get(EnvILMTransitionWorkers, kvs.GetWithDefault(transitionWorkers, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 1.9K bytes
    - Viewed (0)
Back to top