client

Documentation

Index

• func NatsSetupConnOptions(name string) []natsGo.Option
• func New(conf Conf) nats
• type Conf
• type Nats
• type NatsPubType

Functions

func NatsSetupConnOptions

func NatsSetupConnOptions(name string) []natsGo.Option

natsSetupConnOptions setup the Nats connection option such as reconnect

func New

func New(conf Conf) nats

Types

type Conf

type Conf struct {
	Host string
	Port string
}

type Nats

type Nats interface {
	Connect(opts []natsGo.Option) error
	Disconnect()
	Subscribe(subject string, handler natsGo.MsgHandler) (*natsGo.Subscription, error)
	CreatePublisher() NatsPubType
	Publish(subject string, payload string) error
}

type NatsPubType

type NatsPubType func(thingId string, payload string) error