- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for Kats (0.15 sec)
-
internal/event/target/nats_tls_contrib_test.go
package target import ( "path" "path/filepath" "testing" xnet "github.com/minio/pkg/v2/net" natsserver "github.com/nats-io/nats-server/v2/test" ) func TestNatsConnTLSCustomCA(t *testing.T) { s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls.conf")) defer s.Shutdown() clientConfig := &NATSArgs{ Enable: true, Address: xnet.Host{ Name: "localhost",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.1K bytes - Viewed (0) -
internal/config/notify/config.go
Kafka map[string]target.KafkaArgs `json:"kafka"` MQTT map[string]target.MQTTArgs `json:"mqtt"` MySQL map[string]target.MySQLArgs `json:"mysql"` NATS map[string]target.NATSArgs `json:"nats"` NSQ map[string]target.NSQArgs `json:"nsq"` PostgreSQL map[string]target.PostgreSQLArgs `json:"postgresql"` Redis map[string]target.RedisArgs `json:"redis"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.8K bytes - Viewed (0) -
internal/event/target/nats_contrib_test.go
* limitations under the License. */ package target import ( "testing" xnet "github.com/minio/pkg/v2/net" natsserver "github.com/nats-io/nats-server/v2/test" ) func TestNatsConnPlain(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14222 s := natsserver.RunServer(&opts) defer s.Shutdown() clientConfig := &NATSArgs{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/config-versions.go
} // ConsoleLogger is introduced to workaround the dependency about logrus type ConsoleLogger struct { Enable bool `json:"enable"` } // serverConfigV33 is just like version '32', removes clientID from NATS and MQTT, and adds queueDir, queueLimit in all notification targets. type serverConfigV33 struct { quick.Config `json:"-"` // ignore interfaces Version string `json:"version"` // S3 API configuration.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:05:24 GMT 2023 - 2.5K bytes - Viewed (0) -
cmd/config-migrate.go
} for k, args := range cfg.Notify.MQTT { notify.SetNotifyMQTT(newCfg, k, args) } for k, args := range cfg.Notify.MySQL { notify.SetNotifyMySQL(newCfg, k, args) } for k, args := range cfg.Notify.NATS { notify.SetNotifyNATS(newCfg, k, args) } for k, args := range cfg.Notify.NSQ { notify.SetNotifyNSQ(newCfg, k, args) } for k, args := range cfg.Notify.PostgreSQL {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:05:24 GMT 2023 - 5.4K bytes - Viewed (0)