Documentation ¶ Index ¶ func NewNatsConnection(url string, subject string, converter func(log.Log) []byte) (consumer.Consumer, error) type Nats func (n *Nats) Close() error func (n *Nats) Write(value log.Log) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewNatsConnection ¶ func NewNatsConnection(url string, subject string, converter func(log.Log) []byte) (consumer.Consumer, error) Types ¶ type Nats ¶ type Nats struct { // contains filtered or unexported fields } func (*Nats) Close ¶ func (n *Nats) Close() error func (*Nats) Write ¶ func (n *Nats) Write(value log.Log) error Source Files ¶ View all Source files nats.go Click to show internal directories. Click to hide internal directories.