server

Documentation

Index

• func NewNatsStream(opts ...natsjs.Option) (events.Stream, error)
• func RunNatsServer(opts ...Option) error
• type Option
  • func ClusterID(clusterID string) Option
  • func Host(url string) Option
  • func Port(port int) Option

Functions

func NewNatsStream

func NewNatsStream(opts ...natsjs.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 starts the nats server and blocks

Types

type Option

type Option func(*nserver.Options)

Option configures the nats server

func ClusterID

func ClusterID(clusterID string) Option

ClusterID sets the name for the nats cluster

func Host

func Host(url string) Option

Host sets the host URL for the nats server

func Port

func Port(port int) Option

Port sets the host URL for the nats server