- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 168 for ekvs (0.25 sec)
-
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 24 03:58:53 UTC 2022 - 3K bytes - Viewed (0) -
src/net/http/header.go
if cap(hs.kvs) < len(h) { hs.kvs = make([]keyValues, 0, len(h)) } kvs = hs.kvs[:0] for k, vv := range h { if !exclude[k] { kvs = append(kvs, keyValues{k, vv}) } } hs.kvs = kvs slices.SortFunc(hs.kvs, func(a, b keyValues) int { return strings.Compare(a.key, b.key) }) return kvs, hs } // WriteSubset writes a header in wire format.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 22:14:00 UTC 2024 - 7.6K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 25 20:31:19 UTC 2022 - 5.2K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 6.4K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 1.9K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
src/cmd/go/testdata/script/gotoolchain_loop.txt
func TestEnv(t *testing.T) { // the check is in func init in m.go } -- m.go -- package main import "os" func init() { envs := []string{ "GOTOOLCHAIN_INTERNAL_SWITCH_COUNT", "GOTOOLCHAIN_INTERNAL_SWITCH_VERSION", } for _, e := range envs { if v := os.Getenv(e); v != "" { panic("$"+e+"="+v) } } os.Stdout.WriteString("clean\n") } func main() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 31 15:20:23 UTC 2023 - 1.2K bytes - Viewed (0) -
src/crypto/x509/name_constraints_test.go
case "netscapeSGC": ekus = append(ekus, ExtKeyUsageNetscapeServerGatedCrypto) case "msSGC": ekus = append(ekus, ExtKeyUsageMicrosoftServerGatedCrypto) case "any": ekus = append(ekus, ExtKeyUsageAny) case "other": unknowns = append(unknowns, asn1.ObjectIdentifier{2, 4, 1, 2, 3}) default: return nil, nil, fmt.Errorf("unknown EKU %q", s) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 09 22:40:21 UTC 2024 - 45.2K bytes - Viewed (0) -
pkg/bootstrap/instance_test.go
merged := map[string]string{} mergeMap(merged, labels) mergeMap(merged, anno) envs := make([]string, 0) if labels != nil { envs = append(envs, encodeAsJSON(t, labels, "LABELS")) } if anno != nil { envs = append(envs, encodeAsJSON(t, anno, "ANNOTATIONS")) } return merged, envs } func encodeAsJSON(t *testing.T, data map[string]string, name string) string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 19.5K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.7K bytes - Viewed (0)