pipelinerun

Documentation

Index

• func Create(c *cli.Clients, pr *v1beta1.PipelineRun, opts metav1.CreateOptions, ns string) (*v1beta1.PipelineRun, error)
• func Get(c *cli.Clients, prname string, opts metav1.GetOptions, ns string) (*v1beta1.PipelineRun, error)
• func GetAllPipelineRuns(p cli.Params, opts metav1.ListOptions, limit int) ([]string, error)
• func GetV1beta1(c *cli.Clients, prname string, opts metav1.GetOptions, ns string) (*v1beta1.PipelineRun, error)
• func List(c *cli.Clients, opts metav1.ListOptions, ns string) (*v1beta1.PipelineRunList, error)
• func Patch(c *cli.Clients, prname string, opts metav1.PatchOptions, ns string) (*v1beta1.PipelineRun, error)
• func Watch(c *cli.Clients, opts metav1.ListOptions, ns string) (watch.Interface, error)
• type Tracker
  • func NewTracker(name string, ns string, tekton versioned.Interface) *Tracker
  • func (t *Tracker) Monitor(allowed []string) <-chan []trh.Run

Functions

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 Get

func Get(c *cli.Clients, prname string, opts metav1.GetOptions, ns string) (*v1beta1.PipelineRun, error)

It will fetch the resource based on the api available and return v1beta1 form

func GetAllPipelineRuns

func GetAllPipelineRuns(p cli.Params, opts metav1.ListOptions, limit int) ([]string, error)

GetAllPipelineRuns returns all pipelinesruns running in a namespace

func GetV1beta1

func GetV1beta1(c *cli.Clients, prname string, opts metav1.GetOptions, ns string) (*v1beta1.PipelineRun, error)

It will fetch the resource in v1beta1 struct format

func List

func List(c *cli.Clients, opts metav1.ListOptions, ns string) (*v1beta1.PipelineRunList, error)

func Patch

func Patch(c *cli.Clients, prname string, opts metav1.PatchOptions, ns string) (*v1beta1.PipelineRun, error)

func Watch

func Watch(c *cli.Clients, opts metav1.ListOptions, ns string) (watch.Interface, error)

Types

type Tracker

type Tracker struct {
	Name   string
	Ns     string
	Tekton versioned.Interface
	// contains filtered or unexported fields
}

Tracker tracks the progress of a PipelineRun

func NewTracker

func NewTracker(name string, ns string, tekton versioned.Interface) *Tracker

NewTracker returns a new instance of Tracker

func (*Tracker) Monitor

func (t *Tracker) Monitor(allowed []string) <-chan []trh.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