Documentation
¶
Index ¶
- Variables
- func New(opts ...Option) (*nats.Conn, func(), error)
- type Option
- func WithClientName(name string) Option
- func WithCluster(name string, routes []string) Option
- func WithClusterListen() Option
- func WithConnectOpts(opts ...nats.Option) Option
- func WithExternalURL(url string) Option
- func WithJetStream(enabled bool, storeDir ...string) Option
- func WithReadyTimeout(d time.Duration) Option
- func WithServerOpts(opts *server.Options) Option
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotReady = errors.New("nats server not ready after ready check timeout")
Functions ¶
Types ¶
type Option ¶
type Option func(*config)
func WithClientName ¶
func WithCluster ¶
func WithClusterListen ¶
func WithClusterListen() Option
func WithConnectOpts ¶
func WithExternalURL ¶
func WithJetStream ¶
func WithReadyTimeout ¶
func WithServerOpts ¶
Source Files
Click to show internal directories.
Click to hide internal directories.