virtual

Documentation

Index

• type DefaultHandlersFactory
  • func (f DefaultHandlersFactory) Classify(ctx context.Context, input conveyor.InputEvent, ic conveyor.InputContext) (conveyor.InputSetup, error)
• type Dispatcher
  • func NewDispatcher() *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

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) AddInput

func (lr *Dispatcher) AddInput(ctx context.Context, pulse pulse.Number, msg interface{}) error

func (*Dispatcher) AddInputExt

func (lr *Dispatcher) AddInputExt(pulse pulse.Number, msg interface{}, createDefaults smachine.CreateDefaultValues) error

func (*Dispatcher) Init

func (lr *Dispatcher) Init(ctx context.Context) error

func (*Dispatcher) Start

func (lr *Dispatcher) Start(_ context.Context) error

func (*Dispatcher) Stop

func (lr *Dispatcher) Stop(_ context.Context) error