nats

type AddStreamOptions struct {
	StreamName string
}

type Client interface {
	server.NamedMonitor
	io.Closer

	AddStream(ctx context.Context, opts *AddStreamOptions) error
	Publish(ctx context.Context, opts *PublishOptions) error
}

type ClientOption func(*DefaultClient)

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

type EventListener func(*DefaultClient)

type PublishOptions struct {
	Subj  string
	MsgId string
	Data  []byte
}