Documentation ¶
Index ¶
- type IProcessorWrapper
- func (_m *IProcessorWrapper) GetName() utils.ProcessorName
- func (_m *IProcessorWrapper) GetStartWorker() contracts.DocumentType
- func (_m *IProcessorWrapper) GetTerminateWorker() contracts.DocumentType
- func (_m *IProcessorWrapper) Initialize(outputChan map[contracts.UpstreamServiceName]chan contracts.DocumentResult) error
- func (_m *IProcessorWrapper) PushToProcessor(_a0 contracts.DocumentState) processor.ErrorCode
- func (_m *IProcessorWrapper) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IProcessorWrapper ¶
IProcessorWrapper is an autogenerated mock type for the IProcessorWrapper type
func (*IProcessorWrapper) GetName ¶
func (_m *IProcessorWrapper) GetName() utils.ProcessorName
GetName provides a mock function with given fields:
func (*IProcessorWrapper) GetStartWorker ¶
func (_m *IProcessorWrapper) GetStartWorker() contracts.DocumentType
GetStartWorker provides a mock function with given fields:
func (*IProcessorWrapper) GetTerminateWorker ¶
func (_m *IProcessorWrapper) GetTerminateWorker() contracts.DocumentType
GetTerminateWorker provides a mock function with given fields:
func (*IProcessorWrapper) Initialize ¶
func (_m *IProcessorWrapper) Initialize(outputChan map[contracts.UpstreamServiceName]chan contracts.DocumentResult) error
Initialize provides a mock function with given fields: outputChan
func (*IProcessorWrapper) PushToProcessor ¶
func (_m *IProcessorWrapper) PushToProcessor(_a0 contracts.DocumentState) processor.ErrorCode
PushToProcessor provides a mock function with given fields: _a0
func (*IProcessorWrapper) Stop ¶
func (_m *IProcessorWrapper) Stop()
Stop provides a mock function with given fields: stopType
Click to show internal directories.
Click to hide internal directories.