nats

Documentation

Index

• func StartServer(timeWindow int) (*natsserver.Server, error)
• type Client
  • func GetConsumer() *Client
  • func GetPublisher() *Client
  • func (client *Client) ConsumeMsg() (chan string, error)
  • func (client *Client) PublishMsg(id, msg string) error
  • func (client *Client) SetJetStreamContext(addr string) error

Functions

func StartServer

func StartServer(timeWindow int) (*natsserver.Server, error)

Types

type Client

type Client struct {
	nats.JetStreamContext
}

func GetConsumer

func GetConsumer() *Client

func GetPublisher

func GetPublisher() *Client

func (*Client) ConsumeMsg

func (client *Client) ConsumeMsg() (chan string, error)

func (*Client) PublishMsg

func (client *Client) PublishMsg(id, msg string) error

func (*Client) SetJetStreamContext

func (client *Client) SetJetStreamContext(addr string) error