pg

type DB struct {
	*sqlx.DB
	Hostname string
	Database string
}

type Publication struct {
	Active  bool          `db:"active"`
	Name    string        `db:"application_name"`
	Pid     sql.NullInt64 `db:"pid"`
	SentLsn string        `db:"sent_lsn"`
	State   string        `db:"state"`
	Tmp     bool          `db:"temporary"`
}

type ReplicationSlot struct {
	Name              string `db:"slot_name"`
	RestartLsn        string `db:"restart_lsn"`
	ConfirmedFlushLsn string `db:"confirmed_flush_lsn"`
	Active            bool   `db:"active"`
}

type Subscription struct {
	Pid                sql.NullInt64  `db:"pid"`
	Name               string         `db:"subname"`
	Relname            sql.NullString `db:"relname"`
	ReceivedLsn        string         `db:"received_lsn"`
	LastMsgReceiptTime string         `db:"last_msg_receipt_time"`
}