batchcontrollers

Documentation

Index

• type BatchJobReconciler
  • func (r *BatchJobReconciler) ConvertControllerBatchToJobSpec(batchJob batch.BatchJob, api spec.API, queueURL string) (spec.BatchJob, error)
  • func (r *BatchJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BatchJobReconciler) SetupWithManager(mgr ctrl.Manager) error
• type BatchJobReconcilerConfig
  • func (c BatchJobReconcilerConfig) ApplyDefaults() BatchJobReconcilerConfig

Types

type BatchJobReconciler

type BatchJobReconciler struct {
	client.Client
	Config        BatchJobReconcilerConfig
	Log           logr.Logger
	AWS           *awslib.Client
	ClusterConfig *clusterconfig.Config
	Prometheus    promv1.API
	Scheme        *runtime.Scheme
}

BatchJobReconciler reconciles a BatchJob object

func (*BatchJobReconciler) ConvertControllerBatchToJobSpec

func (r *BatchJobReconciler) ConvertControllerBatchToJobSpec(batchJob batch.BatchJob, api spec.API, queueURL string) (spec.BatchJob, error)

func (*BatchJobReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*BatchJobReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type BatchJobReconcilerConfig

type BatchJobReconcilerConfig struct {
	GetTotalBatchCount func(r *BatchJobReconciler, batchJob batch.BatchJob) (int, error)
	GetMetrics         func(r *BatchJobReconciler, batchJob batch.BatchJob) (metrics.BatchMetrics, error)
	SaveJobMetrics     func(r *BatchJobReconciler, batchJob batch.BatchJob) error
	SaveJobStatus      func(r *BatchJobReconciler, batchJob batch.BatchJob) error
}

BatchJobReconcilerConfig reconciler config for the BatchJob kind. Allows for mocking specific methods

func (BatchJobReconcilerConfig) ApplyDefaults

func (c BatchJobReconcilerConfig) ApplyDefaults() BatchJobReconcilerConfig

ApplyDefaults sets the defaults for BatchJobReconcilerConfig