Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Replication ¶
type Replication struct { Database string Host string Port uint16 User string Connection *pgx.ReplicationConn KeepaliveInterval time.Duration SlotName string CreateSlot bool DropSlot bool Options []string }
func (*Replication) Connect ¶
func (r *Replication) Connect(ctx context.Context)
func (*Replication) Read ¶
func (r *Replication) Read(ctx context.Context, send chan pgx.WalMessage, ack chan uint64)
Click to show internal directories.
Click to hide internal directories.