- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 160 for KV (0.02 sec)
-
cmd/admin-handlers-config-kv.go
if err = saveServerConfig(ctx, objectAPI, result.Cfg); err != nil { return } // Write the config input KV to history. err = saveServerConfigHistory(ctx, objectAPI, kvBytes) return } // GetConfigKVHandler - GET /minio/admin/v3/get-config-kv?key={key} // // `key` can be one of three forms: // 1. `subsys:target` -> request for config of a single subsystem and target pair.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.7K bytes - Viewed (0) -
internal/logger/config.go
DefaultLoggerWebhookKVS = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOff, }, config.KV{ Key: Endpoint, Value: "", }, config.KV{ Key: AuthToken, Value: "", }, config.KV{ Key: ClientCert, Value: "", }, config.KV{ Key: ClientKey, Value: "", }, config.KV{ Key: Proxy, Value: "", },
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.8K bytes - Viewed (0) -
internal/config/notify/legacy.go
}, config.KV{ Key: target.MySQLPort, Value: cfg.Port, }, config.KV{ Key: target.MySQLUsername, Value: cfg.User, }, config.KV{ Key: target.MySQLPassword, Value: cfg.Password, }, config.KV{ Key: target.MySQLDatabase, Value: cfg.Database, }, config.KV{ Key: target.MySQLQueueDir, Value: cfg.QueueDir, }, config.KV{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 19 04:37:54 UTC 2024 - 13.1K bytes - Viewed (0) -
internal/config/notify/parse.go
// DefaultKafkaKVS - default KV for kafka target var ( DefaultKafkaKVS = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOff, }, config.KV{ Key: target.KafkaTopic, Value: "", }, config.KV{ Key: target.KafkaBrokers, Value: "", }, config.KV{ Key: target.KafkaSASLUsername, Value: "", }, config.KV{ Key: target.KafkaSASLPassword,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 46.4K bytes - Viewed (0) -
cmd/batch-job-common-types.go
col: kv.col, msg: "key can't be empty", } } return nil } // Empty indicates if kv is not set func (kv BatchJobKV) Empty() bool { return kv.Key == "" && kv.Value == "" } // Match matches input kv with kv, value will be wildcard matched depending on the user input func (kv BatchJobKV) Match(ikv BatchJobKV) bool { if kv.Empty() { return true } if strings.EqualFold(kv.Key, ikv.Key) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 7.9K bytes - Viewed (0) -
src/log/slog/value_access_benchmark_test.go
for i := 0; i < b.N; i++ { for _, kv := range vs { if v, ok := kv.AsString(); ok { s = v } else if v, ok := kv.AsInt64(); ok { ii = v } else if v, ok := kv.AsUint64(); ok { u = v } else if v, ok := kv.AsFloat64(); ok { f = v } else if v, ok := kv.AsBool(); ok { bb = v } else if v, ok := kv.AsDuration(); ok { d = v
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 21 20:55:33 UTC 2023 - 4.3K bytes - Viewed (0) -
internal/logger/legacy.go
) // SetLoggerHTTPAudit - helper for migrating older config to newer KV format. func SetLoggerHTTPAudit(scfg config.Config, k string, args http.Config) { if !args.Enabled { // Do not enable audit targets, if not enabled return } scfg[config.AuditWebhookSubSys][k] = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: Endpoint, Value: args.Endpoint.String(), },
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Aug 03 09:47:07 UTC 2023 - 2K bytes - Viewed (0) -
internal/config/api/api.go
Key: apiListQuorum, Value: "strict", }, config.KV{ Key: apiReplicationPriority, Value: "auto", }, config.KV{ Key: apiReplicationMaxWorkers, Value: "500", }, config.KV{ Key: apiTransitionWorkers, Value: "100", }, config.KV{ Key: apiStaleUploadsCleanupInterval, Value: "6h", }, config.KV{ Key: apiStaleUploadsExpiry,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/latency_tracker.go
) // NewETCDLatencyTracker returns an implementation of // clientv3.KV that times the calls from the specified // 'delegate' KV instance in order to track latency incurred. func NewETCDLatencyTracker(delegate clientv3.KV) clientv3.KV { return &clientV3KVLatencyTracker{KV: delegate} } // clientV3KVLatencyTracker decorates a clientv3.KV instance and times // each call so we can track the latency an API request incurs in etcd
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/event.go
return nil, fmt.Errorf("etcd event received with PrevKv=nil (key=%q, modRevision=%d, type=%s)", string(e.Kv.Key), e.Kv.ModRevision, e.Type.String()) } ret := &event{ key: string(e.Kv.Key), value: e.Kv.Value, rev: e.Kv.ModRevision, isDeleted: e.Type == clientv3.EventTypeDelete, isCreated: e.IsCreate(), } if e.PrevKv != nil { ret.prevValue = e.PrevKv.Value
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 2.3K bytes - Viewed (0)