Versions in this module Expand all Collapse all v1 v1.0.0 Mar 1, 2020 Changes in this version + const DefaultSlotName + const StandbyStatusInterval + func StreamChanges(logger *logrus.Logger, ctx context.Context, replConn *pgx.ReplicationConn, ...) error + type State struct + CurrentLSN uint64 + func Setup(logger *logrus.Logger, pgConn *pgx.Conn, replConn *pgx.ReplicationConn, ...) (string, *State, error) + type WALPayload struct + NextLSN string