cdcpostgres

Feb 15, 2022

Changes in this version

type CDCPostgres

+ func (c *CDCPostgres) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, ...) error

Dec 6, 2021

Changes in this version

+ const BackendName

+ type CDCPostgres struct

+ func New(connOpts *opts.ConnectionOptions) (*CDCPostgres, error)

+ func (c *CDCPostgres) Close(_ context.Context) error

+ func (c *CDCPostgres) DisplayError(msg *records.ErrorRecord) error

+ func (c *CDCPostgres) DisplayMessage(msg *records.ReadRecord) error

+ func (c *CDCPostgres) Dynamic(ctx context.Context, dynamicOpts *opts.DynamicOptions, ...) error

+ func (c *CDCPostgres) Name() string

+ func (c *CDCPostgres) Read(ctx context.Context, readOpts *opts.ReadOptions, ...) error

+ func (c *CDCPostgres) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error

+ func (c *CDCPostgres) Test(_ context.Context) error

+ func (c *CDCPostgres) Write(ctx context.Context, writeOpts *opts.WriteOptions, ...) error