Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for nsqdAddress (0.07 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.2K bytes
    - Viewed (0)
Back to top