matcher

Documentation

Index

• func GetRepo(ctx context.Context, cs *params.Run, repoName string) (*apipac.Repository, error)
• func GrabPipelineFromAnnotations(annotations map[string]string) (string, error)
• func GrabTasksFromAnnotations(annotations map[string]string) ([]string, error)
• func IncomingWebhookRule(branch string, incomingWebhooks []apipac.Incoming) *apipac.Incoming
• func MatchEventURLRepo(ctx context.Context, cs *params.Run, event *info.Event, ns string) (*apipac.Repository, error)
• func MatchRunningPipelineRunForIncomingWebhook(eventType, incomingPipelineRun string, prs []*tektonv1.PipelineRun) []*tektonv1.PipelineRun
• type Match
  • func MatchPipelinerunByAnnotation(ctx context.Context, logger *zap.SugaredLogger, pruns []*tektonv1.PipelineRun, ...) ([]Match, error)
• type RemoteTasks
  • func (rt RemoteTasks) GetPipelineFromAnnotationName(ctx context.Context, name string) (*tektonv1.Pipeline, error)
  • func (rt RemoteTasks) GetTaskFromAnnotationName(ctx context.Context, name string) (*tektonv1.Task, error)

Functions

func GetRepo

func GetRepo(ctx context.Context, cs *params.Run, repoName string) (*apipac.Repository, error)

GetRepo get a repo by name anywhere on a cluster.

func GrabPipelineFromAnnotations

func GrabPipelineFromAnnotations(annotations map[string]string) (string, error)

func GrabTasksFromAnnotations

func GrabTasksFromAnnotations(annotations map[string]string) ([]string, error)

func IncomingWebhookRule

func IncomingWebhookRule(branch string, incomingWebhooks []apipac.Incoming) *apipac.Incoming

IncomingWebhookRule will match a rule to an incoming rule, currently a rule is a target branch.

func MatchEventURLRepo

func MatchEventURLRepo(ctx context.Context, cs *params.Run, event *info.Event, ns string) (*apipac.Repository, error)

func MatchRunningPipelineRunForIncomingWebhook

func MatchRunningPipelineRunForIncomingWebhook(eventType, incomingPipelineRun string, prs []*tektonv1.PipelineRun) []*tektonv1.PipelineRun

Types

type Match

type Match struct {
	PipelineRun *tektonv1.PipelineRun
	Repo        *apipac.Repository
	Config      map[string]string
}

func MatchPipelinerunByAnnotation

func MatchPipelinerunByAnnotation(ctx context.Context, logger *zap.SugaredLogger, pruns []*tektonv1.PipelineRun, cs *params.Run, event *info.Event, vcx provider.Interface) ([]Match, error)

type RemoteTasks

type RemoteTasks struct {
	Run               *params.Run
	ProviderInterface provider.Interface
	Event             *info.Event
	Logger            *zap.SugaredLogger
}

func (RemoteTasks) GetPipelineFromAnnotationName

func (rt RemoteTasks) GetPipelineFromAnnotationName(ctx context.Context, name string) (*tektonv1.Pipeline, error)

func (RemoteTasks) GetTaskFromAnnotationName

func (rt RemoteTasks) GetTaskFromAnnotationName(ctx context.Context, name string) (*tektonv1.Task, error)