nats

Documentation

Index

• Variables
• func Module() dep.Module
• type Client
  • func (c *Client) Subject(ctx context.Context, subject string) (message.Mailbox, error)
• type Mailbox
  • func (m *Mailbox) Emit(ctx context.Context, message message.Message) error
  • func (m *Mailbox) ReadC(ctx context.Context) (<-chan message.Message, context.CancelFunc)

Variables

var (
	ConfNatsDsn = config.Key("nats", "dsn")
)

var (
	ModuleName = dep.Name("wk", "nats")
)

Functions

func Module

func Module() dep.Module

Types

type Client

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

func (*Client) Subject

func (c *Client) Subject(ctx context.Context, subject string) (message.Mailbox, error)

type Mailbox

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

func (*Mailbox) Emit

func (m *Mailbox) Emit(ctx context.Context, message message.Message) error

func (*Mailbox) ReadC

func (m *Mailbox) ReadC(ctx context.Context) (<-chan message.Message, context.CancelFunc)