- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for nsqdAddress (0.07 sec)
-
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) -
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)