destination

Documentation

Index

• Constants
• func NewDestination() sdk.Destination
• type Config
  • func (Config) Parameters() map[string]config.Parameter
• type Destination
  • func (d *Destination) Configure(ctx context.Context, cfg config.Config) error
  • func (d *Destination) Open(ctx context.Context) (err error)
  • func (d *Destination) Parameters() config.Parameters
  • func (d *Destination) Teardown(_ context.Context) error
  • func (d *Destination) Write(ctx context.Context, records []opencdc.Record) (int, error)

Constants

const (
	GroupIDKey = "groupID"
	DedupIDKey = "deduplicationID"
)

const (
	ConfigAwsAccessKeyId     = "aws.accessKeyId"
	ConfigAwsDelayTime       = "aws.delayTime"
	ConfigAwsQueue           = "aws.queue"
	ConfigAwsRegion          = "aws.region"
	ConfigAwsSecretAccessKey = "aws.secretAccessKey"
	ConfigAwsUrl             = "aws.url"
	ConfigBatchSize          = "batchSize"
)

Functions

func NewDestination

func NewDestination() sdk.Destination

Types

type Config

type Config struct {
	common.Config

	// QueueName is the sqs queue name
	QueueName string `json:"aws.queue" default:"{{ index .Metadata \"opencdc.collection\" }}"`

	// MessageDelay represents the length of time, in seconds, for which a
	// specific message is delayed
	MessageDelay int32 `json:"aws.delayTime"`

	// BatchSize represents the amount of records written per batch
	BatchSize int `json:"batchSize" default:"10"`
}

func (Config) Parameters

func (Config) Parameters() map[string]config.Parameter

type Destination

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

func (*Destination) Configure

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

func (*Destination) Open

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

func (*Destination) Parameters

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

func (*Destination) Teardown

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

func (*Destination) Write

func (d *Destination) Write(ctx context.Context, records []opencdc.Record) (int, error)