mockfetcher

Documentation

Index

• type AssignedChunkProcessor
  • func (_m *AssignedChunkProcessor) ProcessAssignedChunk(locator *chunks.Locator)
  • func (_m *AssignedChunkProcessor) WithChunkConsumerNotifier(notifier module.ProcessingNotifier)
• type ChunkDataPackHandler
  • func (_m *ChunkDataPackHandler) HandleChunkDataPack(originID flow.Identifier, chunkDataPack *flow.ChunkDataPack, ...)
  • func (_m *ChunkDataPackHandler) NotifyChunkDataPackSealed(chunkID flow.Identifier)
• type ChunkDataPackRequester
  • func (_m *ChunkDataPackRequester) Request(chunkID flow.Identifier, executorID flow.Identifier) error

Types

type AssignedChunkProcessor

type AssignedChunkProcessor struct {
	mock.Mock
}

AssignedChunkProcessor is an autogenerated mock type for the AssignedChunkProcessor type

func (*AssignedChunkProcessor) ProcessAssignedChunk

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

ProcessAssignedChunk provides a mock function with given fields: locator

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 (*ChunkDataPackHandler) HandleChunkDataPack

func (_m *ChunkDataPackHandler) HandleChunkDataPack(originID flow.Identifier, chunkDataPack *flow.ChunkDataPack, collection *flow.Collection)

HandleChunkDataPack provides a mock function with given fields: originID, chunkDataPack, collection

func (*ChunkDataPackHandler) NotifyChunkDataPackSealed

func (_m *ChunkDataPackHandler) NotifyChunkDataPackSealed(chunkID flow.Identifier)

NotifyChunkDataPackSealed provides a mock function with given fields: chunkID

type ChunkDataPackRequester

type ChunkDataPackRequester struct {
	mock.Mock
}

ChunkDataPackRequester is an autogenerated mock type for the ChunkDataPackRequester type

func (*ChunkDataPackRequester) Request

func (_m *ChunkDataPackRequester) Request(chunkID flow.Identifier, executorID flow.Identifier) error

Request provides a mock function with given fields: chunkID, executorID