Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for nsqd_address (0.17 sec)

  1. 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)
  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)
  3. 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)
  4. 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)
  5. 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)
Back to top