GetJobStatusFromPodAnnotations gets the json serialized pod job statusfrom Pod.Annotations and converts it to the Affinity type in api.

PodJobAnnotationPrefix defines the prefix key for a job data (json serialized) in the annotations of the pod.

These are vars to allow modifications for testing.

These are vars to allow modifications for testing.

CassandraTaskReconciler reconciles a CassandraJob object.

TaskConfiguration sets the command's functions to execute.

AsyncTaskExecutorFunc is called for all methods that support async processing.

PodFilterFunc approves or rejects the target pod for processing purposes.

ProcessFunc is a function that's run before the pods are being processed individually, or after the pods have been processed.

SyncTaskExecutorFunc is called as a backup if async one isn't supported.

ValidatorFunc validates that necessary parameters are set for the task.