controllers

Documentation

Index

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

Constants

const (
	ServiceAccountName = "korifi-task"
)

Types

type StatusGetter

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

func NewStatusGetter

func NewStatusGetter(logger logr.Logger, 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 NewTaskWorkloadReconciler

func NewTaskWorkloadReconciler(logger logr.Logger, k8sClient client.Client, scheme *runtime.Scheme, statusGetter TaskStatusGetter, jobTTL time.Duration) *TaskWorkloadReconciler

func (*TaskWorkloadReconciler) Reconcile

func (r *TaskWorkloadReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*TaskWorkloadReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.