Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NATS (0.01 sec)

  1. internal/event/target/nats_contrib_test.go

     * limitations under the License.
     */
    
    package target
    
    import (
    	"testing"
    
    	xnet "github.com/minio/pkg/v3/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{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. internal/event/target/nats_tls_contrib_test.go

     * limitations under the License.
     */
    
    package target
    
    import (
    	"path"
    	"path/filepath"
    	"testing"
    
    	xnet "github.com/minio/pkg/v3/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{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. 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"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  4. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  5. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. docs/tls/README.md

    ```
    
    ## 4. Install Certificates from Third-party CAs
    
    MinIO can connect to other servers, including MinIO nodes or other server types such as NATs and Redis. If these servers use certificates that were not registered with a known CA, add trust for these certificates to MinIO Server by placing these certificates under one of the following MinIO configuration paths:
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 8.4K bytes
    - Viewed (0)
Back to top