mocks

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, uint64) error
	DropReplicationSlotFn     func(ctx context.Context) error
	GetLSNParserFn            func() replication.LSNParser
	GetCurrentLSNFn           func(context.Context) (replication.LSN, error)
	ResetConnectionFn         func(ctx context.Context) error
	GetReplicationLagFn       func(context.Context) (int64, error)
	CloseFn                   func() error
	SyncLSNCalls              uint64
	ReceiveMessageCalls       uint64
}

type LSNParser struct {
	ToStringFn   func(replication.LSN) string
	FromStringFn func(string) (replication.LSN, error)
}