Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for nsqd_address (0.05 sec)

  1. internal/event/target/nsq.go

    	EnvNSQQueueLimit    = "MINIO_NOTIFY_NSQ_QUEUE_LIMIT"
    )
    
    // NSQArgs - NSQ target arguments.
    type NSQArgs struct {
    	Enable      bool      `json:"enable"`
    	NSQDAddress xnet.Host `json:"nsqdAddress"`
    	Topic       string    `json:"topic"`
    	TLS         struct {
    		Enable     bool `json:"enable"`
    		SkipVerify bool `json:"skipVerify"`
    	} `json:"tls"`
    	QueueDir   string `json:"queueDir"`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  2. 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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K 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),
    		},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Apr 27 04:30:57 UTC 2025
    - 13.3K 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,
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 47.5K bytes
    - Viewed (0)
Back to top