triggerv2

Documentation

Index

• type TriggerRunner
  • func NewTriggerRunner(trigger *modconfig.Trigger, executionID, triggerExecutionID string) TriggerRunner
• type TriggerRunnerBase
  • func (tr *TriggerRunnerBase) ExecuteTriggerWithArgs(ctx context.Context, args map[string]interface{}, argsString map[string]string) ([]*event.PipelineQueue, error)
  • func (tr *TriggerRunnerBase) GetTriggerResponse(pipelineCmds []*event.PipelineQueue) (types.TriggerExecutionResponse, error)
• type TriggerRunnerQuery
  • func (tr *TriggerRunnerQuery) ExecuteTriggerWithArgs(ctx context.Context, args map[string]interface{}, argsString map[string]string) ([]*event.PipelineQueue, error)

Types

type TriggerRunner

type TriggerRunner interface {
	ExecuteTriggerWithArgs(ctx context.Context, args map[string]interface{}, argsString map[string]string) ([]*event.PipelineQueue, error)
	GetTriggerResponse([]*event.PipelineQueue) (types.TriggerExecutionResponse, error)
}

func NewTriggerRunner

func NewTriggerRunner(trigger *modconfig.Trigger, executionID, triggerExecutionID string) TriggerRunner

type TriggerRunnerBase

type TriggerRunnerBase struct {
	ExecutionID        string
	TriggerExecutionID string
	Trigger            *modconfig.Trigger

	Type string
	// contains filtered or unexported fields
}

func (*TriggerRunnerBase) ExecuteTriggerWithArgs

func (tr *TriggerRunnerBase) ExecuteTriggerWithArgs(ctx context.Context, args map[string]interface{}, argsString map[string]string) ([]*event.PipelineQueue, error)

func (*TriggerRunnerBase) GetTriggerResponse

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

type TriggerRunnerQuery

type TriggerRunnerQuery struct {
	TriggerRunnerBase
}

func (*TriggerRunnerQuery) ExecuteTriggerWithArgs

func (tr *TriggerRunnerQuery) ExecuteTriggerWithArgs(ctx context.Context, args map[string]interface{}, argsString map[string]string) ([]*event.PipelineQueue, error)