skipjobcontroller

Documentation

Index

• Constants
• Variables
• func GetJobLabels(skipJob *skiperatorv1alpha1.SKIPJob, jobName string, labels map[string]string) map[string]string
• type SKIPJobReconciler
  • func (r *SKIPJobReconciler) GetLastCondition(conditions []v1.Condition) (*v1.Condition, bool)
  • func (r *SKIPJobReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (r *SKIPJobReconciler) SetStatusFailed(ctx context.Context, skipJob *skiperatorv1alpha1.SKIPJob, errMessage string) error
  • func (r *SKIPJobReconciler) SetStatusFinished(ctx context.Context, skipJob *skiperatorv1alpha1.SKIPJob) error
  • func (r *SKIPJobReconciler) SetStatusRunning(ctx context.Context, skipJob *skiperatorv1alpha1.SKIPJob) error
  • func (r *SKIPJobReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	ConditionRunning  = "Running"
	ConditionFinished = "Finished"

	ConditionFailed = "Failed"
)

Variables

var (
	SKIPJobReferenceLabelKey = "skipJobOwnerName"
	DefaultPollingRate       = time.Second * 15

	DefaultRequeueForPodsWait = time.Second * 5

	DefaultAwaitCronJobResourcesWait = time.Second * 5

	IstioProxyPodContainerName = "istio-proxy"
)

Functions

func GetJobLabels

func GetJobLabels(skipJob *skiperatorv1alpha1.SKIPJob, jobName string, labels map[string]string) map[string]string

Types

type SKIPJobReconciler

type SKIPJobReconciler struct {
	util.ReconcilerBase
}

func (*SKIPJobReconciler) GetLastCondition

func (r *SKIPJobReconciler) GetLastCondition(conditions []v1.Condition) (*v1.Condition, bool)

func (*SKIPJobReconciler) Reconcile

func (r *SKIPJobReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*SKIPJobReconciler) SetStatusFailed

func (r *SKIPJobReconciler) SetStatusFailed(ctx context.Context, skipJob *skiperatorv1alpha1.SKIPJob, errMessage string) error

func (*SKIPJobReconciler) SetStatusFinished

func (r *SKIPJobReconciler) SetStatusFinished(ctx context.Context, skipJob *skiperatorv1alpha1.SKIPJob) error

func (*SKIPJobReconciler) SetStatusRunning

func (r *SKIPJobReconciler) SetStatusRunning(ctx context.Context, skipJob *skiperatorv1alpha1.SKIPJob) error

func (*SKIPJobReconciler) SetupWithManager

func (r *SKIPJobReconciler) SetupWithManager(mgr ctrl.Manager) error