writer

Documentation

Index

• Variables
• type Writer
  • func NewWriter(collection *mongo.Collection) *Writer
  • func (w *Writer) Write(ctx context.Context, record opencdc.Record) error

Variables

var ErrEmptyKey = errors.New("empty key")

ErrEmptyKey occurs when a record has an empty key and an operation is update or delete.

Types

type Writer

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

Writer implements a writer logic for Mongo destination.

func NewWriter

func NewWriter(collection *mongo.Collection) *Writer

NewWriter creates new instance of the Writer.

func (*Writer) Write

func (w *Writer) Write(ctx context.Context, record opencdc.Record) error

Write writes a opencdc.Record into a Destination.