nats

Documentation

Index

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

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 MessageWithContext, error)

func (*Client) PublishMsg

func (client *Client) PublishMsg(ctx context.Context, id, msg string) error

func (*Client) SetJetStreamContext

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

type MessageWithContext

type MessageWithContext struct {
	Ctx  context.Context
	Data []byte
}