Documentation
¶
Index ¶
- Constants
- 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 GetHostsAndUUIDs(ctx context.Context, client corev1client.CoreV1Interface, ...) ([]string, []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 GetMemberServiceSelector(scyllaClusterName string) labels.Selector
- func GetNodeName(sc *scyllav1.ScyllaCluster, idx int) string
- func GetScyllaClient(ctx context.Context, client corev1client.CoreV1Interface, ...) (*scyllaclient.Client, []string, error)
- func GetScyllaHostsAndWaitForFullQuorum(ctx context.Context, client corev1client.CoreV1Interface, ...) ([]string, error)
- func GetServerTLSCertificates(address string, tlsConfig *tls.Config) ([]*x509.Certificate, 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 RunEphemeralContainerAndWaitForCompletion(ctx context.Context, client corev1client.PodInterface, podName string, ...) (*corev1.Pod, error)
- func SyncTimeoutForScyllaCluster(sc *scyllav1.ScyllaCluster) time.Duration
- func WaitForConfigMapState(ctx context.Context, client corev1client.ConfigMapInterface, name string, ...) (*corev1.ConfigMap, error)
- func WaitForNodeConfigState(ctx context.Context, ncClient scyllav1alpha1client.NodeConfigInterface, ...) (*scyllav1alpha1.NodeConfig, error)
- func WaitForObjectState[Object, ListObject runtime.Object](ctx context.Context, client listerWatcher[ListObject], name string, ...) (Object, error)
- func WaitForPVCState(ctx context.Context, client corev1client.CoreV1Interface, namespace string, ...) (*corev1.PersistentVolumeClaim, error)
- func WaitForPodState(ctx context.Context, client corev1client.PodInterface, name string, ...) (*corev1.Pod, error)
- func WaitForRoleBindingState(ctx context.Context, client rbacv1client.RbacV1Interface, namespace string, ...) (*rbacv1.RoleBinding, error)
- func WaitForScyllaClusterState(ctx context.Context, client scyllav1client.ScyllaV1Interface, namespace string, ...) (*scyllav1.ScyllaCluster, error)
- func WaitForSecretState(ctx context.Context, client corev1client.SecretInterface, name string, ...) (*corev1.Secret, error)
- func WaitForServiceAccountState(ctx context.Context, client corev1client.CoreV1Interface, namespace string, ...) (*corev1.ServiceAccount, error)
- type DataInserter
- type TestData
- type WaitForStateOptions
Constants ¶
View Source
const ( // SyncTimeout is the maximum time the sync loop can last. In normal circumstances this is in the order // of seconds but there are special cases we need to account for. Like when the sync loop generates new keys // and signs certificates it can take several seconds. When the CI creates multiple clusters in parallel on // a constrained CPU, one cert can easily take over 30s. SyncTimeout = 2 * time.Minute )
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 GetHostsAndUUIDs ¶ added in v1.8.0
func GetHostsAndUUIDs(ctx context.Context, client corev1client.CoreV1Interface, sc *scyllav1.ScyllaCluster) ([]string, []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 GetMemberServiceSelector ¶ added in v1.8.0
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 GetScyllaHostsAndWaitForFullQuorum ¶ added in v1.8.0
func GetScyllaHostsAndWaitForFullQuorum(ctx context.Context, client corev1client.CoreV1Interface, sc *scyllav1.ScyllaCluster) ([]string, error)
func GetServerTLSCertificates ¶ added in v1.8.0
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 RunEphemeralContainerAndWaitForCompletion ¶ added in v1.8.0
func RunEphemeralContainerAndWaitForCompletion(ctx context.Context, client corev1client.PodInterface, podName string, ec *corev1.EphemeralContainer) (*corev1.Pod, error)
func SyncTimeoutForScyllaCluster ¶
func SyncTimeoutForScyllaCluster(sc *scyllav1.ScyllaCluster) time.Duration
func WaitForConfigMapState ¶
func WaitForNodeConfigState ¶
func WaitForNodeConfigState(ctx context.Context, ncClient scyllav1alpha1client.NodeConfigInterface, name string, options WaitForStateOptions, condition func(*scyllav1alpha1.NodeConfig) (bool, error), additionalConditions ...func(*scyllav1alpha1.NodeConfig) (bool, error)) (*scyllav1alpha1.NodeConfig, error)
func WaitForObjectState ¶ added in v1.8.0
func WaitForPVCState ¶
func WaitForPVCState(ctx context.Context, client corev1client.CoreV1Interface, namespace string, name string, options WaitForStateOptions, condition func(*corev1.PersistentVolumeClaim) (bool, error), additionalConditions ...func(*corev1.PersistentVolumeClaim) (bool, error)) (*corev1.PersistentVolumeClaim, error)
func WaitForPodState ¶
func WaitForRoleBindingState ¶ added in v1.8.0
func WaitForRoleBindingState(ctx context.Context, client rbacv1client.RbacV1Interface, namespace string, name string, options WaitForStateOptions, condition func(*rbacv1.RoleBinding) (bool, error), additionalConditions ...func(*rbacv1.RoleBinding) (bool, error)) (*rbacv1.RoleBinding, error)
func WaitForScyllaClusterState ¶
func WaitForScyllaClusterState(ctx context.Context, client scyllav1client.ScyllaV1Interface, namespace string, name string, options WaitForStateOptions, condition func(*scyllav1.ScyllaCluster) (bool, error), additionalConditions ...func(*scyllav1.ScyllaCluster) (bool, error)) (*scyllav1.ScyllaCluster, error)
func WaitForSecretState ¶ added in v1.8.0
func WaitForServiceAccountState ¶ added in v1.8.0
func WaitForServiceAccountState(ctx context.Context, client corev1client.CoreV1Interface, namespace string, name string, options WaitForStateOptions, condition func(*corev1.ServiceAccount) (bool, error), additionalConditions ...func(*corev1.ServiceAccount) (bool, error)) (*corev1.ServiceAccount, error)
Types ¶
type DataInserter ¶ added in v1.8.0
type DataInserter struct {
// contains filtered or unexported fields
}
func NewDataInserter ¶ added in v1.8.0
func NewDataInserter(hosts []string) (*DataInserter, error)
func (*DataInserter) Close ¶ added in v1.8.0
func (di *DataInserter) Close()
func (*DataInserter) GetExpected ¶ added in v1.8.0
func (di *DataInserter) GetExpected() []*TestData
func (*DataInserter) Insert ¶ added in v1.8.0
func (di *DataInserter) Insert() error
func (*DataInserter) Read ¶ added in v1.8.0
func (di *DataInserter) Read() ([]*TestData, error)
func (*DataInserter) SetClientEndpoints ¶ added in v1.8.0
func (di *DataInserter) SetClientEndpoints(hosts []string) error
SetClientEndpoints creates a new session and closes a previous session if it existed. In case an error was returned, DataInserter can no Longer be used.
type WaitForStateOptions ¶
type WaitForStateOptions struct {
TolerateDelete bool
}
Click to show internal directories.
Click to hide internal directories.