destination

Documentation

Index

• func NewDestination() sdk.Destination
• type Destination
  • func (d *Destination) Configure(ctx context.Context, cfg commonsConfig.Config) error
  • func (d *Destination) Open(ctx context.Context) error
  • func (d *Destination) Parameters() commonsConfig.Parameters
  • func (d *Destination) Teardown(ctx context.Context) error
  • func (d *Destination) Write(ctx context.Context, records []opencdc.Record) (int, error)
• type Writer

Functions

func NewDestination

func NewDestination() sdk.Destination

NewDestination initialises a new Destination.

Types

type Destination

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

Destination is a Redshift destination plugin.

func (*Destination) Configure

func (d *Destination) Configure(ctx context.Context, cfg commonsConfig.Config) error

Configure parses and stores configurations, returns an error in case of invalid configuration.

func (*Destination) Open

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

Open makes sure everything is prepared to receive records.

func (*Destination) Parameters

func (d *Destination) Parameters() commonsConfig.Parameters

Parameters returns a map of named Parameters that describe how to configure the Destination.

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, records []opencdc.Record) (int, error)

Write writes records into a Destination.

type Writer

type Writer interface {
	Insert(context.Context, opencdc.Record) error
	Update(context.Context, opencdc.Record) error
	Delete(context.Context, opencdc.Record) error
	Stop() error
}

Writer defines a writer interface needed for the Destination.