- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for KV (0.04 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) -
cmd/iam-etcd-store.go
m.Store(name, p) return nil } func getMappedPolicy(kv *mvccpb.KeyValue, m *xsync.MapOf[string, MappedPolicy], basePrefix string) error { var p MappedPolicy err := getIAMConfig(&p, kv.Value, string(kv.Key)) if err != nil { if err == errConfigNotFound { return errNoSuchPolicy } return err } name := extractPathPrefixAndSuffix(string(kv.Key), basePrefix, ".json") m.Store(name, p) return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 13.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/experimental/tac/execution_metadata_exporter.cc
std::vector<float> device_costs(hardware_map.size(), -1.f); for (const auto& kv : hardware_map) { auto cost_attr = device_costs_attr.getNamed(kv.first); if (!cost_attr.has_value()) return std::nullopt; float cost = mlir::dyn_cast_or_null<mlir::FloatAttr>(cost_attr->getValue()) .getValueAsDouble(); device_costs[kv.second] = cost; } return device_costs; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 06:11:34 UTC 2024 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
opts = append([]setupOption{withDefaults}, opts...) for _, opt := range opts { opt(&setupOpts) } client := setupOpts.client(t) if setupOpts.recorderEnabled { client.KV = &clientRecorder{KV: client.KV} } store := newStore( client, setupOpts.codec, setupOpts.newFunc, setupOpts.newListFunc, setupOpts.prefix, setupOpts.resourcePrefix, setupOpts.groupResource,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
src/os/exec/exec.go
i = strings.Index(kv[1:], "=") + 1 } if i < 0 { if kv != "" { // The entry is not of the form "key=value" (as it is required to be). // Leave it as-is for now. // TODO(#52436): should we strip or reject these bogus entries? out = append(out, kv) } continue } k := kv[:i] if caseInsensitive { k = strings.ToLower(k) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 13:50:53 UTC 2024 - 21.1K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
} sel := selector.MatchLabels kv := []string{} for k, v := range sel { kv = append(kv, k+"="+v) } podsr, err := client.Kube().CoreV1().Pods(namespace).List(context.Background(), metav1.ListOptions{ TypeMeta: metav1.TypeMeta{}, LabelSelector: strings.Join(kv, ","), FieldSelector: "spec.nodeName=" + node, }) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
cmd/handler-utils.go
if v == nil { bugLogIf(ctx, errInvalidArgument) return errInvalidArgument } nv := make(textproto.MIMEHeader, len(v)) for k, kv := range v { // Canonicalize all headers, to remove any duplicates. nv[http.CanonicalHeaderKey(k)] = kv } // Save all supported headers. for _, supportedHeader := range supportedHeaders { value, ok := nv[http.CanonicalHeaderKey(supportedHeader)] if ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging.go
// Sort keys to ensure stable XDS generation for _, key := range slices.Sort(maps.Keys(labels)) { value := labels[key] kv := &otlpcommon.KeyValue{ Key: key, Value: &otlpcommon.AnyValue{Value: &otlpcommon.AnyValue_StringValue{StringValue: value.GetStringValue()}}, } attrList = append(attrList, kv) } return attrList }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 23K bytes - Viewed (0)