controllers

Documentation

Index

• Constants
• func GetSubdomain(js *jobset.JobSet) string
• func JobFinished(job *batchv1.Job) (bool, batchv1.JobConditionType)
• func SetupJobSetIndexes(ctx context.Context, indexer client.FieldIndexer) error
• func SetupPodIndexes(ctx context.Context, indexer client.FieldIndexer) error
• type JobSetReconciler
  • func NewJobSetReconciler(client client.Client, scheme *runtime.Scheme, record record.EventRecorder) *JobSetReconciler
  • func (r *JobSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *JobSetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PodReconciler
  • func NewPodReconciler(client client.Client, scheme *runtime.Scheme, record record.EventRecorder) *PodReconciler
  • func (r *PodReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PodReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	// PodNameKey is the key used for building an index where the key is the
	// pod name (without the random suffix), and the value is the pod itself.
	PodNameKey string = "podName"
)

Functions

func GetSubdomain

func GetSubdomain(js *jobset.JobSet) string

func JobFinished

func JobFinished(job *batchv1.Job) (bool, batchv1.JobConditionType)

func SetupJobSetIndexes

func SetupJobSetIndexes(ctx context.Context, indexer client.FieldIndexer) error

func SetupPodIndexes

func SetupPodIndexes(ctx context.Context, indexer client.FieldIndexer) error

Types

type JobSetReconciler

type JobSetReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Record record.EventRecorder
	// contains filtered or unexported fields
}

JobSetReconciler reconciles a JobSet object

func NewJobSetReconciler

func NewJobSetReconciler(client client.Client, scheme *runtime.Scheme, record record.EventRecorder) *JobSetReconciler

func (*JobSetReconciler) Reconcile

func (r *JobSetReconciler) 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 (*JobSetReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PodReconciler

type PodReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Record record.EventRecorder
}

PodReconciler reconciles a Pod owned by a JobSet using exclusive placement.

func NewPodReconciler

func NewPodReconciler(client client.Client, scheme *runtime.Scheme, record record.EventRecorder) *PodReconciler

func (*PodReconciler) Reconcile

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

Reconcile attempts to enforce that the pods that belong to the same job are scheduled on the same topology domain exclusively if the parent JobSet is using exclusive placement.

func (*PodReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.