nats

Documentation

Index

• func NewStream(opts ...Option) (events.Stream, error)
• type Option
  • func Address(addr string) Option
  • func ClientID(id string) Option
  • func ClusterID(id string) Option
  • func TLSConfig(t *tls.Config) Option
• type Options

Functions

func NewStream

func NewStream(opts ...Option) (events.Stream, error)

NewStream returns an initialized nats stream or an error if the connection to the nats server could not be established

Types

type Option

type Option func(o *Options)

Option is a function which configures options

func Address

func Address(addr string) Option

Address of the nats cluster

func ClientID

func ClientID(id string) Option

ClientID sets the client id for the nats connection

func ClusterID

func ClusterID(id string) Option

ClusterID sets the cluster id for the nats connection

func TLSConfig

func TLSConfig(t *tls.Config) Option

TLSConfig to use when connecting to the cluster

type Options

type Options struct {
	ClusterID string
	ClientID  string
	Address   string
	TLSConfig *tls.Config
}

Options which are used to configure the nats stream