Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for ekvs (0.13 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. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  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. ci/official/envs/linux_x86_build

    # limitations under the License.
    # ==============================================================================
    
    # Temporary envs file while we migrate to the new docker image.
    # Once the migration is complete, this file will be removed.
    source ci/official/envs/linux_x86
    TFCI_DOCKER_IMAGE=us-central1-docker.pkg.dev/tensorflow-sigs/tensorflow/ml-build:latest
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 28 17:57:41 UTC 2024
    - 1011 bytes
    - Viewed (0)
Back to top