etcd: kubedb.dev/etcd/test/e2e/framework Index | Files

package framework

import "kubedb.dev/etcd/test/e2e/framework"

Index

Package Files

admission_controller.go crd.go database.go dormantdatabase.go etcd.go etcd_version.go framework.go namespace.go secret.go snapshot.go util.go

Constants

const (
    EtcdTestKey   = "testKey"
    EtcdTestValue = "testValue"
)
const (
    S3_BUCKET_NAME       = "S3_BUCKET_NAME"
    GCS_BUCKET_NAME      = "GCS_BUCKET_NAME"
    AZURE_CONTAINER_NAME = "AZURE_CONTAINER_NAME"
    SWIFT_CONTAINER_NAME = "SWIFT_CONTAINER_NAME"
)

Variables

var (
    DockerRegistry     string
    ExporterTag        string
    DBVersion          string
    SelfHostedOperator bool
)

type Framework Uses

type Framework struct {
    StorageClass string
    // contains filtered or unexported fields
}

func New Uses

func New(
    restConfig *rest.Config,
    kubeClient kubernetes.Interface,
    extClient cs.Interface,
    kaClient ka.Interface,
    storageClass string,
) *Framework

func (*Framework) CleanAdmissionConfigs Uses

func (f *Framework) CleanAdmissionConfigs()

func (*Framework) CleanDormantDatabase Uses

func (f *Framework) CleanDormantDatabase()

func (*Framework) CleanEtcd Uses

func (f *Framework) CleanEtcd()

func (*Framework) CleanSnapshot Uses

func (f *Framework) CleanSnapshot()

func (*Framework) CreateEtcd Uses

func (f *Framework) CreateEtcd(obj *api.Etcd) error

func (*Framework) CreateEtcdVersion Uses

func (f *Framework) CreateEtcdVersion(obj *api.EtcdVersion) error

func (*Framework) CreateNamespace Uses

func (f *Framework) CreateNamespace() error

func (*Framework) CreateSecret Uses

func (f *Framework) CreateSecret(obj *core.Secret) error

func (*Framework) CreateSnapshot Uses

func (f *Framework) CreateSnapshot(obj *api.Snapshot) error

func (*Framework) DeleteDormantDatabase Uses

func (f *Framework) DeleteDormantDatabase(meta metav1.ObjectMeta) error

func (*Framework) DeleteEtcd Uses

func (f *Framework) DeleteEtcd(meta metav1.ObjectMeta) error

func (*Framework) DeleteEtcdVersion Uses

func (f *Framework) DeleteEtcdVersion(meta metav1.ObjectMeta) error

func (*Framework) DeleteNamespace Uses

func (f *Framework) DeleteNamespace() error

func (*Framework) DeleteSecret Uses

func (f *Framework) DeleteSecret(meta metav1.ObjectMeta) error

func (*Framework) DeleteSnapshot Uses

func (f *Framework) DeleteSnapshot(meta metav1.ObjectMeta) error

func (*Framework) EventuallyAPIServiceReady Uses

func (f *Framework) EventuallyAPIServiceReady() GomegaAsyncAssertion

func (*Framework) EventuallyCRD Uses

func (f *Framework) EventuallyCRD() GomegaAsyncAssertion

func (*Framework) EventuallyDatabaseReady Uses

func (f *Framework) EventuallyDatabaseReady(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyDormantDatabase Uses

func (f *Framework) EventuallyDormantDatabase(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyDormantDatabaseStatus Uses

func (f *Framework) EventuallyDormantDatabaseStatus(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyEtcd Uses

func (f *Framework) EventuallyEtcd(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyEtcdRunning Uses

func (f *Framework) EventuallyEtcdRunning(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyKeyExists Uses

func (f *Framework) EventuallyKeyExists(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyMultipleSnapshotFinishedProcessing Uses

func (f *Framework) EventuallyMultipleSnapshotFinishedProcessing(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallySetKey Uses

func (f *Framework) EventuallySetKey(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallySnapshot Uses

func (f *Framework) EventuallySnapshot(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallySnapshotCount Uses

func (f *Framework) EventuallySnapshotCount(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallySnapshotDataFound Uses

func (f *Framework) EventuallySnapshotDataFound(snapshot *api.Snapshot) GomegaAsyncAssertion

func (*Framework) EventuallySnapshotPhase Uses

func (f *Framework) EventuallySnapshotPhase(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyWipedOut Uses

func (f *Framework) EventuallyWipedOut(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) ForwardPort Uses

func (f *Framework) ForwardPort(meta metav1.ObjectMeta) (*portforward.Tunnel, error)

func (*Framework) GetDormantDatabase Uses

func (f *Framework) GetDormantDatabase(meta metav1.ObjectMeta) (*api.DormantDatabase, error)

func (*Framework) GetEtcd Uses

func (f *Framework) GetEtcd(meta metav1.ObjectMeta) (*api.Etcd, error)

func (*Framework) GetEtcdClient Uses

func (f *Framework) GetEtcdClient(tunnel *portforward.Tunnel) (goetcd.Client, error)

func (*Framework) GetEtcdClientPod Uses

func (f *Framework) GetEtcdClientPod(meta metav1.ObjectMeta) (string, error)

func (*Framework) GetEtcdRootPassword Uses

func (f *Framework) GetEtcdRootPassword(etcd *api.Etcd) (string, error)

func (*Framework) GetSnapshot Uses

func (f *Framework) GetSnapshot(meta metav1.ObjectMeta) (*api.Snapshot, error)

func (*Framework) Invoke Uses

func (f *Framework) Invoke() *Invocation

func (*Framework) Namespace Uses

func (f *Framework) Namespace() string

func (*Framework) PatchDormantDatabase Uses

func (f *Framework) PatchDormantDatabase(meta metav1.ObjectMeta, transform func(*api.DormantDatabase) *api.DormantDatabase) (*api.DormantDatabase, error)

func (*Framework) PatchEtcd Uses

func (f *Framework) PatchEtcd(meta metav1.ObjectMeta, transform func(*api.Etcd) *api.Etcd) (*api.Etcd, error)

func (*Framework) RunOperatorAndServer Uses

func (f *Framework) RunOperatorAndServer(config *restclient.Config, kubeconfigPath string, stopCh <-chan struct{})

func (*Framework) UpdateSecret Uses

func (f *Framework) UpdateSecret(meta metav1.ObjectMeta, transformer func(core.Secret) core.Secret) error

type Invocation Uses

type Invocation struct {
    *Framework
    // contains filtered or unexported fields
}

func (*Invocation) CreatePersistentVolumeClaim Uses

func (f *Invocation) CreatePersistentVolumeClaim(pvc *core.PersistentVolumeClaim) error

func (*Invocation) DeletePersistentVolumeClaim Uses

func (f *Invocation) DeletePersistentVolumeClaim(meta metav1.ObjectMeta) error

func (*Invocation) Etcd Uses

func (f *Invocation) Etcd() *api.Etcd

func (*Invocation) EtcdPVCSpec Uses

func (f *Invocation) EtcdPVCSpec() *core.PersistentVolumeClaimSpec

func (*Invocation) EtcdVersion Uses

func (i *Invocation) EtcdVersion() *api.EtcdVersion

func (*Invocation) GCSBackupScheduleSpec Uses

func (f *Invocation) GCSBackupScheduleSpec(secretName string) *api.BackupScheduleSpec

func (*Invocation) GetPersistentVolumeClaim Uses

func (f *Invocation) GetPersistentVolumeClaim() *core.PersistentVolumeClaim

func (*Invocation) LocalBackupScheduleSpec Uses

func (f *Invocation) LocalBackupScheduleSpec(secretName string) *api.BackupScheduleSpec

func (*Invocation) LocalStorageSpec Uses

func (f *Invocation) LocalStorageSpec() *store.LocalSpec

func (*Invocation) SecretForAzureBackend Uses

func (fi *Invocation) SecretForAzureBackend() *core.Secret

func (*Invocation) SecretForGCSBackend Uses

func (fi *Invocation) SecretForGCSBackend() *core.Secret

func (*Invocation) SecretForLocalBackend Uses

func (fi *Invocation) SecretForLocalBackend() *core.Secret

func (*Invocation) SecretForS3Backend Uses

func (fi *Invocation) SecretForS3Backend() *core.Secret

func (*Invocation) SecretForSwiftBackend Uses

func (fi *Invocation) SecretForSwiftBackend() *core.Secret

func (*Invocation) Snapshot Uses

func (f *Invocation) Snapshot() *api.Snapshot

type KubedbTable Uses

type KubedbTable struct {
    Key   string
    Value string
}

Package framework imports 39 packages (graph). Updated 2019-07-24. Refresh now. Tools for package owners.