jetstream

Documentation

Index

• type Writer
  • func NewWriter(params WriterParams) (*Writer, error)
  • func (w *Writer) Close() error
  • func (w *Writer) Write(record sdk.Record) error
• type WriterParams

Types

type Writer

type Writer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Writer implements a JetStream writer. It writes messages asynchronously.

func NewWriter

func NewWriter(params WriterParams) (*Writer, error)

NewWriter creates new instance of the Writer.

func (*Writer) Close

func (w *Writer) Close() error

Close closes the underlying NATS connection.

func (*Writer) Write

func (w *Writer) Write(record sdk.Record) error

Write synchronously writes a record.

type WriterParams

type WriterParams struct {
	Conn          *nats.Conn
	Subject       string
	RetryWait     time.Duration
	RetryAttempts int
}

WriterParams is an incoming params for the NewWriter function.