nats

Documentation

Index

• type Client
  • func NewClient(url string, opts ...natsio.Option) (Client, error)
  • func NewClientWithDefaults(url string) (Client, error)

Types

type Client

type Client interface {
	Publish(string, []byte) error
	ChanSubscribe(string, chan *natsio.Msg) (*natsio.Subscription, error)
}

Client is the nats client

func NewClient

func NewClient(url string, opts ...natsio.Option) (Client, error)

NewClient returns a new workflows client

func NewClientWithDefaults

func NewClientWithDefaults(url string) (Client, error)

NewClient returns a new nats client with default options