Documentation
¶
Index ¶
- type Handler
- func (m *Handler) Close() error
- func (m *Handler) DropReplicationSlot(ctx context.Context) error
- func (m *Handler) GetCurrentLSN(ctx context.Context) (replication.LSN, error)
- func (m *Handler) GetLSNParser() replication.LSNParser
- func (m *Handler) GetReceiveMessageCalls() uint64
- func (m *Handler) GetSyncLSNCalls() uint64
- func (m *Handler) ReceiveMessage(ctx context.Context) (*replication.Message, error)
- func (m *Handler) StartReplication(ctx context.Context) error
- func (m *Handler) StartReplicationFromLSN(ctx context.Context, lsn replication.LSN) error
- func (m *Handler) SyncLSN(ctx context.Context, lsn replication.LSN) error
- type LSNParser
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
StartReplicationFn func(context.Context) error
StartReplicationFromLSNFn func(context.Context, replication.LSN) error
ReceiveMessageFn func(context.Context, uint64) (*replication.Message, error)
SyncLSNFn func(context.Context, replication.LSN) error
DropReplicationSlotFn func(ctx context.Context) error
GetLSNParserFn func() replication.LSNParser
GetCurrentLSNFn func(context.Context) (replication.LSN, error)
CloseFn func() error
SyncLSNCalls uint64
ReceiveMessageCalls uint64
}
func (*Handler) DropReplicationSlot ¶
func (*Handler) GetCurrentLSN ¶ added in v0.3.0
func (*Handler) GetLSNParser ¶
func (m *Handler) GetLSNParser() replication.LSNParser
func (*Handler) GetReceiveMessageCalls ¶
func (*Handler) GetSyncLSNCalls ¶
func (*Handler) ReceiveMessage ¶
func (*Handler) StartReplicationFromLSN ¶ added in v0.3.0
type LSNParser ¶
type LSNParser struct {
ToStringFn func(replication.LSN) string
FromStringFn func(string) (replication.LSN, error)
}
func (*LSNParser) FromString ¶
func (m *LSNParser) FromString(lsn string) (replication.LSN, error)
Source Files
Click to show internal directories.
Click to hide internal directories.