- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 160 for KV (0.02 sec)
-
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) -
internal/config/config.go
} // Delete - deletes the key if present from the KV list. func (kvs *KVS) Delete(key string) { for i, kv := range *kvs { if kv.Key == key { *kvs = append((*kvs)[:i], (*kvs)[i+1:]...) return } } } // LookupKV returns the KV by its key func (kvs KVS) LookupKV(key string) (KV, bool) { for _, kv := range kvs { if kv.Key == key { return kv, true } } return KV{}, false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.8K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_client.go
klog.Infof("Attaching lease to %d entries", len(objectsResp.Kvs)) for _, kv := range objectsResp.Kvs { putResp, err := v3client.KV.Put(ctx, string(kv.Key), string(kv.Value), clientv3.WithLease(lease.ID), clientv3.WithPrevKV()) if err != nil { klog.Errorf("Error while attaching lease to: %s", string(kv.Key)) } if !bytes.Equal(putResp.PrevKv.Value, kv.Value) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 6.6K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
config.KV{ Key: ClaimUserinfo, Value: "", }, config.KV{ Key: RolePolicy, Value: "", }, config.KV{ Key: ClaimPrefix, Value: "", }, config.KV{ Key: RedirectURI, Value: "", }, config.KV{ Key: RedirectURIDynamic, Value: "off", }, config.KV{ Key: Scopes, Value: "", }, config.KV{ Key: Vendor,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16.5K bytes - Viewed (0) -
internal/config/scanner/scanner.go
Cycle time.Duration } // DefaultKVS - default KV config for heal settings var DefaultKVS = config.KVS{ config.KV{ Key: Speed, Value: "default", }, config.KV{ Key: IdleSpeed, Value: "", HiddenIfEmpty: true, }, config.KV{ Key: ExcessVersions, Value: "100", }, config.KV{ Key: ExcessFolders, Value: "50000", },
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/config/policy/opa/config.go
func LookupConfig(kv config.KVS, transport *http.Transport, closeRespFn func(io.ReadCloser)) (Args, error) { args := Args{} if err := config.CheckValidKeys(config.PolicyOPASubSys, kv, DefaultKVS); err != nil { return args, err } opaURL := env.Get(EnvIamOpaURL, "") if opaURL == "" { opaURL = env.Get(EnvPolicyOpaURL, kv.Get(URL)) if opaURL == "" { return args, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.2K bytes - Viewed (0)