trigger

Documentation

Index

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

Types

type TriggerRunner

type TriggerRunner interface {
	GetTrigger() *resources.Trigger
	GetPipelineQueuesWithArgs(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 *resources.Trigger, executionID, triggerExecutionID string) TriggerRunner

type TriggerRunnerBase

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

	Type string
	// contains filtered or unexported fields
}

func (*TriggerRunnerBase) GetPipelineQueuesWithArgs

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

func (*TriggerRunnerBase) GetTrigger

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

func (*TriggerRunnerBase) GetTriggerResponse

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

type TriggerRunnerQuery

type TriggerRunnerQuery struct {
	TriggerRunnerBase
}

func (*TriggerRunnerQuery) GetPipelineQueuesWithArgs

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