io

Documentation

Index

• type NatsWriter
  • func NewNatsWriter(server string, subject string) (*NatsWriter, error)
  • func (w *NatsWriter) Write(b []byte) (int, error)

Types

type NatsWriter

type NatsWriter struct {
	Conn    *nats.Conn
	Subject string
}

NatsWriter - nats writer struct

func NewNatsWriter

func NewNatsWriter(server string, subject string) (*NatsWriter, error)

NewNatsWriter - creat new writer

func (*NatsWriter) Write

func (w *NatsWriter) Write(b []byte) (int, error)

Write - writer inteface