jx

Documentation

Index

• func ConvertPipelineActivity(pa *v1.PipelineActivity) (*v1alpha1.ActivityRecord, error)
• func NewMetaPipelineClient(ns string) (metapipeline.Client, jxclient.Interface, clientset.Interface, error)
• func RateLimiter() workqueue.RateLimitingInterface
• func ToPipelineState(status v1.ActivityStatusType) v1alpha1.PipelineState
• type Controller
  • func NewController(kubeClient kubernetes.Interface, jxClient jxclient.Interface, ...) (*Controller, error)
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

Functions

func ConvertPipelineActivity

func ConvertPipelineActivity(pa *v1.PipelineActivity) (*v1alpha1.ActivityRecord, error)

ConvertPipelineActivity converts a PipelineActivity from jx to an ActivityRecord

func NewMetaPipelineClient

func NewMetaPipelineClient(ns string) (metapipeline.Client, jxclient.Interface, clientset.Interface, error)

NewMetaPipelineClient creates a new client for the creation and application of meta pipelines. The responsibility of the meta pipeline is to prepare the execution pipeline and to allow Apps to contribute the this execution pipeline.

func RateLimiter

func RateLimiter() workqueue.RateLimitingInterface

RateLimiter creates a ratelimiting queue for the foghorn controller.

func ToPipelineState

func ToPipelineState(status v1.ActivityStatusType) v1alpha1.PipelineState

ToPipelineState converts the PipelineActivity state to LighthouseJob state

Types

type Controller

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

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

func NewController

func NewController(kubeClient kubernetes.Interface, jxClient jxclient.Interface, lhClient clientset.Interface, activityInformer jxinformers.PipelineActivityInformer,
	lhInformer lhinformers.LighthouseJobInformer, ns string, logger *logrus.Entry) (*Controller, error)

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

func (*Controller) Run

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

Run actually runs the controller