Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewNatsStream ¶
NewNatsStream returns a streaming client used by `Consume` and `Publish` methods retries exponentially to connect to a nats server
func RunNatsServer ¶
RunNatsServer runs the nats streaming server
Types ¶
type Option ¶
type Option func(*natsServer.Options, *stanServer.Options)
Option configures the nats server
func NatsOpts ¶
func NatsOpts(opt func(*natsServer.Options)) Option
NatsOpts allows setting Options from nats package directly
func StanOpts ¶
func StanOpts(opt func(*stanServer.Options)) Option
StanOpts allows setting Options from stan package directly
Click to show internal directories.
Click to hide internal directories.