Versions in this module Expand all Collapse all v0 v0.2.0 Nov 9, 2021 Changes in this version + type Follower interface + Follow func(ctx context.Context, startingpos pglogrepl.LSN) error + type WalFollower struct + func NewWalFollower(conn *pgconn.PgConn, mapping []config.InternalTableMapping, cache *cache.Cache) *WalFollower + func (f *WalFollower) Follow(ctx context.Context, startpos pglogrepl.LSN) error
Go to main page