waljs

type ChangeFilter struct {
	// contains filtered or unexported fields
}

type Config struct {
	Tables              *types.Set[types.StreamInterface]
	Connection          url.URL
	SSHClient           *ssh.Client
	ReplicationSlotName string
	InitialWaitTime     time.Duration
	TLSConfig           *tls.Config
	BatchSize           int
	// Publications is used with pgoutput
	Publication string
}

type ReplicationSlot struct {
	SlotType   string        `db:"slot_type"`
	Plugin     string        `db:"plugin"`
	LSN        pglogrepl.LSN `db:"confirmed_flush_lsn"`
	CurrentLSN pglogrepl.LSN `db:"current_lsn"`
}

type Replicator interface {
	// info about socket
	Socket() *Socket
	// StreamChanges processes messages until it emits changes via insertFn or exits per logic.
	StreamChanges(ctx context.Context, db *sqlx.DB, insertFn abstract.CDCMsgFn) error
}

type Socket struct {

	// clientXLogPos tracks the current position (while reading logs) in the Write-Ahead Log (WAL)
	ClientXLogPos pglogrepl.LSN

	// confirmedLSN is the position from which replication should start (Prev marked lsn)
	ConfirmedFlushLSN pglogrepl.LSN
	// wal position at a point of time
	CurrentWalPosition pglogrepl.LSN
	// replicationSlot is the name of the PostgreSQL replication slot being used
	ReplicationSlot string
	// contains filtered or unexported fields
}

type WALMessage struct {
	NextLSN   string         `json:"nextlsn"`
	Timestamp typeutils.Time `json:"timestamp"`
	Change    []struct {
		Kind         string        `json:"kind"`
		Schema       string        `json:"schema"`
		Table        string        `json:"table"`
		Columnnames  []string      `json:"columnnames"`
		Columntypes  []string      `json:"columntypes"`
		Columnvalues []interface{} `json:"columnvalues"`
		Oldkeys      struct {
			Keynames  []string      `json:"keynames"`
			Keytypes  []string      `json:"keytypes"`
			Keyvalues []interface{} `json:"keyvalues"`
		} `json:"oldkeys"`
	} `json:"change"`
}

type WALState struct {
	LSN string `json:"lsn"`
}