control

Jan 30, 2023

Changes in this version

type TaskConfiguration

+ Completed int

Sep 29, 2022

Changes in this version

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

+ type ProcessFunc func(*TaskConfiguration) error

type TaskConfiguration

+ Context context.Context

+ Datacenter *cassapi.CassandraDatacenter

+ PodFilter PodFilterFunc

+ PreProcessFunc ProcessFunc

+ 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

Mar 29, 2023

Changes in this version

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

type CassandraTaskReconciler

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

Feb 17, 2022

Changes in this version

+ const PodJobAnnotationPrefix

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

+ type AsyncTaskExecutorFunc func(httphelper.NodeMgmtClient, *corev1.Pod, map[string]string) (string, error)

+ type CassandraTaskReconciler struct

+ Scheme *runtime.Scheme

+ 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 SyncTaskExecutorFunc func(httphelper.NodeMgmtClient, *corev1.Pod, map[string]string) error

+ type TaskConfiguration struct

+ Arguments map[string]string

+ AsyncFeature httphelper.Feature

+ AsyncFunc AsyncTaskExecutorFunc

+ Id string

+ RestartPolicy corev1.RestartPolicy

+ SyncFunc SyncTaskExecutorFunc