consensus

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)

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 -