- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 65 for kv (0.01 sec)
-
internal/config/legacy.go
// SetRegion - One time migration code needed, for migrating from older config to new for server Region. func SetRegion(c Config, name string) { if name == "" { return } c[RegionSubSys][Default] = KVS{ KV{ Key: RegionName, Value: name, }, }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Dec 19 20:27:06 UTC 2022 - 1.1K bytes - Viewed (0) -
internal/s3select/jstream/decoder_test.go
} // test at depth level 1 counter = 0 kvcounter := 0 decoder = NewDecoder(mkReader(body), 1) for mv = range decoder.Stream() { switch mv.Value.(type) { case KV: kvcounter++ default: counter++ } t.Logf("depth=%d offset=%d len=%d (%v)", mv.Depth, mv.Offset, mv.Length, mv.Value) } if err := decoder.Err(); err != nil { t.Fatalf("decoder error: %s", err)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.6K bytes - Viewed (0) -
cmd/batch-handlers.go
return false } tagMap = t.ToMap() } for _, kv := range r.Flags.Filter.Tags { for t, v := range tagMap { if kv.Match(BatchJobKV{Key: t, Value: v}) { return true } } } // None of the provided tags filter match skip the object return false } for _, kv := range r.Flags.Filter.Metadata { for k, v := range oi.UserDefined {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.5K bytes - Viewed (0) -
docs/language_names.yml
iu: ᐃᓄᒃᑎᑐᑦ ja: 日本語 jv: basa Jawa ka: ქართული kg: Kikongo ki: Gĩkũyũ kj: Kuanyama kk: қазақ тілі kl: kalaallisut km: ខេមរភាសា kn: ಕನ್ನಡ ko: 한국어 kr: Kanuri ks: कश्मीरी ku: Kurdî kv: коми кыв kw: Kernewek ky: Кыргызча la: latine lb: Lëtzebuergesch lg: Luganda li: Limburgs ln: Lingála lo: ພາສາ lt: lietuvių kalba lu: Tshiluba lv: latviešu valoda mg: fiteny malagasy
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Mon Jan 22 19:42:53 UTC 2024 - 3.1K bytes - Viewed (0) -
internal/config/drive/drive.go
EnvMaxDriveTimeoutLegacy = "_MINIO_DRIVE_MAX_TIMEOUT" EnvMaxDiskTimeoutLegacy = "_MINIO_DISK_MAX_TIMEOUT" ) // DefaultKVS - default KVS for drive var DefaultKVS = config.KVS{ config.KV{ Key: MaxTimeout, Value: "30s", }, } var configLk sync.RWMutex // Config represents the subnet related configuration type Config struct { // MaxTimeout - maximum timeout for a drive operation
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Nov 11 14:51:43 UTC 2024 - 3K bytes - Viewed (0) -
cmd/batch-expire.go
t, err := tags.ParseObjectTags(obj.UserTags) if err != nil { return false } tagMap = t.ToMap() } for _, kv := range ef.Tags { // Object (version) must match all tags specified in // the filter var match bool for t, v := range tagMap { if kv.Match(BatchJobKV{Key: t, Value: v}) { match = true } } if !match { return false } } }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Apr 22 11:16:32 UTC 2025 - 23K bytes - Viewed (0) -
internal/s3select/json/reader.go
} 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}} } dstRec, ok := dst.(*Record) if !ok { dstRec = &Record{} } dstRec.KVS = kvs dstRec.SelectFormat = sql.SelectFmtJSON return dstRec, nil }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 3.2K bytes - Viewed (0) -
docs/bigdata/README.md
 ``` sudo pip install yq alias kv-pairify='yq ".configuration[]" | jq ".[]" | jq -r ".name + \"=\" + .value"' ```
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 14.7K bytes - Viewed (0) -
internal/config/identity/tls/config.go
} return cfg, nil } const ( skipVerify = "skip_verify" ) // DefaultKVS is the default K/V config system for // the STS TLS API. var DefaultKVS = config.KVS{ config.KV{ Key: skipVerify, Value: "off", }, } // Help is the help and description for the STS API K/V configuration. var Help = config.HelpKVS{ config.HelpKV{ Key: skipVerify,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.6K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
var value any if v, ok := nextRow[col.FlatName()]; ok { value, err = convertFromAnnotation(col.Element(), v) if err != nil { return nil, errParquetParsingError(err) } } kvs = append(kvs, jstream.KV{Key: col.FlatName(), Value: value}) } // Reuse destination if we can. dstRec, ok := dst.(*jsonfmt.Record) if !ok { dstRec = &jsonfmt.Record{} } dstRec.SelectFormat = sql.SelectFmtParquet
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.5K bytes - Viewed (0)