Documentation ¶
Index ¶
- type ScheduledProcessorStub
- func (sps *ScheduledProcessorStub) ForceStopScheduledExecutionBlocking()
- func (sps *ScheduledProcessorStub) IsInterfaceNil() bool
- func (sps *ScheduledProcessorStub) IsProcessedOKWithTimeout() bool
- func (sps *ScheduledProcessorStub) StartScheduledProcessing(header data.HeaderHandler, body data.BodyHandler, startTime time.Time)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ScheduledProcessorStub ¶
type ScheduledProcessorStub struct { StartScheduledProcessingCalled func(header data.HeaderHandler, body data.BodyHandler, startTime time.Time) IsProcessedOKCalled func() bool }
ScheduledProcessorStub -
func (*ScheduledProcessorStub) ForceStopScheduledExecutionBlocking ¶
func (sps *ScheduledProcessorStub) ForceStopScheduledExecutionBlocking()
ForceStopScheduledExecutionBlocking -
func (*ScheduledProcessorStub) IsInterfaceNil ¶
func (sps *ScheduledProcessorStub) IsInterfaceNil() bool
IsInterfaceNil -
func (*ScheduledProcessorStub) IsProcessedOKWithTimeout ¶
func (sps *ScheduledProcessorStub) IsProcessedOKWithTimeout() bool
IsProcessedOKWithTimeout -
func (*ScheduledProcessorStub) StartScheduledProcessing ¶
func (sps *ScheduledProcessorStub) StartScheduledProcessing(header data.HeaderHandler, body data.BodyHandler, startTime time.Time)
StartScheduledProcessing -
Click to show internal directories.
Click to hide internal directories.