postgres

package

v0.0.0-...-cd81764 Latest Latest Go to latest Published: Jul 11, 2021 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateSlot(ctx context.Context, conn *pgconn.PgConn, slotName string) error

func DropSlot(ctx context.Context, conn *pgconn.PgConn, slotName string) error

type HandleFunc func(data WalData) error

type WalData struct {
	StreamName string
	StreamID   string
	EventName  string
	Version    int64
	Data       []byte
}

func (d WalData) Validate() error

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

func NewWalReceiverWithContext(
	ctx context.Context,
	conn *pgconn.PgConn,
	slotName string,
) *WalReceiver

func (r *WalReceiver) Listen() error

func (r *WalReceiver) OnError(fn func(*pgproto3.ErrorResponse))

func (r *WalReceiver) OnExit(fn func())

func (r *WalReceiver) OnMessage(fn HandleFunc)

func (r *WalReceiver) OnPrimaryKeepalive(fn func(pglogrepl.PrimaryKeepaliveMessage))

func (r *WalReceiver) OnStandbyStatusUpdate(fn func(pglogrepl.LSN))