controllers

Documentation

Index

• Constants
• func NewTaskWorkloadReconciler(logger logr.Logger, k8sClient client.Client, scheme *runtime.Scheme, ...) ...
• type StatusGetter
  • func NewStatusGetter(k8sClient client.Client) *StatusGetter
  • func (s *StatusGetter) GetStatusConditions(ctx context.Context, job *batchv1.Job) ([]metav1.Condition, error)
• type TaskStatusGetter
• type TaskWorkloadReconciler
  • func (r *TaskWorkloadReconciler) ReconcileResource(ctx context.Context, taskWorkload *korifiv1alpha1.TaskWorkload) (ctrl.Result, error)
  • func (r *TaskWorkloadReconciler) SetupWithManager(mgr ctrl.Manager) *builder.Builder

Constants

const (
	ServiceAccountName = "korifi-task"
)

Functions

func NewTaskWorkloadReconciler

func NewTaskWorkloadReconciler(
	logger logr.Logger,
	k8sClient client.Client,
	scheme *runtime.Scheme,
	statusGetter TaskStatusGetter,
	jobTTL time.Duration,
) *k8s.PatchingReconciler[korifiv1alpha1.TaskWorkload, *korifiv1alpha1.TaskWorkload]

Types

type StatusGetter

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

func NewStatusGetter

func NewStatusGetter(k8sClient client.Client) *StatusGetter

func (*StatusGetter) GetStatusConditions

func (s *StatusGetter) GetStatusConditions(ctx context.Context, job *batchv1.Job) ([]metav1.Condition, error)

type TaskStatusGetter

type TaskStatusGetter interface {
	GetStatusConditions(ctx context.Context, job *batchv1.Job) ([]metav1.Condition, error)
}

type TaskWorkloadReconciler

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

TaskWorkloadReconciler reconciles a TaskWorkload object

func (*TaskWorkloadReconciler) ReconcileResource

func (r *TaskWorkloadReconciler) ReconcileResource(ctx context.Context, taskWorkload *korifiv1alpha1.TaskWorkload) (ctrl.Result, error)

func (*TaskWorkloadReconciler) SetupWithManager

func (r *TaskWorkloadReconciler) SetupWithManager(mgr ctrl.Manager) *builder.Builder