trigger

Documentation

Index

• type TriggerRunner
  • func NewTriggerRunner(ctx context.Context, commandBus handler.FpCommandBus, rootMod *modconfig.Mod, ...) TriggerRunner
• type TriggerRunnerBase
  • func (tr *TriggerRunnerBase) ExecuteTrigger() (types.TriggerExecutionResponse, []event.PipelineQueue, error)
  • func (tr *TriggerRunnerBase) ExecuteTriggerForExecutionID(executionId string, args map[string]interface{}, argsString map[string]string) (types.TriggerExecutionResponse, []event.PipelineQueue, error)
  • func (tr *TriggerRunnerBase) GetFqueue() *fqueue.FunctionQueue
  • func (tr *TriggerRunnerBase) GetTrigger() *modconfig.Trigger
  • func (tr *TriggerRunnerBase) Run()
• type TriggerRunnerQuery
  • func (tr *TriggerRunnerQuery) ExecuteTrigger() (types.TriggerExecutionResponse, []event.PipelineQueue, error)
  • func (tr *TriggerRunnerQuery) ExecuteTriggerForExecutionID(executionId string, args map[string]interface{}, argsString map[string]string) (types.TriggerExecutionResponse, []event.PipelineQueue, error)
  • func (tr *TriggerRunnerQuery) Run()
  • func (tr *TriggerRunnerQuery) RunOne() error

Types

type TriggerRunner

type TriggerRunner interface {
	Run()
	GetTrigger() *modconfig.Trigger
	GetFqueue() *fqueue.FunctionQueue
	ExecuteTrigger() (types.TriggerExecutionResponse, []event.PipelineQueue, error)
	ExecuteTriggerForExecutionID(executionId string, args map[string]interface{}, argsString map[string]string) (types.TriggerExecutionResponse, []event.PipelineQueue, error)
}

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

func (tr *TriggerRunnerBase) ExecuteTrigger() (types.TriggerExecutionResponse, []event.PipelineQueue, error)

func (*TriggerRunnerBase) ExecuteTriggerForExecutionID

func (tr *TriggerRunnerBase) ExecuteTriggerForExecutionID(executionId string, args map[string]interface{}, argsString map[string]string) (types.TriggerExecutionResponse, []event.PipelineQueue, error)

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

func (tr *TriggerRunnerQuery) ExecuteTrigger() (types.TriggerExecutionResponse, []event.PipelineQueue, error)

func (*TriggerRunnerQuery) ExecuteTriggerForExecutionID

func (tr *TriggerRunnerQuery) ExecuteTriggerForExecutionID(executionId string, args map[string]interface{}, argsString map[string]string) (types.TriggerExecutionResponse, []event.PipelineQueue, error)

TODO: executionId doesn't mean anything here .. since can execute 0 - 3 pipelines

func (*TriggerRunnerQuery) Run

func (tr *TriggerRunnerQuery) Run()

func (*TriggerRunnerQuery) RunOne

func (tr *TriggerRunnerQuery) RunOne() error