tests

Documentation

Index

• type MessageStreamerMock
  • func NewMessageStreamerMock() *MessageStreamerMock
  • func (m MessageStreamerMock) Handle(ctx context.Context, id refs.Feed, seq *message.Sequence, ...)
• type RawMessageHandlerMock
  • func NewRawMessageHandlerMock() *RawMessageHandlerMock
  • func (r RawMessageHandlerMock) Handle(replicatedFrom identity.Public, msg message.RawMessage) error
• type TestReplication
  • func BuildTestReplication(t *testing.T) (TestReplication, error)
• type WantedFeedsProviderMock
  • func NewWantedFeedsProviderMock() *WantedFeedsProviderMock
  • func (c WantedFeedsProviderMock) GetWantedFeeds() (replication.WantedFeeds, error)

Types

type MessageStreamerMock

type MessageStreamerMock struct {
}

func NewMessageStreamerMock

func NewMessageStreamerMock() *MessageStreamerMock

func (MessageStreamerMock) Handle

func (m MessageStreamerMock) Handle(ctx context.Context, id refs.Feed, seq *message.Sequence, messageWriter ebt.MessageWriter)

type RawMessageHandlerMock

type RawMessageHandlerMock struct {
}

func NewRawMessageHandlerMock

func NewRawMessageHandlerMock() *RawMessageHandlerMock

func (RawMessageHandlerMock) Handle

func (r RawMessageHandlerMock) Handle(replicatedFrom identity.Public, msg message.RawMessage) error

type TestReplication

type TestReplication struct {
	Negotiator *replication.Negotiator

	RawMessageHandler  *RawMessageHandlerMock
	ContactsRepository *WantedFeedsProviderMock
	MessageStreamer    *MessageStreamerMock
}

func BuildTestReplication

func BuildTestReplication(t *testing.T) (TestReplication, error)

type WantedFeedsProviderMock

type WantedFeedsProviderMock struct {
	GetWantedFeedsReturnValue replication.WantedFeeds
}

func NewWantedFeedsProviderMock

func NewWantedFeedsProviderMock() *WantedFeedsProviderMock

func (WantedFeedsProviderMock) GetWantedFeeds

func (c WantedFeedsProviderMock) GetWantedFeeds() (replication.WantedFeeds, error)