- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for nsqd_address (0.17 sec)
-
internal/event/target/nsq.go
xnet "github.com/minio/pkg/v2/net" ) // NSQ constants const ( NSQAddress = "nsqd_address" NSQTopic = "topic" NSQTLS = "tls" NSQTLSSkipVerify = "tls_skip_verify" NSQQueueDir = "queue_dir" NSQQueueLimit = "queue_limit" EnvNSQEnable = "MINIO_NOTIFY_NSQ_ENABLE" EnvNSQAddress = "MINIO_NOTIFY_NSQ_NSQD_ADDRESS" EnvNSQTopic = "MINIO_NOTIFY_NSQ_TOPIC"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0) -
docs/bucket/notifications/README.md
To update the configuration, use `mc admin config get` command to get the current configuration for `notify_nsq`. ``` KEY: notify_nsq[:name] publish bucket notifications to NSQ endpoints ARGS: nsqd_address* (address) NSQ server address e.g. '127.0.0.1:4150' topic* (string) NSQ topic tls (on|off) set to 'on' to enable TLS
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
cmd/testdata/undeleteable-object.tgz
async","value":"off"},{"key":"streaming_max_pub_acks_in_flight","value":"0"},{"key":"streaming_cluster_id","value":""},{"key":"queue_dir","value":""},{"key":"queue_limit","value":"0"}]},"notify_nsq":{"_":[{"key":"enable","value":"off"},{"key":"nsqd_address","value":""},{"key":"topic","value":""},{"key":"tls","value":"off"},{"key":"tls_skip_verify","value":"off"},{"key":"queue_dir","value":""},{"key":"queue_limit","value":"0"}]},"notify_postgres":{"_":[{"key":"enable","value":"off"},{"key":"format","v...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Viewed (0) -
internal/config/notify/legacy.go
return err } s[config.NotifyNSQSubSys][nsqName] = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: target.NSQAddress, Value: cfg.NSQDAddress.String(), }, config.KV{ Key: target.NSQTopic, Value: cfg.Topic, }, config.KV{ Key: target.NSQTLS, Value: config.FormatBool(cfg.TLS.Enable), },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/event/target/nsq_test.go
}, { name: "test4_emptynsqdaddr", fields: fields{ Enable: true, NSQDAddress: xnet.Host{}, Topic: "topic", }, wantErr: true, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { n := NSQArgs{ Enable: tt.fields.Enable, NSQDAddress: tt.fields.NSQDAddress, Topic: tt.fields.Topic, } if err := n.Validate(); (err != nil) != tt.wantErr {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.2K bytes - Viewed (0) -
internal/config/notify/parse.go
} queueDirEnv := target.EnvNSQQueueDir if k != config.Default { 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, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 46.4K bytes - Viewed (0) -
internal/config/notify/help.go
Key: config.Comment, Description: config.DefaultComment, Optional: true, Type: "sentence", }, } HelpNSQ = config.HelpKVS{ config.HelpKV{ Key: target.NSQAddress, Description: "NSQ server address e.g. '127.0.0.1:4150'", Type: "address", Sensitive: true, }, config.HelpKV{ Key: target.NSQTopic, Description: "NSQ topic",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0)