scyllacluster

Documentation

Index

• func InsertAndVerifyCQLData(ctx context.Context, hosts []string, options ...utils.DataInserterOption) *utils.DataInserter
• func InsertAndVerifyCQLDataByDC(ctx context.Context, hosts map[string][]string) *utils.DataInserter
• func InsertAndVerifyCQLDataUsingDataInserter(ctx context.Context, di *utils.DataInserter) *utils.DataInserter
• func Verify(ctx context.Context, kubeClient kubernetes.Interface, ...)
• func VerifyAndParseCQLConnectionConfigs(secret *corev1.Secret, options VerifyCQLConnectionConfigsOptions) map[string]*cqlclientv1alpha1.CQLConnectionConfig
• func VerifyCQLData(ctx context.Context, di *utils.DataInserter)
• func VerifyWithOptions(ctx context.Context, kubeClient kubernetes.Interface, ...)
• func WaitForFullMultiDCQuorum(ctx context.Context, dcClientMap map[string]corev1client.CoreV1Interface, ...)
• func WaitForFullQuorum(ctx context.Context, client corev1client.CoreV1Interface, ...)
• type VerifyCQLConnectionConfigsOptions
• type VerifyOptions
• type VerifyStatefulSetOptions

Functions

func InsertAndVerifyCQLData

func InsertAndVerifyCQLData(ctx context.Context, hosts []string, options ...utils.DataInserterOption) *utils.DataInserter

func InsertAndVerifyCQLDataByDC

func InsertAndVerifyCQLDataByDC(ctx context.Context, hosts map[string][]string) *utils.DataInserter

func InsertAndVerifyCQLDataUsingDataInserter

func InsertAndVerifyCQLDataUsingDataInserter(ctx context.Context, di *utils.DataInserter) *utils.DataInserter

func Verify

func Verify(ctx context.Context, kubeClient kubernetes.Interface, scyllaClient scyllaclient.Interface, sc *scyllav1.ScyllaCluster)

func VerifyAndParseCQLConnectionConfigs

func VerifyAndParseCQLConnectionConfigs(secret *corev1.Secret, options VerifyCQLConnectionConfigsOptions) map[string]*cqlclientv1alpha1.CQLConnectionConfig

func VerifyCQLData

func VerifyCQLData(ctx context.Context, di *utils.DataInserter)

func VerifyWithOptions

func VerifyWithOptions(ctx context.Context, kubeClient kubernetes.Interface, scyllaClient scyllaclient.Interface, sc *scyllav1.ScyllaCluster, options VerifyOptions)

func WaitForFullMultiDCQuorum

func WaitForFullMultiDCQuorum(ctx context.Context, dcClientMap map[string]corev1client.CoreV1Interface, scs []*scyllav1.ScyllaCluster)

func WaitForFullQuorum

func WaitForFullQuorum(ctx context.Context, client corev1client.CoreV1Interface, sc *scyllav1.ScyllaCluster)

Types

type VerifyCQLConnectionConfigsOptions

type VerifyCQLConnectionConfigsOptions struct {
	Domains               []string
	Datacenters           []string
	ServingCAData         []byte
	ClientCertificateData []byte
	ClientKeyData         []byte
}

type VerifyOptions

type VerifyOptions struct {
	VerifyStatefulSetOptions
}

type VerifyStatefulSetOptions

type VerifyStatefulSetOptions struct {
	PodRestartCountAssertion func(a o.Assertion, containerName, podName string)
}