destination

Documentation

Index

• Variables
• func NewDestination() sdk.Destination
• type Destination
  • func (d *Destination) Configure(ctx context.Context, cfg map[string]string) error
  • func (d *Destination) Open(ctx context.Context) error
  • func (d *Destination) Teardown(ctx context.Context) error
  • func (d *Destination) Write(ctx context.Context, record sdk.Record) error

Variables

var (
	// ErrEmptyPayload occurs when a provided payload is empty.
	ErrEmptyPayload = errors.New("payload cannot be empty")
	// ErrEmptyKey occurs when there is no value for key.
	ErrEmptyKey = errors.New("key value must be provided")
	// ErrCompositeKeysNotSupported occurs when there are more than one key in a Key map.
	ErrCompositeKeysNotSupported = errors.New("composite keys not yet supported")
)

Functions

func NewDestination

func NewDestination() sdk.Destination

NewDestination creates new instance of the Destination.

Types

type Destination

type Destination struct {
	sdk.UnimplementedDestination
	// contains filtered or unexported fields
}

Destination Materialize Connector persists records to an Materialize database.

func (*Destination) Configure

func (d *Destination) Configure(ctx context.Context, cfg map[string]string) error

Configure parses and initializes the config.

func (*Destination) Open

func (d *Destination) Open(ctx context.Context) error

Open makes sure everything is prepared to receive records.

func (*Destination) Teardown

func (d *Destination) Teardown(ctx context.Context) error

Teardown gracefully closes connections.

func (*Destination) Write

func (d *Destination) Write(ctx context.Context, record sdk.Record) error

Write writes a record into a Destination.