nats

Documentation

Index

• func Module() fx.Option
• func NewEvent(ctx context.Context, conn *nats.Conn) repository.Event
• type Client
  • func NewClient(conn *nats.Conn) *Client
  • func (p *Client) Publish(ctx context.Context, outs []*v2.Event) (err error)

Functions

func Module

func Module() fx.Option

Module loads the NATS module providing an initialized client.

The module is only loaded once.

func NewEvent

func NewEvent(ctx context.Context, conn *nats.Conn) repository.Event

NewEvent returns an initialized NATS client that implements event repository.

Types

type Client

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

Client represents a NATS client that implements the event repository.

func NewClient

func NewClient(conn *nats.Conn) *Client

NewClient creates a new NATS client.

func (*Client) Publish

func (p *Client) Publish(ctx context.Context, outs []*v2.Event) (err error)

Publish publishes an event slice.