Versions in this module Expand all Collapse all v0 v0.1.3 Jun 20, 2022 Changes in this version + var ConfNatsDsn = config.Key("nats", "dsn") + var ModuleName = dep.Name("wk", "nats") + func Module() dep.Module + type Client struct + func (c *Client) Subject(ctx context.Context, subject string) (message.Mailbox, error) + type Mailbox struct + func (m *Mailbox) Emit(ctx context.Context, message message.Message) error + func (m *Mailbox) ReadC(ctx context.Context) (<-chan message.Message, context.CancelFunc)