pendingpipelinerun

Documentation

Index

• Constants
• func CreatePipelineRunWithMutations(ctx context.Context, client client.Client, run *v1beta1.PipelineRun) error
• func InitPrometheus(client client.Client)
• func MutatePipelineRun(run *v1beta1.PipelineRun) *v1beta1.PipelineRun
• func PipelineRunStats(prList *v1beta1.PipelineRunList) (map[string]Counts, error)
• func SetupPRReconcilerWithManager(mgr ctrl.Manager) error
• type Counts
• type ReconcilePendingPipelineRun
  • func SetupClientAndPRReconciler(useOpenshift bool, objs ...runtimeclient.Object) (runtimeclient.Client, *ReconcilePendingPipelineRun)
  • func (r *ReconcilePendingPipelineRun) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (
	NamespaceLabel  string = "namespace"
	PendingMetric   string = "stonesoup_pending_pipelineruns_total"
	AbandonedMetric string = "stonesoup_abandoned_pipelineruns_total"
)

const (

	//TODO move to API folder, along with config obj changes
	AbandonedAnnotation = "openshift-pipelines/cancelled-to-abandon"
	AbandonedReason     = "Abandoned"
	AbandonedMessage    = "PipelineRun %s:%s abandoned because of Pod Quota pressure"
)

Functions

func CreatePipelineRunWithMutations

func CreatePipelineRunWithMutations(ctx context.Context, client client.Client, run *v1beta1.PipelineRun) error

func InitPrometheus

func InitPrometheus(client client.Client)

func MutatePipelineRun

func MutatePipelineRun(run *v1beta1.PipelineRun) *v1beta1.PipelineRun

func PipelineRunStats

func PipelineRunStats(prList *v1beta1.PipelineRunList) (map[string]Counts, error)

func SetupPRReconcilerWithManager

func SetupPRReconcilerWithManager(mgr ctrl.Manager) error

Types

type Counts

type Counts struct {
	ActiveCount    int
	PendingCount   int
	AbandonedCount int
	DoneCount      int
	TotalCount     int
}

type ReconcilePendingPipelineRun

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

func SetupClientAndPRReconciler

func SetupClientAndPRReconciler(useOpenshift bool, objs ...runtimeclient.Object) (runtimeclient.Client, *ReconcilePendingPipelineRun)

func (*ReconcilePendingPipelineRun) Reconcile

func (r *ReconcilePendingPipelineRun) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)