Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 160 for KV (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top