postgres

Jan 31, 2025

Changes in this version

type Destination

+ func (d *Destination) Config() sdk.DestinationConfig

type Source

+ func (s *Source) Config() sdk.SourceConfig

May 23, 2024

Changes in this version

type Source

+ func (s *Source) LifecycleOnDeleted(ctx context.Context, _ map[string]string) error

Mar 29, 2024

Changes in this version

+ const MetadataPostgresTable

+ func NewDestination() sdk.Destination

+ func NewSource() sdk.Source

+ type Destination struct

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

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

+ func (d *Destination) Parameters() map[string]sdk.Parameter

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

+ func (d *Destination) Write(ctx context.Context, recs []sdk.Record) (int, error)

+ type Source struct

+ func (s *Source) Ack(ctx context.Context, pos sdk.Position) error

+ func (s *Source) Configure(_ context.Context, cfg map[string]string) error

+ func (s *Source) Open(ctx context.Context, pos sdk.Position) error

+ func (s *Source) Parameters() map[string]sdk.Parameter

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

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

Sep 27, 2022

Changes in this version

+ var Connector = sdk.Connector

Apr 5, 2022

Changes in this version

+ func Specification() sdk.Specification