- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 312 for Enable (0.17 sec)
-
internal/config/notify/legacy.go
func SetNotifyKafka(s config.Config, name string, cfg target.KafkaArgs) error { if !cfg.Enable { return nil } if err := cfg.Validate(); err != nil { return err } s[config.NotifyKafkaSubSys][name] = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: target.KafkaBrokers, Value: func() string {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/config/lambda/parse.go
enableEnv := target.EnvWebhookEnable if k != config.Default { enableEnv = enableEnv + config.Default + k } enabled, err := config.ParseBool(env.Get(enableEnv, kv.Get(config.Enable))) if err != nil { return nil, err } if !enabled { continue } urlEnv := target.EnvWebhookEndpoint if k != config.Default { urlEnv = urlEnv + config.Default + k }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/config/callhome/help.go
} // HelpCallhome - provides help for callhome config HelpCallhome = config.HelpKVS{ config.HelpKV{ Key: Enable, Type: "on|off", Description: "set to enable callhome" + defaultHelpPostfix(Enable), Optional: true, }, config.HelpKV{ Key: Frequency, Type: "duration",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jun 06 23:14:52 GMT 2022 - 1.4K bytes - Viewed (0) -
internal/config/compress/help.go
var ( defaultHelpPostfix = func(key string) string { return config.DefaultHelpPostfix(DefaultKVS, key) } Help = config.HelpKVS{ config.HelpKV{ Key: config.Enable, Description: "Enable or disable object compression", Type: "on|off", Optional: true, Sensitive: false, }, config.HelpKV{ Key: Extensions,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jul 17 15:43:14 GMT 2022 - 1.8K bytes - Viewed (0) -
internal/config/notify/parse.go
queueDirEnv = queueDirEnv + config.Default + k } nsqArgs := target.NSQArgs{ Enable: enabled, NSQDAddress: *nsqdAddress, Topic: env.Get(topicEnv, kv.Get(target.NSQTopic)), QueueDir: env.Get(queueDirEnv, kv.Get(target.NSQQueueDir)), QueueLimit: queueLimit, } nsqArgs.TLS.Enable = env.Get(tlsEnableEnv, kv.Get(target.NSQTLS)) == config.EnableOn
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 46.4K bytes - Viewed (0) -
internal/event/target/redis.go
EnvRedisQueueDir = "MINIO_NOTIFY_REDIS_QUEUE_DIR" EnvRedisQueueLimit = "MINIO_NOTIFY_REDIS_QUEUE_LIMIT" ) // RedisArgs - Redis target arguments. type RedisArgs struct { Enable bool `json:"enable"` Format string `json:"format"` Addr xnet.Host `json:"address"` Password string `json:"password"` User string `json:"user"` Key string `json:"key"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/event/target/nsq_test.go
func TestNSQArgs_Validate(t *testing.T) { type fields struct { Enable bool NSQDAddress xnet.Host Topic string TLS struct { Enable bool SkipVerify bool } } tests := []struct { name string fields fields wantErr bool }{ { name: "test1_missing_topic", fields: fields{ Enable: true, NSQDAddress: xnet.Host{ Name: "127.0.0.1",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.2K bytes - Viewed (0) -
internal/config/config_test.go
}, }, // Keys with spaces in between { input: `enable=on format=namespace connection_string=" host=localhost port=5432 dbname = cesnietor sslmode=disable" table=holicrayoli`, keys: []string{"enable", "connection_string", "comment", "format", "table"}, expectedFields: map[string]struct{}{ `enable=on`: {}, `format=namespace`: {},
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Aug 18 22:55:17 GMT 2022 - 4.2K bytes - Viewed (0) -
internal/config/config.go
for _, hkv := range hkvs { var enabled bool if enableRequired { enabled = currKVS.Get(Enable) == EnableOn } else { // when enable arg is not required // then it is implicit on for the sub-system. enabled = true } v, _ := currKVS.Lookup(hkv.Key) if v == "" && !hkv.Optional && enabled { // Return error only if the // key is enabled, for state=off // let it be empty.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
internal/config/cache/help.go
return config.DefaultHelpPostfix(DefaultKVS, key) } // Help - provides help for cache config Help = config.HelpKVS{ config.HelpKV{ Key: Enable, Type: "on|off", Description: "set to enable remote cache plugin" + defaultHelpPostfix(Enable), Optional: true, }, config.HelpKV{ Key: Endpoint, Type: "string",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Dec 22 00:57:13 GMT 2023 - 1.5K bytes - Viewed (0)