pubsub

Documentation

Index

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

Types

type Writer

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

Writer implements a PubSub writer. It writes messages synchronously. It doesn't support batching/async writing.

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 opencdc.Record) error

Write writes directly and synchronously a record to a subject.

type WriterParams

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

WriterParams is an incoming params for the NewWriter function.