mockfetcher

Documentation

Index

• type AssignedChunkProcessor
  • func NewAssignedChunkProcessor(t NewAssignedChunkProcessorT) *AssignedChunkProcessor
  • func (_m *AssignedChunkProcessor) Done() <-chan struct{}
  • func (_m *AssignedChunkProcessor) ProcessAssignedChunk(locator *chunks.Locator)
  • func (_m *AssignedChunkProcessor) Ready() <-chan struct{}
  • func (_m *AssignedChunkProcessor) WithChunkConsumerNotifier(notifier module.ProcessingNotifier)
• type ChunkDataPackHandler
  • func NewChunkDataPackHandler(t NewChunkDataPackHandlerT) *ChunkDataPackHandler
  • func (_m *ChunkDataPackHandler) HandleChunkDataPack(originID flow.Identifier, response *verification.ChunkDataPackResponse)
  • func (_m *ChunkDataPackHandler) NotifyChunkDataPackSealed(chunkIndex uint64, resultID flow.Identifier)
• type ChunkDataPackRequester
  • func NewChunkDataPackRequester(t NewChunkDataPackRequesterT) *ChunkDataPackRequester
  • func (_m *ChunkDataPackRequester) Done() <-chan struct{}
  • func (_m *ChunkDataPackRequester) Ready() <-chan struct{}
  • func (_m *ChunkDataPackRequester) Request(request *verification.ChunkDataPackRequest)
  • func (_m *ChunkDataPackRequester) WithChunkDataPackHandler(handler fetcher.ChunkDataPackHandler)
• type NewAssignedChunkProcessorT
• type NewChunkDataPackHandlerT
• type NewChunkDataPackRequesterT

Types

type AssignedChunkProcessor

type AssignedChunkProcessor struct {
	mock.Mock
}

AssignedChunkProcessor is an autogenerated mock type for the AssignedChunkProcessor type

func NewAssignedChunkProcessor

func NewAssignedChunkProcessor(t NewAssignedChunkProcessorT) *AssignedChunkProcessor

NewAssignedChunkProcessor creates a new instance of AssignedChunkProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*AssignedChunkProcessor) Done

func (_m *AssignedChunkProcessor) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*AssignedChunkProcessor) ProcessAssignedChunk

func (_m *AssignedChunkProcessor) ProcessAssignedChunk(locator *chunks.Locator)

ProcessAssignedChunk provides a mock function with given fields: locator

func (*AssignedChunkProcessor) Ready

func (_m *AssignedChunkProcessor) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*AssignedChunkProcessor) WithChunkConsumerNotifier

func (_m *AssignedChunkProcessor) WithChunkConsumerNotifier(notifier module.ProcessingNotifier)

WithChunkConsumerNotifier provides a mock function with given fields: notifier

type ChunkDataPackHandler

type ChunkDataPackHandler struct {
	mock.Mock
}

ChunkDataPackHandler is an autogenerated mock type for the ChunkDataPackHandler type

func NewChunkDataPackHandler

func NewChunkDataPackHandler(t NewChunkDataPackHandlerT) *ChunkDataPackHandler

NewChunkDataPackHandler creates a new instance of ChunkDataPackHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ChunkDataPackHandler) HandleChunkDataPack

func (_m *ChunkDataPackHandler) HandleChunkDataPack(originID flow.Identifier, response *verification.ChunkDataPackResponse)

HandleChunkDataPack provides a mock function with given fields: originID, response

func (*ChunkDataPackHandler) NotifyChunkDataPackSealed

func (_m *ChunkDataPackHandler) NotifyChunkDataPackSealed(chunkIndex uint64, resultID flow.Identifier)

NotifyChunkDataPackSealed provides a mock function with given fields: chunkIndex, resultID

type ChunkDataPackRequester

type ChunkDataPackRequester struct {
	mock.Mock
}

ChunkDataPackRequester is an autogenerated mock type for the ChunkDataPackRequester type

func NewChunkDataPackRequester

func NewChunkDataPackRequester(t NewChunkDataPackRequesterT) *ChunkDataPackRequester

NewChunkDataPackRequester creates a new instance of ChunkDataPackRequester. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ChunkDataPackRequester) Done

func (_m *ChunkDataPackRequester) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*ChunkDataPackRequester) Ready

func (_m *ChunkDataPackRequester) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*ChunkDataPackRequester) Request

func (_m *ChunkDataPackRequester) Request(request *verification.ChunkDataPackRequest)

Request provides a mock function with given fields: request

func (*ChunkDataPackRequester) WithChunkDataPackHandler

func (_m *ChunkDataPackRequester) WithChunkDataPackHandler(handler fetcher.ChunkDataPackHandler)

WithChunkDataPackHandler provides a mock function with given fields: handler

type NewAssignedChunkProcessorT

type NewAssignedChunkProcessorT interface {
	mock.TestingT
	Cleanup(func())
}

type NewChunkDataPackHandlerT

type NewChunkDataPackHandlerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewChunkDataPackRequesterT

type NewChunkDataPackRequesterT interface {
	mock.TestingT
	Cleanup(func())
}