postgres_incr_sync

May 13, 2024

Changes in this version

+ func NewPostgresIncrSourcePlugin(appCtx *stream_context.Context, config Config, s []schema.StreamSchema) sources.DataSource

+ type Config struct

+ Database string

+ Host string

+ Password string

+ Port int

+ SSLRequired bool

+ Schema string

+ StreamSnapshot bool

+ TablesSchema []pglogicalstream.DbTablesSchema

+ User string

+ type SourcePlugin struct

+ func (p *SourcePlugin) Connect(ctx context.Context) error

+ func (p *SourcePlugin) Events() chan sources.MessageEvent

+ func (p *SourcePlugin) Start()

+ func (p *SourcePlugin) Stop()