swosync

Aug 25, 2023

Changes in this version

+ const ConnLockQuery

+ const ConnWaitLockQuery

+ type LogicalReplicator struct

+ func NewLogicalReplicator() *LogicalReplicator

+ func (l *LogicalReplicator) FinalSync(ctx context.Context) error

+ func (l *LogicalReplicator) FullInitialSync(ctx context.Context) error

+ func (l *LogicalReplicator) LogicalSync(ctx context.Context) error

+ func (l *LogicalReplicator) ResetChangeTracking(ctx context.Context) error

+ func (l *LogicalReplicator) SetDestinationDB(db *pgx.Conn)

+ func (l *LogicalReplicator) SetProgressFunc(fn func(ctx context.Context, format string, args ...interface{}))

+ func (l *LogicalReplicator) SetSourceDB(db *pgx.Conn)

+ func (l *LogicalReplicator) StartTrackingChanges(ctx context.Context) error

+ type SequenceSync struct

+ func NewSequenceSync(names []string) *SequenceSync

+ func (s *SequenceSync) AddBatchReads(b *pgx.Batch)

+ func (s *SequenceSync) AddBatchWrites(b *pgx.Batch)

+ func (s *SequenceSync) ScanBatchReads(res pgx.BatchResults) error

+ type TableSync struct

+ func NewTableSync(tables []swoinfo.Table) *TableSync

+ func (c *TableSync) AddBatchChangeRead(b *pgx.Batch)

+ func (c *TableSync) AddBatchRowReads(b *pgx.Batch)

+ func (c *TableSync) AddBatchWrites(b *pgx.Batch)

+ func (c *TableSync) ExecDeleteChanges(ctx context.Context, srcConn *pgx.Conn) (int64, error)

+ func (c *TableSync) HasChanges() bool

+ func (c *TableSync) ScanBatchChangeRead(res pgx.BatchResults) error

+ func (c *TableSync) ScanBatchRowReads(res pgx.BatchResults) error