framework

Documentation

Index

• Variables
• type AerospikeClient
  • func NewAerospikeClient(aerospikeCluster *aerospikev1alpha2.AerospikeCluster) (*AerospikeClient, error)
  • func (ac *AerospikeClient) Close()
  • func (ac *AerospikeClient) GetNamespaceStorageEngine(namespace string) (string, error)
  • func (ac *AerospikeClient) GetNodeNames() []string
  • func (ac *AerospikeClient) IsConnected() bool
  • func (ac *AerospikeClient) IsDataInMemoryEnabled(namespace string) (bool, error)
  • func (ac *AerospikeClient) ReadSequentialIntegers(asNamespace string, n int) error
  • func (ac *AerospikeClient) WriteSequentialIntegers(asNamespace string, n int) error
• type TestFramework
  • func NewTestFramework(kubeconfigPath string) (*TestFramework, error)
  • func (tf *TestFramework) ChangeNamespaceMemorySizeAndScaleClusterAndWait(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, newMemorySizeGB int, ...) error
  • func (tf *TestFramework) CreateRandomNamespace() (*v1.Namespace, error)
  • func (tf *TestFramework) DeleteNamespace(ns *v1.Namespace) error
  • func (tf *TestFramework) ErrorCauses(err error) []string
  • func (tf *TestFramework) ExecInContainer(pod corev1.Pod, ns *corev1.Namespace, command []string, container string) error
  • func (tf *TestFramework) NewAerospikeCluster(version string, nodeCount int32, ...) aerospikev1alpha2.AerospikeCluster
  • func (tf *TestFramework) NewAerospikeClusterV1alpha1(version string, nodeCount int32, ...) aerospikev1alpha1.AerospikeCluster
  • func (tf *TestFramework) NewAerospikeClusterWithDefaults() aerospikev1alpha2.AerospikeCluster
  • func (tf *TestFramework) NewAerospikeNamespaceBackupGCS(cluster *aerospikev1alpha2.AerospikeCluster, namespace string, ttl *string) aerospikev1alpha2.AerospikeNamespaceBackup
  • func (tf *TestFramework) NewAerospikeNamespaceBackupGCSWithoutBackupStorageSpec(cluster *aerospikev1alpha2.AerospikeCluster, namespace string, ttl *string) aerospikev1alpha2.AerospikeNamespaceBackup
  • func (tf *TestFramework) NewAerospikeNamespaceRestoreGCS(cluster *aerospikev1alpha2.AerospikeCluster, namespace string, ...) aerospikev1alpha2.AerospikeNamespaceRestore
  • func (tf *TestFramework) NewAerospikeNamespaceRestoreGCSWithoutBackupStorageSpec(cluster *aerospikev1alpha2.AerospikeCluster, namespace string, ...) aerospikev1alpha2.AerospikeNamespaceRestore
  • func (tf *TestFramework) NewAerospikeNamespaceWithDeviceStorage(name string, replicationFactor int32, memorySizeGB int, defaultTTLSeconds int, ...) aerospikev1alpha2.AerospikeNamespaceSpec
  • func (tf *TestFramework) NewAerospikeNamespaceWithFileStorage(name string, replicationFactor int32, memorySizeGB int, defaultTTLSeconds int, ...) aerospikev1alpha2.AerospikeNamespaceSpec
  • func (tf *TestFramework) NewAerospikeNamespaceWithFileStorageV1alpha1(name string, replicationFactor int32, memorySizeGB int, defaultTTLSeconds int, ...) aerospikev1alpha1.AerospikeNamespaceSpec
  • func (tf *TestFramework) NewV1alpha1AerospikeClusterWithDefaults() aerospikev1alpha1.AerospikeCluster
  • func (tf *TestFramework) ScaleCluster(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, nodeCount int32) error
  • func (tf *TestFramework) UpgradeClusterAndWait(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, targetVersion string) (*aerospikev1alpha2.AerospikeCluster, error)
  • func (tf *TestFramework) WaitForBackupRestoreCompleted(obj aerospikev1alpha2.BackupRestoreObject) error
  • func (tf *TestFramework) WaitForBackupRestoreCondition(obj aerospikev1alpha2.BackupRestoreObject, fn watch.ConditionFunc, ...) (err error)
  • func (tf *TestFramework) WaitForClusterCondition(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, fn watch.ConditionFunc, ...) error
  • func (tf *TestFramework) WaitForClusterNodeCount(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, nodeCount int32) error
  • func (tf *TestFramework) WaitForClusterNodeCountOrTimeout(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, nodeCount int32, ...) error

Variables

var (
	GCSBucketName      string
	GCSSecretName      string
	GCSSecretNamespace string
	GCSSecretKey       string
)

Types

type AerospikeClient

type AerospikeClient struct {
	// contains filtered or unexported fields
}

func NewAerospikeClient

func NewAerospikeClient(aerospikeCluster *aerospikev1alpha2.AerospikeCluster) (*AerospikeClient, error)

func (*AerospikeClient) Close

func (ac *AerospikeClient) Close()

func (*AerospikeClient) GetNamespaceStorageEngine

func (ac *AerospikeClient) GetNamespaceStorageEngine(namespace string) (string, error)

func (*AerospikeClient) GetNodeNames

func (ac *AerospikeClient) GetNodeNames() []string

func (*AerospikeClient) IsConnected

func (ac *AerospikeClient) IsConnected() bool

func (*AerospikeClient) IsDataInMemoryEnabled

func (ac *AerospikeClient) IsDataInMemoryEnabled(namespace string) (bool, error)

func (*AerospikeClient) ReadSequentialIntegers

func (ac *AerospikeClient) ReadSequentialIntegers(asNamespace string, n int) error

func (*AerospikeClient) WriteSequentialIntegers

func (ac *AerospikeClient) WriteSequentialIntegers(asNamespace string, n int) error

type TestFramework

type TestFramework struct {
	AerospikeClient *aerospikeclientset.Clientset
	KubeClient      *kubernetes.Clientset
	RestConfig      *rest.Config
}

func NewTestFramework

func NewTestFramework(kubeconfigPath string) (*TestFramework, error)

func (*TestFramework) ChangeNamespaceMemorySizeAndScaleClusterAndWait

func (tf *TestFramework) ChangeNamespaceMemorySizeAndScaleClusterAndWait(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, newMemorySizeGB int, nodeCount int32) error

func (*TestFramework) CreateRandomNamespace

func (tf *TestFramework) CreateRandomNamespace() (*v1.Namespace, error)

func (*TestFramework) DeleteNamespace

func (tf *TestFramework) DeleteNamespace(ns *v1.Namespace) error

func (*TestFramework) ErrorCauses

func (tf *TestFramework) ErrorCauses(err error) []string

func (*TestFramework) ExecInContainer

func (tf *TestFramework) ExecInContainer(pod corev1.Pod, ns *corev1.Namespace, command []string, container string) error

func (*TestFramework) NewAerospikeCluster

func (tf *TestFramework) NewAerospikeCluster(version string, nodeCount int32, namespaces []aerospikev1alpha2.AerospikeNamespaceSpec) aerospikev1alpha2.AerospikeCluster

func (*TestFramework) NewAerospikeClusterV1alpha1

func (tf *TestFramework) NewAerospikeClusterV1alpha1(version string, nodeCount int32, namespaces []aerospikev1alpha1.AerospikeNamespaceSpec) aerospikev1alpha1.AerospikeCluster

func (*TestFramework) NewAerospikeClusterWithDefaults

func (tf *TestFramework) NewAerospikeClusterWithDefaults() aerospikev1alpha2.AerospikeCluster

func (*TestFramework) NewAerospikeNamespaceBackupGCS

func (tf *TestFramework) NewAerospikeNamespaceBackupGCS(cluster *aerospikev1alpha2.AerospikeCluster, namespace string, ttl *string) aerospikev1alpha2.AerospikeNamespaceBackup

func (*TestFramework) NewAerospikeNamespaceBackupGCSWithoutBackupStorageSpec

func (tf *TestFramework) NewAerospikeNamespaceBackupGCSWithoutBackupStorageSpec(cluster *aerospikev1alpha2.AerospikeCluster, namespace string, ttl *string) aerospikev1alpha2.AerospikeNamespaceBackup

func (*TestFramework) NewAerospikeNamespaceRestoreGCS

func (tf *TestFramework) NewAerospikeNamespaceRestoreGCS(cluster *aerospikev1alpha2.AerospikeCluster, namespace string, backup *aerospikev1alpha2.AerospikeNamespaceBackup) aerospikev1alpha2.AerospikeNamespaceRestore

func (*TestFramework) NewAerospikeNamespaceRestoreGCSWithoutBackupStorageSpec

func (tf *TestFramework) NewAerospikeNamespaceRestoreGCSWithoutBackupStorageSpec(cluster *aerospikev1alpha2.AerospikeCluster, namespace string, backup *aerospikev1alpha2.AerospikeNamespaceBackup) aerospikev1alpha2.AerospikeNamespaceRestore

func (*TestFramework) NewAerospikeNamespaceWithDeviceStorage

func (tf *TestFramework) NewAerospikeNamespaceWithDeviceStorage(name string, replicationFactor int32, memorySizeGB int, defaultTTLSeconds int, storageSizeGB int) aerospikev1alpha2.AerospikeNamespaceSpec

func (*TestFramework) NewAerospikeNamespaceWithFileStorage

func (tf *TestFramework) NewAerospikeNamespaceWithFileStorage(name string, replicationFactor int32, memorySizeGB int, defaultTTLSeconds int, storageSizeGB int) aerospikev1alpha2.AerospikeNamespaceSpec

func (*TestFramework) NewAerospikeNamespaceWithFileStorageV1alpha1

func (tf *TestFramework) NewAerospikeNamespaceWithFileStorageV1alpha1(name string, replicationFactor int32, memorySizeGB int, defaultTTLSeconds int, storageSizeGB int) aerospikev1alpha1.AerospikeNamespaceSpec

func (*TestFramework) NewV1alpha1AerospikeClusterWithDefaults

func (tf *TestFramework) NewV1alpha1AerospikeClusterWithDefaults() aerospikev1alpha1.AerospikeCluster

func (*TestFramework) ScaleCluster

func (tf *TestFramework) ScaleCluster(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, nodeCount int32) error

func (*TestFramework) UpgradeClusterAndWait

func (tf *TestFramework) UpgradeClusterAndWait(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, targetVersion string) (*aerospikev1alpha2.AerospikeCluster, error)

UpgradeClusterAndWait upgrades an Aerospike cluster to the specified targetVersion

func (*TestFramework) WaitForBackupRestoreCompleted

func (tf *TestFramework) WaitForBackupRestoreCompleted(obj aerospikev1alpha2.BackupRestoreObject) error

func (*TestFramework) WaitForBackupRestoreCondition

func (tf *TestFramework) WaitForBackupRestoreCondition(obj aerospikev1alpha2.BackupRestoreObject, fn watch.ConditionFunc, timeout time.Duration) (err error)

func (*TestFramework) WaitForClusterCondition

func (tf *TestFramework) WaitForClusterCondition(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, fn watch.ConditionFunc, timeout time.Duration) error

func (*TestFramework) WaitForClusterNodeCount

func (tf *TestFramework) WaitForClusterNodeCount(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, nodeCount int32) error

func (*TestFramework) WaitForClusterNodeCountOrTimeout

func (tf *TestFramework) WaitForClusterNodeCountOrTimeout(aerospikeCluster *aerospikev1alpha2.AerospikeCluster, nodeCount int32, timeout time.Duration) error