tekton

Documentation

Index

• Constants
• func ConvertPipelineRun(pr *v1beta1.PipelineRun) *v1alpha1.ActivityRecord
• func RateLimiter() workqueue.RateLimitingInterface
• type Controller
  • func NewController(kubeClient kubernetes.Interface, tektonClient tektonclient.Interface, ...) (*Controller, error)
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

Constants

const (
	// ProwImplicitGitResource is the keyword used to signal generating Tekton pipelines' git resources dynamically
	ProwImplicitGitResource = "PROW_IMPLICIT_GIT_REF"
)

Functions

func ConvertPipelineRun

func ConvertPipelineRun(pr *v1beta1.PipelineRun) *v1alpha1.ActivityRecord

ConvertPipelineRun translates a PipelineRun into an ActivityRecord

func RateLimiter

func RateLimiter() workqueue.RateLimitingInterface

RateLimiter creates a ratelimiting queue for the foghorn controller.

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller listens for changes to PipelineRuns and updates the corresponding LighthouseJobs with their activity

func NewController

func NewController(kubeClient kubernetes.Interface, tektonClient tektonclient.Interface, lhClient clientset.Interface, prInformer tektoninformers.PipelineRunInformer,
	lhInformer lhinformers.LighthouseJobInformer, ns string, dashboardURL string, logger *logrus.Entry) (*Controller, error)

NewController returns a new controller for syncing PipelineRun updates to LighthouseJobs and commit statuses

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

Run actually runs the controller