trigger

Documentation

Index

• type TriggerRunner
  • func NewTriggerRunner(ctx context.Context, commandBus handler.FpCommandBus, rootMod *modconfig.Mod, ...) TriggerRunner
• type TriggerRunnerBase
  • func (tr *TriggerRunnerBase) GetFqueue() *fqueue.FunctionQueue
  • func (tr *TriggerRunnerBase) GetTrigger() *modconfig.Trigger
  • func (tr *TriggerRunnerBase) Run()
• type TriggerRunnerQuery
  • func (tr *TriggerRunnerQuery) Run()
  • func (tr *TriggerRunnerQuery) RunOne() error

Types

type TriggerRunner

type TriggerRunner interface {
	Run()
	GetTrigger() *modconfig.Trigger
	GetFqueue() *fqueue.FunctionQueue
}

func NewTriggerRunner

func NewTriggerRunner(ctx context.Context, commandBus handler.FpCommandBus, rootMod *modconfig.Mod, trigger *modconfig.Trigger) TriggerRunner

type TriggerRunnerBase

type TriggerRunnerBase struct {
	Trigger *modconfig.Trigger

	Fqueue *fqueue.FunctionQueue
	// contains filtered or unexported fields
}

func (*TriggerRunnerBase) GetFqueue

func (tr *TriggerRunnerBase) GetFqueue() *fqueue.FunctionQueue

func (*TriggerRunnerBase) GetTrigger

func (tr *TriggerRunnerBase) GetTrigger() *modconfig.Trigger

func (*TriggerRunnerBase) Run

func (tr *TriggerRunnerBase) Run()

type TriggerRunnerQuery

type TriggerRunnerQuery struct {
	TriggerRunnerBase
}

func (*TriggerRunnerQuery) Run

func (tr *TriggerRunnerQuery) Run()

func (*TriggerRunnerQuery) RunOne

func (tr *TriggerRunnerQuery) RunOne() error