pipelinerun

Documentation

Index

• func Cancel(c *cli.Clients, prname string, opts metav1.PatchOptions, ...) (*v1.PipelineRun, error)
• func Create(c *cli.Clients, pr *v1beta1.PipelineRun, opts metav1.CreateOptions, ns string) (*v1beta1.PipelineRun, error)
• func GetAllPipelineRuns(gr schema.GroupVersionResource, opts metav1.ListOptions, c *cli.Clients, ...) ([]string, error)
• func GetPipelineRun(gr schema.GroupVersionResource, c *cli.Clients, prName, ns string) (*v1.PipelineRun, error)
• func GetTaskRunsWithStatus(pr *v1.PipelineRun, c *cli.Clients, ns string) (map[string]*v1.PipelineRunTaskRunStatus, error)
• func PrintPipelineRunDescription(out io.Writer, c *cli.Clients, ns string, prName string, time clockwork.Clock) error
• type TaskRunWithStatus
• type TaskRunWithStatusList
  • func (trs TaskRunWithStatusList) Len() int
  • func (trs TaskRunWithStatusList) Less(i, j int) bool
  • func (trs TaskRunWithStatusList) Swap(i, j int)
• type Tracker
  • func NewTracker(name string, ns string, client *cli.Clients) *Tracker
  • func (t *Tracker) Monitor(allowed []string) <-chan []taskrunpkg.Run

Functions

func Cancel

func Cancel(c *cli.Clients, prname string, opts metav1.PatchOptions, cancelStatus, ns string) (*v1.PipelineRun, error)

func Create

func Create(c *cli.Clients, pr *v1beta1.PipelineRun, opts metav1.CreateOptions, ns string) (*v1beta1.PipelineRun, error)

It will create the resource based on the api available.

func GetAllPipelineRuns

func GetAllPipelineRuns(gr schema.GroupVersionResource, opts metav1.ListOptions, c *cli.Clients, ns string, limit int, time clockwork.Clock) ([]string, error)

GetAllPipelineRuns returns all pipelinesruns running in a namespace

func GetPipelineRun

func GetPipelineRun(gr schema.GroupVersionResource, c *cli.Clients, prName, ns string) (*v1.PipelineRun, error)

func GetTaskRunsWithStatus

func GetTaskRunsWithStatus(pr *v1.PipelineRun, c *cli.Clients, ns string) (map[string]*v1.PipelineRunTaskRunStatus, error)

func PrintPipelineRunDescription

func PrintPipelineRunDescription(out io.Writer, c *cli.Clients, ns string, prName string, time clockwork.Clock) error

Types

type TaskRunWithStatus

type TaskRunWithStatus struct {
	TaskRunName      string
	PipelineTaskName string
	Status           *v1.TaskRunStatus
}

type TaskRunWithStatusList

type TaskRunWithStatusList []TaskRunWithStatus

func (TaskRunWithStatusList) Len

func (trs TaskRunWithStatusList) Len() int

func (TaskRunWithStatusList) Less

func (trs TaskRunWithStatusList) Less(i, j int) bool

func (TaskRunWithStatusList) Swap

func (trs TaskRunWithStatusList) Swap(i, j int)

type Tracker

type Tracker struct {
	Name   string
	Ns     string
	Client *cli.Clients
	// contains filtered or unexported fields
}

Tracker tracks the progress of a PipelineRun

func NewTracker

func NewTracker(name string, ns string, client *cli.Clients) *Tracker

NewTracker returns a new instance of Tracker

func (*Tracker) Monitor

func (t *Tracker) Monitor(allowed []string) <-chan []taskrunpkg.Run

Monitor to observe the progress of PipelineRun. It emits an event upon starting of a new Pipeline's Task. allowed containers the name of the Pipeline tasks, which used as filter limit the events to only those tasks