nats

Documentation

Index

• type Client
  • func NewClient(info *ClientInfo) (*Client, error)
  • func (c *Client) Connection() *nats.Conn
  • func (c *Client) DispatchEvent(ctx context.Context, aggregate string, payload []byte) error
  • func (c *Client) NewInbox() string
  • func (c *Client) Publish(subject string, message []byte) error
  • func (c *Client) Subscribe(ctx context.Context, consumer string, stream string, subject string, ...) (interface{}, error)
  • func (c *Client) SubscribeSync(stream string) (libdomain.EventDispatcherSubscription, error)
• type ClientInfo
• type Subscription
  • func (s *Subscription) NextMsg(timeout time.Duration) ([]byte, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Driver contains all the function needed to be recognized as a libdata driver

func NewClient

func NewClient(info *ClientInfo) (*Client, error)

func (*Client) Connection

func (c *Client) Connection() *nats.Conn

func (*Client) DispatchEvent

func (c *Client) DispatchEvent(ctx context.Context, aggregate string, payload []byte) error

func (*Client) NewInbox

func (c *Client) NewInbox() string

func (*Client) Publish

func (c *Client) Publish(subject string, message []byte) error

func (*Client) Subscribe

func (c *Client) Subscribe(ctx context.Context, consumer string, stream string, subject string, function func([]byte) error) (interface{}, error)

func (*Client) SubscribeSync

func (c *Client) SubscribeSync(stream string) (libdomain.EventDispatcherSubscription, error)

type ClientInfo

type ClientInfo struct {
	URL string
}

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

func (*Subscription) NextMsg

func (s *Subscription) NextMsg(timeout time.Duration) ([]byte, error)