utils

Documentation

Index

• func ContextForManagerSync(parent context.Context, sc *scyllav1.ScyllaCluster) (context.Context, context.CancelFunc)
• func ContextForRollout(parent context.Context, sc *scyllav1.ScyllaCluster) (context.Context, context.CancelFunc)
• func GetDaemonSetsForNodeConfig(ctx context.Context, client appv1client.AppsV1Interface, ...) ([]*appsv1.DaemonSet, error)
• func GetHosts(ctx context.Context, client corev1client.CoreV1Interface, ...) ([]string, error)
• func GetManagerClient(ctx context.Context, client corev1client.CoreV1Interface) (*mermaidclient.Client, error)
• func GetMatchingNodesForNodeConfig(ctx context.Context, nodeGetter corev1client.NodesGetter, ...) ([]*corev1.Node, error)
• func GetMemberCount(sc *scyllav1.ScyllaCluster) int32
• func GetNodeName(sc *scyllav1.ScyllaCluster, idx int) string
• func GetScyllaClient(ctx context.Context, client corev1client.CoreV1Interface, ...) (*scyllaclient.Client, []string, error)
• func GetStatefulSetsForScyllaCluster(ctx context.Context, client appv1client.AppsV1Interface, ...) (map[string]*appsv1.StatefulSet, error)
• func IsNodeConfigDoneWithNodeTuningFunc(nodes []*corev1.Node) func(nc *scyllav1alpha1.NodeConfig) (bool, error)
• func IsNodeConfigRolledOut(nc *scyllav1alpha1.NodeConfig) (bool, error)
• func IsScyllaClusterRolledOut(sc *scyllav1.ScyllaCluster) (bool, error)
• func RolloutTimeoutForScyllaCluster(sc *scyllav1.ScyllaCluster) time.Duration
• func SyncTimeoutForScyllaCluster(sc *scyllav1.ScyllaCluster) time.Duration
• func WaitForConfigMapState(ctx context.Context, cmClient corev1client.ConfigMapInterface, name string, ...) (*corev1.ConfigMap, error)
• func WaitForNodeConfigState(ctx context.Context, ncClient scyllav1alpha1client.NodeConfigInterface, ...) (*scyllav1alpha1.NodeConfig, error)
• func WaitForPVCState(ctx context.Context, client corev1client.CoreV1Interface, namespace string, ...) (*corev1.PersistentVolumeClaim, error)
• func WaitForPodState(ctx context.Context, client corev1client.CoreV1Interface, namespace string, ...) (*corev1.Pod, error)
• func WaitForScyllaClusterState(ctx context.Context, client scyllav1client.ScyllaV1Interface, namespace string, ...) (*scyllav1.ScyllaCluster, error)
• type WaitForStateOptions

Functions

func ContextForManagerSync

func ContextForManagerSync(parent context.Context, sc *scyllav1.ScyllaCluster) (context.Context, context.CancelFunc)

func ContextForRollout

func ContextForRollout(parent context.Context, sc *scyllav1.ScyllaCluster) (context.Context, context.CancelFunc)

func GetDaemonSetsForNodeConfig

func GetDaemonSetsForNodeConfig(ctx context.Context, client appv1client.AppsV1Interface, nc *scyllav1alpha1.NodeConfig) ([]*appsv1.DaemonSet, error)

func GetHosts

func GetHosts(ctx context.Context, client corev1client.CoreV1Interface, sc *scyllav1.ScyllaCluster) ([]string, error)

func GetManagerClient

func GetManagerClient(ctx context.Context, client corev1client.CoreV1Interface) (*mermaidclient.Client, error)

GetManagerClient gets managerClient using IP address. E2E tests shouldn't rely on InCluster DNS.

func GetMatchingNodesForNodeConfig

func GetMatchingNodesForNodeConfig(ctx context.Context, nodeGetter corev1client.NodesGetter, nc *scyllav1alpha1.NodeConfig) ([]*corev1.Node, error)

func GetMemberCount

func GetMemberCount(sc *scyllav1.ScyllaCluster) int32

func GetNodeName

func GetNodeName(sc *scyllav1.ScyllaCluster, idx int) string

func GetScyllaClient

func GetScyllaClient(ctx context.Context, client corev1client.CoreV1Interface, sc *scyllav1.ScyllaCluster) (*scyllaclient.Client, []string, error)

func GetStatefulSetsForScyllaCluster

func GetStatefulSetsForScyllaCluster(ctx context.Context, client appv1client.AppsV1Interface, sc *scyllav1.ScyllaCluster) (map[string]*appsv1.StatefulSet, error)

func IsNodeConfigDoneWithNodeTuningFunc

func IsNodeConfigDoneWithNodeTuningFunc(nodes []*corev1.Node) func(nc *scyllav1alpha1.NodeConfig) (bool, error)

func IsNodeConfigRolledOut

func IsNodeConfigRolledOut(nc *scyllav1alpha1.NodeConfig) (bool, error)

func IsScyllaClusterRolledOut

func IsScyllaClusterRolledOut(sc *scyllav1.ScyllaCluster) (bool, error)

func RolloutTimeoutForScyllaCluster

func RolloutTimeoutForScyllaCluster(sc *scyllav1.ScyllaCluster) time.Duration

func SyncTimeoutForScyllaCluster

func SyncTimeoutForScyllaCluster(sc *scyllav1.ScyllaCluster) time.Duration

func WaitForConfigMapState

func WaitForConfigMapState(ctx context.Context, cmClient corev1client.ConfigMapInterface, name string, o WaitForStateOptions, condition func(cm *corev1.ConfigMap) (bool, error), additionalConditions ...func(cm *corev1.ConfigMap) (bool, error)) (*corev1.ConfigMap, error)

func WaitForNodeConfigState

func WaitForNodeConfigState(ctx context.Context, ncClient scyllav1alpha1client.NodeConfigInterface, name string, o WaitForStateOptions, condition func(sc *scyllav1alpha1.NodeConfig) (bool, error), additionalConditions ...func(sc *scyllav1alpha1.NodeConfig) (bool, error)) (*scyllav1alpha1.NodeConfig, error)

func WaitForPVCState

func WaitForPVCState(ctx context.Context, client corev1client.CoreV1Interface, namespace string, name string, condition func(sc *corev1.PersistentVolumeClaim) (bool, error), o WaitForStateOptions) (*corev1.PersistentVolumeClaim, error)

func WaitForPodState

func WaitForPodState(ctx context.Context, client corev1client.CoreV1Interface, namespace string, name string, condition func(sc *corev1.Pod) (bool, error), o WaitForStateOptions) (*corev1.Pod, error)

func WaitForScyllaClusterState

func WaitForScyllaClusterState(ctx context.Context, client scyllav1client.ScyllaV1Interface, namespace string, name string, conditions ...func(sc *scyllav1.ScyllaCluster) (bool, error)) (*scyllav1.ScyllaCluster, error)

Types

type WaitForStateOptions

type WaitForStateOptions struct {
	TolerateDelete bool
}