Versions in this module Expand all Collapse all v0 v0.5.0 Dec 5, 2022 Changes in this version + func OnOwnerDeleteAndDeletionExpectationFunc(jc job_controller.JobController) func(e event.DeleteEvent) bool + type ElasticBatchConfig struct + Environment string + Task TaskSpec + type ElasticBatchJobReconciler struct + func NewReconciler(mgr ctrl.Manager, config options.JobControllerConfiguration) *ElasticBatchJobReconciler + func (r *ElasticBatchJobReconciler) ControllerName() string + func (r *ElasticBatchJobReconciler) DeleteJob(job interface{}) error + func (r *ElasticBatchJobReconciler) GetAPIGroupVersion() schema.GroupVersion + func (r *ElasticBatchJobReconciler) GetAPIGroupVersionKind() schema.GroupVersionKind + func (r *ElasticBatchJobReconciler) GetDefaultContainerName() string + func (r *ElasticBatchJobReconciler) GetDefaultContainerPortName() string + func (r *ElasticBatchJobReconciler) GetDefaultContainerPortNumber() int32 + func (r *ElasticBatchJobReconciler) GetGroupNameLabelValue() string + func (r *ElasticBatchJobReconciler) GetJobFromAPIClient(namespace, name string) (metav1.Object, error) + func (r *ElasticBatchJobReconciler) GetJobFromInformerCache(namespace, name string) (metav1.Object, error) + func (r *ElasticBatchJobReconciler) GetNodeForModelOutput(pods []*corev1.Pod) (nodeName string) + func (r *ElasticBatchJobReconciler) GetPodsForJob(obj interface{}) ([]*corev1.Pod, error) + func (r *ElasticBatchJobReconciler) GetReconcileOrders() []v1.ReplicaType + func (r *ElasticBatchJobReconciler) GetServicesForJob(obj interface{}) ([]*corev1.Service, error) + func (r *ElasticBatchJobReconciler) IsMasterRole(replicas map[v1.ReplicaType]*v1.ReplicaSpec, rtype v1.ReplicaType, index int) bool + func (r *ElasticBatchJobReconciler) Reconcile(_ context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *ElasticBatchJobReconciler) SetClusterSpec(ctx context.Context, job interface{}, podTemplateSpec *corev1.PodTemplateSpec, ...) error + func (r *ElasticBatchJobReconciler) SetupWithManager(mgr ctrl.Manager) error + func (r *ElasticBatchJobReconciler) UpdateJobStatus(job interface{}, replicas map[v1.ReplicaType]*v1.ReplicaSpec, ...) error + func (r *ElasticBatchJobReconciler) UpdateJobStatusInApiServer(job interface{}, jobStatus *v1.JobStatus) error + type TaskSpec struct + Index int + Type string
Go to main page