Versions in this module Expand all Collapse all v0 v0.0.3 Feb 13, 2024 v0.0.2 Feb 13, 2024 v0.0.1 Jan 25, 2024 Changes in this version + type Config struct + BatchSize int + DbHost string + DbName string + DbPassword string + DbPort int + DbSchema string + DbTablesSchema []DbTablesSchema + DbUser string + ReplicationSlotName string + SeparateChanges bool + SnapshotMemorySafetyFactor float64 + StreamOldData bool + TlsVerify TlsVerify + type DbSchemaColumn struct + DatabrewType string + Name string + NativeConnectorType string + Nullable bool + Pk bool + type DbTablesSchema struct + Columns []DbSchemaColumn + Table string + type OnMessage = func(message replication.Wal2JsonChanges) + type Stream struct + func NewPgStream(config Config, logger *log.Logger) (*Stream, error) + func (s *Stream) AckLSN(lsn string) + func (s *Stream) LrMessageC() chan replication.Wal2JsonChanges + func (s *Stream) OnMessage(callback OnMessage) + func (s *Stream) SnapshotMessageC() chan replication.Wal2JsonChanges + func (s *Stream) Stop() error + type TlsVerify string + const TlsNoVerify + const TlsRequireVerify