- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 82 for KV (0.03 sec)
-
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) -
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) -
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) -
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) -
cmd/metacache-marker.go
tags := strings.Split(tag, ",") for _, tag := range tags { kv := strings.Split(tag, ":") if len(kv) < 2 { continue } switch kv[0] { case "minio_cache": if kv[1] != markerTagVersion { continue } case "id": o.ID = kv[1] case "return": o.ID = mustGetUUID() o.Create = true case "p": // pool v, err := strconv.ParseInt(kv[1], 10, 64) if err != nil { o.ID = mustGetUUID()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.5K bytes - Viewed (0) -
internal/config/lambda/parse.go
} ) // DefaultWebhookKVS - default KV for webhook config var ( DefaultWebhookKVS = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOff, }, config.KV{ Key: target.WebhookEndpoint, Value: "", }, config.KV{ Key: target.WebhookAuthToken, Value: "", }, config.KV{ Key: target.WebhookClientCert, Value: "", },
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
pkg/test/echo/parse.go
matches := requestHeaderFieldRegex.FindAllStringSubmatch(output, -1) for _, kv := range matches { sl := strings.SplitN(kv[1], ":", 2) if len(sl) != 2 { continue } out.RequestHeaders.Set(sl[0], sl[1]) } matches = responseHeaderFieldRegex.FindAllStringSubmatch(output, -1) for _, kv := range matches { sl := strings.SplitN(kv[1], ":", 2) if len(sl) != 2 { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 23 22:25:46 UTC 2022 - 4.3K bytes - Viewed (0) -
test/slice3.go
continue } expr := base + "[" + i + ":" + j + ":" + k + "]" var xbase, xlen, xcap int if iv > jv || jv > kv || kv > Cap || iv < 0 || jv < 0 || kv < 0 { xbase, xlen, xcap = -1, -1, -1 } else { xbase = iv xlen = jv - iv xcap = kv - iv } fmt.Fprintf(bout, "\tcheckSlice(%q, func() []byte { return %s }, %d, %d, %d)\n", expr, expr, xbase, xlen, xcap)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 2.9K bytes - Viewed (0) -
internal/config/etcd/etcd.go
) // DefaultKVS - default KV settings for etcd. var ( DefaultKVS = config.KVS{ config.KV{ Key: Endpoints, Value: "", }, config.KV{ Key: PathPrefix, Value: "", }, config.KV{ Key: CoreDNSPath, Value: "/skydns", }, config.KV{ Key: ClientCert, Value: "", }, config.KV{ Key: ClientCertKey, Value: "", }, }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.8K bytes - Viewed (0)