source

Documentation

Index

• func NewIterator(ctx context.Context, cfg IteratorConfig) error
• func NewSource() sdk.Source
• type Iterator
• type IteratorConfig
• type Position
  • func NewPosition() *Position
  • func ParseSDKPosition(position opencdc.Position) (*Position, error)
• type Source
  • func (s *Source) Ack(ctx context.Context, position opencdc.Position) error
  • func (s *Source) Configure(ctx context.Context, cfgRaw commonsConfig.Config) error
  • func (s *Source) Open(ctx context.Context, position opencdc.Position) error
  • func (s *Source) Parameters() commonsConfig.Parameters
  • func (s *Source) Read(ctx context.Context) (opencdc.Record, error)
  • func (s *Source) Teardown(ctx context.Context) error
• type TablePosition

Functions

func NewIterator

func NewIterator(ctx context.Context, cfg IteratorConfig) error

NewTableIterator creates a new iterator goroutine and polls redshift for new records.

func NewSource

func NewSource() sdk.Source

NewSource initialises a new source.

Types

type Iterator

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

type IteratorConfig

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

type Position

type Position struct {
	TablePositions *csync.Map[string, TablePosition] `json:"tablePositions"` // Use csync.Map for thread safety
}

Position represents Redshift's position.

func NewPosition

func NewPosition() *Position

NewPosition initializes a new position when sdk position is nil.

func ParseSDKPosition

func ParseSDKPosition(position opencdc.Position) (*Position, error)

ParseSDKPosition parses opencdc.Position and returns Position.

type Source

type Source struct {
	sdk.UnimplementedSource
	// contains filtered or unexported fields
}

Source is an Amazon Redshift source plugin.

func (*Source) Ack

func (s *Source) Ack(ctx context.Context, position opencdc.Position) error

Ack logs the debug event with the position.

func (*Source) Configure

func (s *Source) Configure(ctx context.Context, cfgRaw commonsConfig.Config) error

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

func (*Source) Open

func (s *Source) Open(ctx context.Context, position opencdc.Position) error

Open parses the position and initializes the iterator.

func (*Source) Parameters

func (s *Source) Parameters() commonsConfig.Parameters

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

func (*Source) Read

func (s *Source) Read(ctx context.Context) (opencdc.Record, error)

Read returns the next record.

func (*Source) Teardown

func (s *Source) Teardown(ctx context.Context) error

Teardown gracefully shutdown connector.

type TablePosition

type TablePosition struct {
	// LastProcessedValue represents the last processed value from ordering column.
	LastProcessedValue any `json:"lastProcessedValue"`
	// LatestSnapshotValue represents the most recent value of ordering column.
	LatestSnapshotValue any `json:"latestSnapshotValue"`
}