mocks

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
  • func (m *LSNParser) FromString(lsn string) (replication.LSN, error)
  • func (m *LSNParser) ToString(lsn replication.LSN) string

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) Close

func (m *Handler) Close() error

func (*Handler) DropReplicationSlot

func (m *Handler) DropReplicationSlot(ctx context.Context) error

func (*Handler) GetCurrentLSN

func (m *Handler) GetCurrentLSN(ctx context.Context) (replication.LSN, error)

func (*Handler) GetLSNParser

func (m *Handler) GetLSNParser() replication.LSNParser

func (*Handler) GetReceiveMessageCalls

func (m *Handler) GetReceiveMessageCalls() uint64

func (*Handler) GetSyncLSNCalls

func (m *Handler) GetSyncLSNCalls() uint64

func (*Handler) ReceiveMessage

func (m *Handler) ReceiveMessage(ctx context.Context) (*replication.Message, error)

func (*Handler) StartReplication

func (m *Handler) StartReplication(ctx context.Context) error

func (*Handler) StartReplicationFromLSN

func (m *Handler) StartReplicationFromLSN(ctx context.Context, lsn replication.LSN) error

func (*Handler) SyncLSN

func (m *Handler) SyncLSN(ctx context.Context, lsn replication.LSN) error

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)

func (*LSNParser) ToString

func (m *LSNParser) ToString(lsn replication.LSN) string