Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 56 for KV (0.06 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. 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 (1)
  6. 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)
  7. 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)
  8. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go

    	getReactors []func()
    }
    
    func newEtcdClientKVWrapper(kv clientv3.KV) *etcdClientKVWrapper {
    	return &etcdClientKVWrapper{
    		KV:             kv,
    		getCallCounter: 0,
    	}
    }
    
    func (ecw *etcdClientKVWrapper) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) {
    	resp, err := ecw.KV.Get(ctx, key, opts...)
    	ecw.getCallCounter++
    	if err != nil {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 12.3K bytes
    - Viewed (1)
  9. 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)
  10. internal/config/identity/plugin/config.go

    )
    
    var (
    	// DefaultKVS - default config for AuthN plugin config
    	DefaultKVS = config.KVS{
    		config.KV{
    			Key:   URL,
    			Value: "",
    		},
    		config.KV{
    			Key:   AuthToken,
    			Value: "",
    		},
    		config.KV{
    			Key:   RolePolicy,
    			Value: "",
    		},
    		config.KV{
    			Key:   RoleID,
    			Value: "",
    		},
    	}
    
    	defaultHelpPostfix = func(key string) string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top