Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for connectNats (0.3 sec)

  2. github.com/minio/minio

    internal/event/target/nats_contrib_test.go 

    	clientConfig := &NATSArgs{
		Enable: true,
		Address: xnet.Host{
			Name:      "localhost",
			Port:      (xnet.Port(opts.Port)),
			IsPortSet: true,
		},
		Subject: "test",
	}
	con, err := clientConfig.connectNats()
	if err != nil {
		t.Errorf("Could not connect to nats: %v", err)
	}
	defer con.Close()
}

func TestNatsConnUserPass(t *testing.T) {
	opts := natsserver.DefaultTestOptions
	opts.Port = 14223
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  3. github.com/minio/minio

    internal/event/target/nats_tls_contrib_test.go 

    			IsPortSet: true,
		},
		Subject:       "test",
		Secure:        true,
		CertAuthority: path.Join("testdata", "contrib", "certs", "root_ca_cert.pem"),
	}

	con, err := clientConfig.connectNats()
	if err != nil {
		t.Errorf("Could not connect to nats: %v", err)
	}
	defer con.Close()
}

func TestNatsConnTLSClientAuthorization(t *testing.T) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  4. github.com/minio/minio

    internal/event/target/nats.go 

    		if !filepath.IsAbs(n.QueueDir) {
			return errors.New("queueDir path should be absolute")
		}
	}

	return nil
}

// To obtain a nats connection from args.
func (n NATSArgs) connectNats() (*nats.Conn, error) {
	connOpts := []nats.Option{nats.Name("Minio Notification"), nats.MaxReconnects(-1)}
	if n.Username != "" && n.Password != "" {
		connOpts = append(connOpts, nats.UserInfo(n.Username, n.Password))
	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Feb 27 18:11:55 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  5. github.com/golang/go

    api/go1.3.txt 

    pkg syscall (freebsd-386), const SYS_BINDAT ideal-int
pkg syscall (freebsd-386), const SYS_CHFLAGSAT = 540
pkg syscall (freebsd-386), const SYS_CHFLAGSAT ideal-int
pkg syscall (freebsd-386), const SYS_CONNECTAT = 539
pkg syscall (freebsd-386), const SYS_CONNECTAT ideal-int
pkg syscall (freebsd-386), const SYS_PIPE2 = 542
pkg syscall (freebsd-386), const SYS_PIPE2 ideal-int
pkg syscall (freebsd-386), const SYS_PROCCTL = 544
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Jun 02 02:45:00 GMT 2014
    - 117K bytes
    - Viewed (0)
  6. github.com/golang/go

    api/go1.14.txt 

    pkg syscall (freebsd-arm64), const SYS_CONNECT = 98
pkg syscall (freebsd-arm64), const SYS_CONNECT ideal-int
pkg syscall (freebsd-arm64), const SYS_CONNECTAT = 539
pkg syscall (freebsd-arm64), const SYS_CONNECTAT ideal-int
pkg syscall (freebsd-arm64), const SYS_CPUSET = 484
pkg syscall (freebsd-arm64), const SYS_CPUSET ideal-int
pkg syscall (freebsd-arm64), const SYS_CPUSET_GETAFFINITY = 487
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Feb 17 20:31:46 GMT 2023
    - 508.9K bytes
    - Viewed (0)
  7. github.com/golang/go

    api/go1.20.txt 

    pkg syscall (freebsd-riscv64), const SYS_CONNECT = 98 #53466
pkg syscall (freebsd-riscv64), const SYS_CONNECT ideal-int #53466
pkg syscall (freebsd-riscv64), const SYS_CONNECTAT = 539 #53466
pkg syscall (freebsd-riscv64), const SYS_CONNECTAT ideal-int #53466
pkg syscall (freebsd-riscv64), const SYS_CPUSET = 484 #53466
pkg syscall (freebsd-riscv64), const SYS_CPUSET ideal-int #53466
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Feb 17 21:23:32 GMT 2023
    - 602.6K bytes
    - Viewed (0)
Back to top