server

Documentation

Index

• func NewNatsStream(opts ...nats.Option) (events.Stream, error)
• func RunNatsServer(opts ...Option) error
• type Option
  • func Host(url string) Option
  • func NatsOpts(opt func(*natsServer.Options)) Option
  • func Port(port int) Option
  • func StanOpts(opt func(*stanServer.Options)) Option

Functions

func NewNatsStream

func NewNatsStream(opts ...nats.Option) (events.Stream, error)

NewNatsStream returns a streaming client used by `Consume` and `Publish` methods retries exponentially to connect to a nats server

func RunNatsServer

func RunNatsServer(opts ...Option) error

RunNatsServer runs the nats streaming server

Types

type Option

type Option func(*natsServer.Options, *stanServer.Options)

Option configures the nats server

func Host

func Host(url string) Option

Host sets the host URL for the nats server

func NatsOpts

func NatsOpts(opt func(*natsServer.Options)) Option

NatsOpts allows setting Options from nats package directly

func Port

func Port(port int) Option

Port sets the host URL for the nats server

func StanOpts

func StanOpts(opt func(*stanServer.Options)) Option

StanOpts allows setting Options from stan package directly