control

Sep 1, 2023

Changes in this version

+ var JobRunningRequeue = 10 * time.Second

+ var TaskRunningRequeue = time.Duration(5 * time.Second)

Jun 30, 2023

Changes in this version

+ const PodJobAnnotationPrefix

+ func JobStatusToPodAnnotations(taskId string, annotations map[string]string, jobStatus JobStatus) error

+ func SetCondition(task *api.CassandraTask, condition api.JobConditionType, ...) bool

+ type AsyncTaskExecutorFunc func(httphelper.NodeMgmtClient, *corev1.Pod, *TaskConfiguration) (string, error)

+ type CassandraTaskReconciler struct

+ Scheme *runtime.Scheme

+ func (r *CassandraTaskReconciler) HasCondition(task api.CassandraTask, condition api.JobConditionType, ...) bool

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

+ func (r *CassandraTaskReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type JobStatus struct

+ Handler string

+ Id string

+ Retries int

+ Status string

+ func GetJobStatusFromPodAnnotations(taskId string, annotations map[string]string) (JobStatus, error)

+ type PodFilterFunc func(*corev1.Pod, *TaskConfiguration) bool

+ type ProcessFunc func(*TaskConfiguration) error

+ type SyncTaskExecutorFunc func(httphelper.NodeMgmtClient, *corev1.Pod, *TaskConfiguration) error

+ type TaskConfiguration struct

+ Arguments api.JobArguments

+ AsyncFeature httphelper.Feature

+ AsyncFunc AsyncTaskExecutorFunc

+ Completed int

+ Context context.Context

+ Datacenter *cassapi.CassandraDatacenter

+ Id string

+ PodFilter PodFilterFunc

+ PreProcessFunc ProcessFunc

+ RestartPolicy corev1.RestartPolicy

+ SyncFunc SyncTaskExecutorFunc

+ TaskStartTime *metav1.Time

+ ValidateFunc ValidatorFunc

+ func (t *TaskConfiguration) Filter(pod *corev1.Pod) bool

+ func (t *TaskConfiguration) PreProcess() error

+ func (t *TaskConfiguration) Validate() error

+ type ValidatorFunc func(*TaskConfiguration) error