common

func AssertEvent ¶

func AssertEvent(t *testing.T, event chan string, message string)

func HelperGetStatefulset ¶

func HelperGetStatefulset(t *testing.T, dcRackName string) *v12.StatefulSet

func HelperInitCassandraBackup ¶

func HelperInitCassandraBackup(cassandraBackupYaml string) v1alpha1.CassandraBackup

func HelperLoadBytes ¶

func HelperLoadBytes(t *testing.T, name string) []byte

func NewCassandraBackupConnection ¶

func NewCassandraBackupConnection(client client.Client, cluster *api.CassandraCluster,
	pod *corev1.Pod) (csClient cassandrabackup.Client, err error)

NewCassandraBackupConnection is a convenience wrapper for creating a sidecars connection and creating a safer close function

func Reconciled ¶

func Reconciled() (reconcile.Result, error)

reconciled returns an empty result with nil error to signal a successful reconcile to the controller manager

func RequeueWithError ¶

func RequeueWithError(logger *logrus.Entry, msg string, err error) (reconcile.Result, error)

RequeueWithError is a convenience wrapper around logging an error message separate from the stacktrace and then passing the error through to the controller manager