framework

package
v0.5.0-rc.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 22, 2019 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EtcdTestKey   = "testKey"
	EtcdTestValue = "testValue"
)
View Source 
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

View Source 
var (
	DockerRegistry     string
	ExporterTag        string
	DBVersion          string
	SelfHostedOperator bool
)

Functions

This section is empty.

Types

type Framework 

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

func New 

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

func (*Framework) CleanAdmissionConfigs 

func (f *Framework) CleanAdmissionConfigs()

func (*Framework) CleanDormantDatabase 

func (f *Framework) CleanDormantDatabase()

func (*Framework) CleanEtcd 

func (f *Framework) CleanEtcd()

func (*Framework) CleanSnapshot 

func (f *Framework) CleanSnapshot()

func (*Framework) CreateEtcd 

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

func (*Framework) CreateEtcdVersion 

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

func (*Framework) CreateNamespace 

func (f *Framework) CreateNamespace() error

func (*Framework) CreateSecret 

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

func (*Framework) CreateSnapshot 

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

func (*Framework) DeleteDormantDatabase 

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

func (*Framework) DeleteEtcd 

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

func (*Framework) DeleteEtcdVersion 

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

func (*Framework) DeleteNamespace 

func (f *Framework) DeleteNamespace() error

func (*Framework) DeleteSecret 

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

func (*Framework) DeleteSnapshot 

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

func (*Framework) EventuallyAPIServiceReady 

func (f *Framework) EventuallyAPIServiceReady() GomegaAsyncAssertion

func (*Framework) EventuallyCRD 

func (f *Framework) EventuallyCRD() GomegaAsyncAssertion

func (*Framework) EventuallyDatabaseReady 

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

func (*Framework) EventuallyDormantDatabase 

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

func (*Framework) EventuallyDormantDatabaseStatus 

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

func (*Framework) EventuallyEtcd 

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

func (*Framework) EventuallyEtcdRunning 

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

func (*Framework) EventuallyKeyExists 

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

func (*Framework) EventuallyMultipleSnapshotFinishedProcessing 

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

func (*Framework) EventuallySetKey 

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

func (*Framework) EventuallySnapshot 

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

func (*Framework) EventuallySnapshotCount 

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

func (*Framework) EventuallySnapshotDataFound 

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

func (*Framework) EventuallySnapshotPhase 

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

func (*Framework) EventuallyWipedOut 

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

func (*Framework) ForwardPort 

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

func (*Framework) GetDormantDatabase 

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

func (*Framework) GetEtcd 

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

func (*Framework) GetEtcdClient 

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

func (*Framework) GetEtcdClientPod 

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

func (*Framework) GetEtcdRootPassword 

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

func (*Framework) GetSnapshot 

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

func (*Framework) Invoke 

func (f *Framework) Invoke() *Invocation

func (*Framework) Namespace 

func (f *Framework) Namespace() string

func (*Framework) PatchDormantDatabase 

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

func (*Framework) PatchEtcd 

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

func (*Framework) RunOperatorAndServer 

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

func (*Framework) UpdateSecret 

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

type Invocation 

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

func (*Invocation) CreatePersistentVolumeClaim 

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

func (*Invocation) DeletePersistentVolumeClaim 

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

func (*Invocation) Etcd 

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

func (*Invocation) EtcdPVCSpec 

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

func (*Invocation) EtcdVersion 

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

func (*Invocation) GCSBackupScheduleSpec 

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

func (*Invocation) GetPersistentVolumeClaim 

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

func (*Invocation) LocalBackupScheduleSpec 

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

func (*Invocation) LocalStorageSpec 

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

func (*Invocation) SecretForAzureBackend 

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

func (*Invocation) SecretForGCSBackend 

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

func (*Invocation) SecretForLocalBackend 

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

func (*Invocation) SecretForS3Backend 

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

func (*Invocation) SecretForSwiftBackend 

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

func (*Invocation) Snapshot 

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

type KubedbTable 

type KubedbTable struct {
	Key   string
	Value string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.