Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for connectNats (0.06 sec)

  1. 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))
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
Back to top