mocks

Documentation

Index

• type Handler
  • func (m *Handler) Close() error
  • func (m *Handler) DropReplicationSlot(ctx context.Context) 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) 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
	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
	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) 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) 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