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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 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
}
Click to show internal directories.
Click to hide internal directories.