nats

type Options struct {
	Url           string
	MaxReconnects int
	ReconnectWait time.Duration
}

type Plugin func(context.Context, *nats.Conn) error

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

type PublisherMiddleware interface {
	Before(context.Context, *nats.Conn, *nats.Msg) (context.Context, error)
	After(context.Context) error
}

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