Documentation
¶
Index ¶
- type DefaultHandlersFactory
- type Dispatcher
- func (lr *Dispatcher) AddInput(ctx context.Context, pulse pulse.Number, msg interface{}) error
- func (lr *Dispatcher) AddInputExt(pulse pulse.Number, msg interface{}, ...) error
- func (lr *Dispatcher) Init(ctx context.Context) error
- func (lr *Dispatcher) Start(_ context.Context) error
- func (lr *Dispatcher) Stop(_ context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DefaultHandlersFactory ¶
type DefaultHandlersFactory struct {
handlers.FactoryMeta
}
func (DefaultHandlersFactory) Classify ¶
func (f DefaultHandlersFactory) Classify(ctx context.Context, input conveyor.InputEvent, ic conveyor.InputContext) (conveyor.InputSetup, error)
type Dispatcher ¶
type Dispatcher struct {
FlowDispatcher beat.Dispatcher
Conveyor *conveyor.PulseConveyor
ConveyorWorker insconveyor.ConveyorWorker
MachineLogger smachine.SlotMachineLogger
// CycleFn is called after every scan cycle done by conveyor worker
CycleFn conveyor.PulseConveyorCycleFunc
// Components
Runner runner.Service
MessageSender messagesender.Service
AuthenticationService authentication.Service
Affinity affinity.Helper
MemoryCache memorycache.Service
PlatformScheme crypto.PlatformScheme
EventlessSleep time.Duration
FactoryLogContextOverride context.Context
MaxRunners int
// contains filtered or unexported fields
}
func NewDispatcher ¶
func NewDispatcher() *Dispatcher
func (*Dispatcher) AddInputExt ¶
func (lr *Dispatcher) AddInputExt(pulse pulse.Number, msg interface{}, createDefaults smachine.CreateDefaultValues) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.