framework

package
v0.10.0-alpha.1 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2020 License: Apache-2.0 Imports: 62 Imported by: 0

Documentation

Overview

Copyright The Stash Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	ProberDemoPodPrefix = "prober-demo"
	ExitCodeSuccess     = "EXIT_CODE_SUCCESS"
	ExitCodeFail        = "EXIT_CODE_FAIL"
	HttpPortName        = "http-port"
	HttpPort            = 8080
	TcpPortName         = "tcp-port"
	TcpPort             = 9090
)
View Source 
const (
	MINIO_PUBLIC_CRT_NAME  = "public.crt"
	MINIO_PRIVATE_KEY_NAME = "private.key"

	MINIO_ACCESS_KEY_ID     = "not@id"
	MINIO_SECRET_ACCESS_KEY = "not@secret"

	MINIO_CERTS_MOUNTPATH = "/root/.minio/certs"
	StandardStorageClass  = "standard"

	MinioServer       = "minio-server"
	MinioServerSecret = "minio-server-secret"
	MinioPVCStorage   = "minio-pvc-storage"
	MinioService      = "minio-service"
	LocalHostIP       = "127.0.0.1"
)
View Source 
const (
	KeyUser       = "username"
	KeyPassword   = "password"
	SuperUser     = "root"
	PrefixSource  = "source"
	PrefixRestore = "restore"

	KeyMySQLRootPassword   = "MYSQL_ROOT_PASSWORD"
	MySQLServingPortName   = "mysql"
	MySQLContainerName     = "mysql"
	MySQLServingPortNumber = 3306
	MySQLBackupTask        = "mysql-backup-8.0.14"
	MySQLRestoreTask       = "mysql-restore-8.0.14"
	MySQLBackupFunction    = "mysql-backup-8.0.14"
	MySQLRestoreFunction   = "mysql-restore-8.0.14"
)
View Source 
const (
	NFSServer  = "nfs-server"
	NFSService = "nfs-service"
)
View Source 
const (
	TestSourceDataVolumeName = "source-data"
	TestSourceDataMountPath  = "/source/data"
	TestSafeDataMountPath    = "/safe/data"
	OperatorNamespace        = "kube-system"
)
View Source 
const (
	REST_PUBLIC_CRT_NAME      = "public.crt"
	REST_PRIVATE_KEY_NAME     = "private.key"
	TEST_REST_SERVER_USERNAME = "myuser"
	TEST_REST_SERVER_PASSWORD = "changeit"

	RestServer       = "rest-server"
	RestServerSecret = "rest-server-secret"
	RestPVCStorage   = "rest-pvc-storage"
	RestService      = "rest-service"
)
View Source 
const (
	DO_ACCESS_KEY_ID     = "DO_ACCESS_KEY_ID"
	DO_SECRET_ACCESS_KEY = "DO_SECRET_ACCESS_KEY"
)
View Source 
const (
	PullInterval             = time.Second * 2
	WaitTimeOut              = time.Minute * 10
	TaskPVCBackup            = "pvc-backup"
	TaskPVCRestore           = "pvc-restore"
	TestSourceDataTargetPath = "/source/data"
	TestSourceVolumeAndMount = SourceVolume + ":" + TestSourceDataMountPath
	WrongBackupBlueprintName = "backup-blueprint"
	WrongTargetPath          = "/source/data-1"

	SourceDeployment   = "source-dp"
	RestoredDeployment = "restored-dp"

	SourceStatefulSet   = "source-ss"
	RestoredStatefulSet = "restored-ss"

	SourceDaemonSet   = "source-dmn"
	RestoredDaemonSet = "restored-dmn"

	SourceReplicaSet   = "source-rs"
	RestoredReplicaSet = "restored-rs"

	SourceReplicationController   = "source-rc"
	RestoredReplicationController = "restored-rc"

	SourcePVC = "source-pvc"

	SourceVolume   = "source-volume"
	RestoredVolume = "restored-volume"

	WorkloadBackupBlueprint = "workload-backup-blueprint"
	PvcBackupBlueprint      = "pvc-backup-blueprint"

	TestFSGroup         = 2000
	TestResourceRequest = "200Mi"
	TestResourceLimit   = "300Mi"
	TestUserID          = 2000
)
View Source 
const (
	TEST_RESTIC_PASSWORD = "not@secret"
)

Variables

View Source 
var TestFailed = false

Functions

func GetTargetRef 

func GetTargetRef(name string, kind string) v1beta1.TargetRef

func HasFSGroup 

func HasFSGroup(sc *core.PodSecurityContext) bool

func HasResources 

func HasResources(containers []core.Container) bool

func HasSecurityContext 

func HasSecurityContext(containers []core.Container) bool

func WaitUntilRepositoryDeleted 

func WaitUntilRepositoryDeleted(sc cs.Interface, repository *api.Repository) error

Types

type Framework 

type Framework struct {
	KubeClient  kubernetes.Interface
	StashClient cs.Interface
	KAClient    ka.Interface

	CertStore      *certstore.CertStore
	ClientConfig   *rest.Config
	StorageClass   string
	DockerRegistry string
	// contains filtered or unexported fields
}
var RootFramework *Framework

RootFramework will be used to invoke new Invocation before each test from the individual test packages

func New 

func New(clientConfig *rest.Config, storageClass, registry string) *Framework

func (*Framework) BrowseBackendRepository 

func (f *Framework) BrowseBackendRepository(repository *api.Repository) ([]stow.Item, error)

func (*Framework) BrowseMinioRepository 

func (f *Framework) BrowseMinioRepository(repo *api.Repository) ([]stow.Item, error)

BrowseMinioRepository browse backend minio repository to check if there is any data in the backend. Minio server is running inside the cluster but the test is running outside of the cluster. So, we can't access the Minio server using the service created for it. Here, we are going to port-forward the Minio pod and and use the port-forwarded address to access the backend.

func (*Framework) CheckLeaderElection 

func (f *Framework) CheckLeaderElection(meta metav1.ObjectMeta, kind string, modifier string)

func (*Framework) CreateBackupBlueprint 

func (f *Framework) CreateBackupBlueprint(backupBlueprint *v1beta1.BackupBlueprint) (*v1beta1.BackupBlueprint, error)

func (*Framework) CreateDaemonSet 

func (f *Framework) CreateDaemonSet(obj apps.DaemonSet) (*apps.DaemonSet, error)

func (*Framework) CreateDeployment 

func (f *Framework) CreateDeployment(obj apps.Deployment) (*apps.Deployment, error)

func (*Framework) CreateDeploymentForMinioServer 

func (f *Framework) CreateDeploymentForMinioServer(obj apps.Deployment) error

func (*Framework) CreateMinioServer 

func (f *Framework) CreateMinioServer(tls bool, ips []net.IP) (string, error)

func (*Framework) CreateNamespace 

func (f *Framework) CreateNamespace(ns *core.Namespace) error

func (*Framework) CreatePersistentVolumeClaim 

func (f *Framework) CreatePersistentVolumeClaim(pvc *core.PersistentVolumeClaim) (*core.PersistentVolumeClaim, error)

func (*Framework) CreatePersistentVolumeClaimForMinioServer 

func (f *Framework) CreatePersistentVolumeClaimForMinioServer(obj core.PersistentVolumeClaim) error

func (*Framework) CreatePersistentVolumeClaimForRestServer 

func (f *Framework) CreatePersistentVolumeClaimForRestServer(obj core.PersistentVolumeClaim) (*core.PersistentVolumeClaim, error)

func (*Framework) CreateReplicaSet 

func (f *Framework) CreateReplicaSet(obj apps.ReplicaSet) (*apps.ReplicaSet, error)

func (*Framework) CreateReplicationController 

func (f *Framework) CreateReplicationController(obj core.ReplicationController) (*core.ReplicationController, error)

func (*Framework) CreateSampleDataInsideWorkload 

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

func (*Framework) CreateSecret 

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

func (*Framework) CreateService 

func (f *Framework) CreateService(obj core.Service) (*core.Service, error)

func (*Framework) CreateServiceForMinioServer 

func (f *Framework) CreateServiceForMinioServer(obj core.Service) (*core.Service, error)

func (*Framework) CreateStatefulSet 

func (f *Framework) CreateStatefulSet(obj apps.StatefulSet) (*apps.StatefulSet, error)

func (*Framework) CreateTestNamespace 

func (f *Framework) CreateTestNamespace() error

func (*Framework) DeleteDeploymentForMinioServer 

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

func (*Framework) DeleteMinioServer 

func (f *Framework) DeleteMinioServer() error

func (*Framework) DeleteNamespace 

func (f *Framework) DeleteNamespace(name string) error

func (*Framework) DeletePVCForMinioServer 

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

func (*Framework) DeleteRepository 

func (f *Framework) DeleteRepository(repository *api.Repository) error

func (*Framework) DeleteSecret 

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

func (*Framework) DeleteSecretForMinioServer 

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

func (*Framework) DeleteServiceForMinioServer 

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

func (*Framework) DeploymentForMinioServer 

func (f *Framework) DeploymentForMinioServer(pvc core.PersistentVolumeClaim, secret core.Secret) apps.Deployment

func (*Framework) EnsureMySQLAddon 

func (f *Framework) EnsureMySQLAddon() error

func (*Framework) EnsureMySQLAddonDeleted 

func (f *Framework) EnsureMySQLAddonDeleted() error

func (*Framework) EventuallyAllPodsAccessible 

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

func (*Framework) EventuallyAnnotationsFound 

func (f *Framework) EventuallyAnnotationsFound(expectedAnnotations map[string]string, obj interface{}) GomegaAsyncAssertion

func (*Framework) EventuallyBackupConfigurationCreated 

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

func (*Framework) EventuallyBackupProcessCompleted 

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

func (*Framework) EventuallyBackupSessionCreated 

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

func (*Framework) EventuallyBackupSessionPhase 

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

func (*Framework) EventuallyCondition 

func (f *Framework) EventuallyCondition(meta metav1.ObjectMeta, kind string, condType string) GomegaAsyncAssertion

func (*Framework) EventuallyCronJobCreated 

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

func (*Framework) EventuallyCronJobResumed 

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

func (*Framework) EventuallyCronJobSuspended 

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

func (*Framework) EventuallyDaemonSet 

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

func (*Framework) EventuallyDeployment 

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

func (*Framework) EventuallyEvent 

func (f *Framework) EventuallyEvent(meta metav1.ObjectMeta, involvedObjectKind string) GomegaAsyncAssertion

func (*Framework) EventuallyEventWritten 

func (f *Framework) EventuallyEventWritten(involvedObjectMeta metav1.ObjectMeta, involvedObjectKind, eventType, eventReason string) GomegaAsyncAssertion

func (*Framework) EventuallyPodAccessible 

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

func (*Framework) EventuallyReplicaSet 

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

func (*Framework) EventuallyReplicationController 

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

func (*Framework) EventuallyRepositoryCreated 

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

func (*Framework) EventuallyRestoreProcessCompleted 

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

func (*Framework) EventuallyStatefulSet 

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

func (*Framework) EventuallyTargetCondition 

func (f *Framework) EventuallyTargetCondition(meta metav1.ObjectMeta, target v1beta1.TargetRef, condType v1beta1.BackupInvokerCondition) GomegaAsyncAssertion

func (*Framework) ExecOnPod 

func (f *Framework) ExecOnPod(pod *core.Pod, command ...string) (string, error)

func (*Framework) GetAllPods 

func (f *Framework) GetAllPods(meta metav1.ObjectMeta) ([]core.Pod, error)

func (*Framework) GetBackupBlueprint 

func (f *Framework) GetBackupBlueprint(name string) (*v1beta1.BackupBlueprint, error)

func (*Framework) GetBackupJob 

func (f *Framework) GetBackupJob(backupSessionName string) (*batchv1.Job, error)

func (*Framework) GetBackupSession 

func (f *Framework) GetBackupSession(meta metav1.ObjectMeta) (*v1beta1.BackupSession, error)

func (*Framework) GetCronJob 

func (f *Framework) GetCronJob(meta metav1.ObjectMeta) (*batch_v1beta1.CronJob, error)

func (*Framework) GetLeaderIdentity 

func (f *Framework) GetLeaderIdentity(meta metav1.ObjectMeta, kind string, modifier string) (string, error)

func (*Framework) GetMinioPod 

func (f *Framework) GetMinioPod() (*core.Pod, error)

func (*Framework) GetMinioServiceName 

func (f *Framework) GetMinioServiceName() string

func (*Framework) GetNodeName 

func (f *Framework) GetNodeName(meta metav1.ObjectMeta) string

func (*Framework) GetOperatorPod 

func (f *Framework) GetOperatorPod() (*core.Pod, error)

func (*Framework) GetPod 

func (f *Framework) GetPod(meta metav1.ObjectMeta) (*core.Pod, error)

func (*Framework) GetRepositories 

func (f *Framework) GetRepositories(kmr KindMetaReplicas) []*api.Repository

func (*Framework) GetRestoreJob 

func (f *Framework) GetRestoreJob(restoreSessionName string) (*batchv1.Job, error)

func (*Framework) Invoke 

func (f *Framework) Invoke() *Invocation

func (*Framework) MinioServerSANs 

func (f *Framework) MinioServerSANs(ips []net.IP) cert.AltNames

func (*Framework) MinioServiceAddres 

func (f *Framework) MinioServiceAddres() string

func (*Framework) Namespace 

func (f *Framework) Namespace() string

func (*Framework) NewNamespace 

func (f *Framework) NewNamespace(name string) *core.Namespace

func (*Framework) PVCForMinioServer 

func (f *Framework) PVCForMinioServer() core.PersistentVolumeClaim

func (*Framework) PrintOperatorLog 

func (f *Framework) PrintOperatorLog()

func (*Framework) ReadSampleDataFromFromWorkload 

func (f *Framework) ReadSampleDataFromFromWorkload(meta metav1.ObjectMeta, resourceKind string) ([]string, error)

func (*Framework) RemoveSecretVolumeMount 

func (f *Framework) RemoveSecretVolumeMount(containers []core.Container, secret core.Secret) []core.Container

func (*Framework) SecretForMinioServer 

func (f *Framework) SecretForMinioServer(ips []net.IP) core.Secret

func (*Framework) ServiceForMinioServer 

func (f *Framework) ServiceForMinioServer() core.Service

type Invocation 

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

func NewInvocation 

func NewInvocation() *Invocation

func (*Invocation) AddAnnotations 

func (fi *Invocation) AddAnnotations(annotations map[string]string, obj interface{}) error

func (*Invocation) AddAutoBackupAnnotations 

func (fi *Invocation) AddAutoBackupAnnotations(annotations map[string]string, obj interface{}) error

func (*Invocation) App 

func (fi *Invocation) App() string

func (*Invocation) AppLabel 

func (fi *Invocation) AppLabel() string

func (*Invocation) AppendToCleanupList 

func (fi *Invocation) AppendToCleanupList(resources ...interface{})

func (*Invocation) BackupBatch 

func (fi *Invocation) BackupBatch(repoName string) *v1beta1.BackupBatch

func (*Invocation) BackupBlueprint 

func (fi *Invocation) BackupBlueprint(secretName string) *v1beta1.BackupBlueprint

func (*Invocation) CleanupSampleDataFromWorkload 

func (fi *Invocation) CleanupSampleDataFromWorkload(meta metav1.ObjectMeta, resourceKind string) error

func (*Invocation) CleanupTestResources 

func (fi *Invocation) CleanupTestResources() error

func (*Invocation) CleanupUndeletedPVCs 

func (fi *Invocation) CleanupUndeletedPVCs()

func (*Invocation) CreateAppBinding 

func (fi *Invocation) CreateAppBinding(appBinding *appCatalog.AppBinding) (*appCatalog.AppBinding, error)

func (Invocation) CreateBackendSecretForMinio 

func (fi Invocation) CreateBackendSecretForMinio() (*core.Secret, error)

func (Invocation) CreateBackendSecretForRest 

func (fi Invocation) CreateBackendSecretForRest() (*core.Secret, error)

func (Invocation) CreateBackupBlueprintForPVC 

func (fi Invocation) CreateBackupBlueprintForPVC(name string) (*v1beta1.BackupBlueprint, error)

func (Invocation) CreateBackupBlueprintForWorkload 

func (fi Invocation) CreateBackupBlueprintForWorkload(name string) (*v1beta1.BackupBlueprint, error)

func (*Invocation) CreateBackupConfigForWorkload 

func (fi *Invocation) CreateBackupConfigForWorkload(objMeta metav1.ObjectMeta, repo *api_v1alpha1.Repository, kind string, transformFuncs ...func(bc *v1beta1.BackupConfiguration)) (*v1beta1.BackupConfiguration, error)

func (*Invocation) CreateBackupConfiguration 

func (fi *Invocation) CreateBackupConfiguration(backupCfg v1beta1.BackupConfiguration) error

func (*Invocation) CreateDeploymentForNFSServer 

func (fi *Invocation) CreateDeploymentForNFSServer(obj apps.Deployment) (*apps.Deployment, error)

func (*Invocation) CreateDeploymentForRestServer 

func (fi *Invocation) CreateDeploymentForRestServer(obj apps.Deployment) (*apps.Deployment, error)

func (*Invocation) CreateMySQL 

func (fi *Invocation) CreateMySQL(dpl *apps.Deployment) error

func (*Invocation) CreateNFSServer 

func (fi *Invocation) CreateNFSServer() (string, error)

func (*Invocation) CreateNewPVC 

func (fi *Invocation) CreateNewPVC(name string) (*core.PersistentVolumeClaim, error)

func (*Invocation) CreatePod 

func (fi *Invocation) CreatePod(pod core.Pod) (*core.Pod, error)

func (*Invocation) CreateRestServer 

func (fi *Invocation) CreateRestServer(tls bool, ips []net.IP) (string, error)

func (*Invocation) CreateRestoreSession 

func (fi *Invocation) CreateRestoreSession(restoreSession *v1beta1.RestoreSession) error

func (*Invocation) CreateRestoreSessionForWorkload 

func (fi *Invocation) CreateRestoreSessionForWorkload(objMeta metav1.ObjectMeta, repoName, kind, volumeName string, transformFuncs ...func(restore *v1beta1.RestoreSession)) (*v1beta1.RestoreSession, error)

func (*Invocation) CreateServiceForNFSServer 

func (fi *Invocation) CreateServiceForNFSServer(obj core.Service) (*core.Service, error)

func (*Invocation) CreateServiceForRestServer 

func (fi *Invocation) CreateServiceForRestServer(obj core.Service) (*core.Service, error)

func (*Invocation) CreateTable 

func (fi *Invocation) CreateTable(db *sql.DB, tableName string) error

func (*Invocation) DaemonSet 

func (fi *Invocation) DaemonSet(name, volumeName string) apps.DaemonSet

func (*Invocation) DeleteBackupBlueprint 

func (fi *Invocation) DeleteBackupBlueprint(name string) error

func (*Invocation) DeleteBackupConfiguration 

func (fi *Invocation) DeleteBackupConfiguration(backupCfg v1beta1.BackupConfiguration) error

func (*Invocation) DeleteDeploymentForNFSServer 

func (fi *Invocation) DeleteDeploymentForNFSServer(objMeta metav1.ObjectMeta) error

func (*Invocation) DeleteNFSServer 

func (fi *Invocation) DeleteNFSServer() error

func (*Invocation) DeletePod 

func (fi *Invocation) DeletePod(meta metav1.ObjectMeta) error

func (Invocation) DeleteRestoreSession 

func (fi Invocation) DeleteRestoreSession(meta metav1.ObjectMeta) error

func (*Invocation) DeleteServiceForNFSServer 

func (fi *Invocation) DeleteServiceForNFSServer(objMeta metav1.ObjectMeta) error

func (*Invocation) DeployDaemonSet 

func (fi *Invocation) DeployDaemonSet(name string, volumeName string) (*apps.DaemonSet, error)

func (*Invocation) DeployDeployment 

func (fi *Invocation) DeployDeployment(name string, replica int32, volName string, transformFuncs ...func(dp *apps.Deployment)) (*apps.Deployment, error)

func (*Invocation) DeployMySQLDatabase 

func (fi *Invocation) DeployMySQLDatabase() (*apps.Deployment, *appCatalog.AppBinding, error)

func (*Invocation) DeployPod 

func (fi *Invocation) DeployPod(pvcName string) (*core.Pod, error)

func (*Invocation) DeployReplicaSet 

func (fi *Invocation) DeployReplicaSet(name string, replica int32, volName string) (*apps.ReplicaSet, error)

func (*Invocation) DeployReplicationController 

func (fi *Invocation) DeployReplicationController(name string, replica int32, volName string) (*core.ReplicationController, error)

func (*Invocation) DeployStatefulSet 

func (fi *Invocation) DeployStatefulSet(name string, replica int32, volName string, transformFuncs ...func(ss *apps.StatefulSet)) (*apps.StatefulSet, error)

func (*Invocation) DeployStatefulSetWithProbeClient 

func (fi *Invocation) DeployStatefulSetWithProbeClient(name string) (*apps.StatefulSet, error)

func (*Invocation) Deployment 

func (fi *Invocation) Deployment(name, pvcName, volName string) apps.Deployment

func (*Invocation) DeploymentForNFSServer 

func (fi *Invocation) DeploymentForNFSServer() apps.Deployment

func (*Invocation) DeploymentForRestServer 

func (fi *Invocation) DeploymentForRestServer() apps.Deployment

func (*Invocation) EventuallyBackupCount 

func (fi *Invocation) EventuallyBackupCount(invokerMeta metav1.ObjectMeta, invokerKind string) GomegaAsyncAssertion

func (*Invocation) EventuallyConnectWithMySQLServer 

func (fi *Invocation) EventuallyConnectWithMySQLServer(db *sql.DB) error

func (*Invocation) EventuallyRunningBackupCompleted 

func (fi *Invocation) EventuallyRunningBackupCompleted(invokerMeta metav1.ObjectMeta, invokerKind string) GomegaAsyncAssertion

func (*Invocation) GenerateBigSampleFile 

func (fi *Invocation) GenerateBigSampleFile(meta metav1.ObjectMeta, kind string) ([]string, error)

func (*Invocation) GenerateSampleData 

func (fi *Invocation) GenerateSampleData(objMeta metav1.ObjectMeta, kind string) ([]string, error)

func (*Invocation) GetBackupConfiguration 

func (fi *Invocation) GetBackupConfiguration(repoName string, transformFuncs ...func(bc *v1beta1.BackupConfiguration)) *v1beta1.BackupConfiguration

func (*Invocation) GetNFSService 

func (fi *Invocation) GetNFSService() string

func (*Invocation) GetRestoreSession 

func (fi *Invocation) GetRestoreSession(repoName string, transformFuncs ...func(restore *v1beta1.RestoreSession)) *v1beta1.RestoreSession

func (*Invocation) GetSuccessfulBackupSessionCount 

func (fi *Invocation) GetSuccessfulBackupSessionCount(invokerMeta metav1.ObjectMeta, invokerKind string) (int64, error)

func (*Invocation) HeadlessService 

func (fi *Invocation) HeadlessService(name string) core.Service

func (*Invocation) HookFailed 

func (fi *Invocation) HookFailed(involvedObjectKind string, involvedObjectMeta metav1.ObjectMeta, probeType string) (bool, error)

func (*Invocation) InsertRow 

func (fi *Invocation) InsertRow(db *sql.DB, tableName string, property string, value int) error

func (*Invocation) ListTables 

func (fi *Invocation) ListTables(db *sql.DB) (sets.String, error)

func (*Invocation) MySQLAddonInstalled 

func (fi *Invocation) MySQLAddonInstalled() bool

func (*Invocation) MySQLAppBinding 

func (fi *Invocation) MySQLAppBinding(cred *core.Secret, svc *core.Service, prefix string) *appCatalog.AppBinding

func (*Invocation) MySQLCredentials 

func (fi *Invocation) MySQLCredentials(prefix string) *core.Secret

func (*Invocation) MySQLDeployment 

func (fi *Invocation) MySQLDeployment(cred *core.Secret, pvc *core.PersistentVolumeClaim, prefix string) *apps.Deployment

func (*Invocation) MySQLPVC 

func (fi *Invocation) MySQLPVC(prefix string) *core.PersistentVolumeClaim

func (*Invocation) MySQLService 

func (fi *Invocation) MySQLService(prefix string) *core.Service

func (*Invocation) NewAzureRepository 

func (fi *Invocation) NewAzureRepository(secretName string, maxConnection int64) *api.Repository

func (*Invocation) NewB2Repository 

func (fi *Invocation) NewB2Repository(secretName string, maxConnection int64) *api.Repository

func (*Invocation) NewGCSRepository 

func (fi *Invocation) NewGCSRepository(secretName string, maxConnection int64) *api.Repository

func (*Invocation) NewLocalRepositoryInHostPath 

func (fi *Invocation) NewLocalRepositoryInHostPath(secretName string) *api.Repository

func (*Invocation) NewLocalRepositoryInNFSServer 

func (fi *Invocation) NewLocalRepositoryInNFSServer(secretName string) *api.Repository

func (*Invocation) NewLocalRepositoryWithPVC 

func (fi *Invocation) NewLocalRepositoryWithPVC(secretName string, pvcName string) *api.Repository

func (*Invocation) NewMinioRepository 

func (fi *Invocation) NewMinioRepository(secretName string) *api.Repository

func (*Invocation) NewRestRepository 

func (fi *Invocation) NewRestRepository(secretName string) *api.Repository

func (*Invocation) NewS3Repository 

func (fi *Invocation) NewS3Repository(secretName string) *api.Repository

func (*Invocation) NewSwiftRepository 

func (fi *Invocation) NewSwiftRepository(secretName string) *api.Repository

func (*Invocation) PVCForRestServer 

func (fi *Invocation) PVCForRestServer() core.PersistentVolumeClaim

func (*Invocation) PersistentVolumeClaim 

func (fi *Invocation) PersistentVolumeClaim(name string) *core.PersistentVolumeClaim

func (*Invocation) Pod 

func (fi *Invocation) Pod(pvcName string) core.Pod

func (*Invocation) PodTemplate 

func (fi *Invocation) PodTemplate(labels map[string]string, pvcName, volName string) core.PodTemplateSpec

func (*Invocation) PrepareMySQLResources 

func (fi *Invocation) PrepareMySQLResources(prefix string) (*core.Secret, *core.PersistentVolumeClaim, *core.Service, *apps.Deployment, error)

func (*Invocation) PrintDebugHelpers 

func (fi *Invocation) PrintDebugHelpers()

func (*Invocation) PrintDebugInfoOnFailure 

func (fi *Invocation) PrintDebugInfoOnFailure()

func (*Invocation) ReadProperty 

func (fi *Invocation) ReadProperty(db *sql.DB, tableName, property string) (int, error)

func (*Invocation) RemoveRestSecretVolume 

func (fi *Invocation) RemoveRestSecretVolume(volumes []core.Volume) []core.Volume

func (*Invocation) RemoveRestSecretVolumeMount 

func (fi *Invocation) RemoveRestSecretVolumeMount(containers []core.Container) []core.Container

func (*Invocation) ReplicaSet 

func (fi *Invocation) ReplicaSet(name, pvcName, volName string) apps.ReplicaSet

func (*Invocation) ReplicationController 

func (fi *Invocation) ReplicationController(name, pvcName, volName string) core.ReplicationController

func (*Invocation) RestServerSANs 

func (fi *Invocation) RestServerSANs(ips []net.IP) cert.AltNames

func (*Invocation) RestServiceAddres 

func (fi *Invocation) RestServiceAddres() string

func (*Invocation) RestoredData 

func (fi *Invocation) RestoredData(objMeta metav1.ObjectMeta, kind string) []string

func (*Invocation) SecretForAzureBackend 

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

func (*Invocation) SecretForB2Backend 

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

func (*Invocation) SecretForDOBackend 

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

func (*Invocation) SecretForGCSBackend 

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

func (*Invocation) SecretForLocalBackend 

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

func (*Invocation) SecretForMinioBackend 

func (fi *Invocation) SecretForMinioBackend(includeCacert bool) core.Secret

func (*Invocation) SecretForRegistry 

func (fi *Invocation) SecretForRegistry(dockerCfgJson []byte) core.Secret

func (*Invocation) SecretForRestBackend 

func (fi *Invocation) SecretForRestBackend(includeCacert bool) core.Secret

func (*Invocation) SecretForRestServer 

func (fi *Invocation) SecretForRestServer(ips []net.IP) core.Secret

func (*Invocation) SecretForS3Backend 

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

func (*Invocation) SecretForSwiftBackend 

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

func (*Invocation) ServiceForNFSServer 

func (fi *Invocation) ServiceForNFSServer() core.Service

func (*Invocation) ServiceForRestServer 

func (fi *Invocation) ServiceForRestServer() core.Service

func (*Invocation) SetupAzureRepository 

func (fi *Invocation) SetupAzureRepository(maxConnection int64, addRepoToCleanupList bool) (*api.Repository, error)

func (*Invocation) SetupB2Repository 

func (fi *Invocation) SetupB2Repository(maxConnection int64) (*api.Repository, error)

func (*Invocation) SetupBatchBackup 

func (fi *Invocation) SetupBatchBackup(repo *api.Repository, transformFuncs ...func(in *v1beta1.BackupBatch)) (*v1beta1.BackupBatch, error)

func (*Invocation) SetupDatabaseBackup 

func (fi *Invocation) SetupDatabaseBackup(appBinding *appCatalog.AppBinding, repo *v1alpha1.Repository, transformFuncs ...func(bc *v1beta1.BackupConfiguration)) (*v1beta1.BackupConfiguration, error)

func (*Invocation) SetupDatabaseRestore 

func (fi *Invocation) SetupDatabaseRestore(appBinding *appCatalog.AppBinding, repo *v1alpha1.Repository, transformFuncs ...func(restore *v1beta1.RestoreSession)) (*v1beta1.RestoreSession, error)

func (*Invocation) SetupGCSRepository 

func (fi *Invocation) SetupGCSRepository(maxConnection int64, appendRepoToCleanupList bool) (*api.Repository, error)

func (*Invocation) SetupLocalRepositoryWithHostPath 

func (fi *Invocation) SetupLocalRepositoryWithHostPath() (*api.Repository, error)

func (*Invocation) SetupLocalRepositoryWithNFSServer 

func (fi *Invocation) SetupLocalRepositoryWithNFSServer() (*api.Repository, error)

func (*Invocation) SetupLocalRepositoryWithPVC 

func (fi *Invocation) SetupLocalRepositoryWithPVC() (*api.Repository, error)

func (*Invocation) SetupMinioRepository 

func (fi *Invocation) SetupMinioRepository() (*api.Repository, error)

func (*Invocation) SetupPVCBackup 

func (fi *Invocation) SetupPVCBackup(pvc *core.PersistentVolumeClaim, repo *v1alpha1.Repository, transformFuncs ...func(bc *v1beta1.BackupConfiguration)) (*v1beta1.BackupConfiguration, error)

func (*Invocation) SetupRestRepository 

func (fi *Invocation) SetupRestRepository(tls bool) (*api.Repository, error)

func (*Invocation) SetupRestoreProcess 

func (fi *Invocation) SetupRestoreProcess(objMeta metav1.ObjectMeta, repo *api.Repository, kind, volumeName string, transformFuncs ...func(restore *v1beta1.RestoreSession)) (*v1beta1.RestoreSession, error)

func (*Invocation) SetupRestoreProcessForPVC 

func (fi *Invocation) SetupRestoreProcessForPVC(pvc *core.PersistentVolumeClaim, repo *v1alpha1.Repository, transformFuncs ...func(restore *v1beta1.RestoreSession)) (*v1beta1.RestoreSession, error)

func (*Invocation) SetupS3Repository 

func (fi *Invocation) SetupS3Repository(appendToCleanupList bool) (*api.Repository, error)

func (*Invocation) SetupSwiftRepository 

func (fi *Invocation) SetupSwiftRepository(appendRepoToCleanupList bool) (*api.Repository, error)

func (*Invocation) SetupWorkloadBackup 

func (fi *Invocation) SetupWorkloadBackup(objMeta metav1.ObjectMeta, repo *api_v1alpha1.Repository, kind string, transformFuncs ...func(bc *v1beta1.BackupConfiguration)) (*v1beta1.BackupConfiguration, error)

func (*Invocation) StatefulSet 

func (fi *Invocation) StatefulSet(name, volName string, replica int32) apps.StatefulSet

func (*Invocation) TakeInstantBackup 

func (fi *Invocation) TakeInstantBackup(objMeta metav1.ObjectMeta, invokerRef v1beta1.BackupInvokerRef) (*v1beta1.BackupSession, error)

func (*Invocation) TriggerInstantBackup 

func (fi *Invocation) TriggerInstantBackup(objMeta metav1.ObjectMeta, invokerRef v1beta1.BackupInvokerRef) (*v1beta1.BackupSession, error)

func (*Invocation) UpdateProperty 

func (fi *Invocation) UpdateProperty(db *sql.DB, tableName, property string, newValue int) error

func (*Invocation) VerifyAutoBackupConfigured 

func (fi *Invocation) VerifyAutoBackupConfigured(workloadMeta metav1.ObjectMeta, kind string) (*v1beta1.BackupConfiguration, error)

func (*Invocation) WaitUntilDaemonSetReadyWithSidecar 

func (fi *Invocation) WaitUntilDaemonSetReadyWithSidecar(meta metav1.ObjectMeta) error

func (*Invocation) WaitUntilDeploymentReadyWithSidecar 

func (fi *Invocation) WaitUntilDeploymentReadyWithSidecar(meta metav1.ObjectMeta) error

func (*Invocation) WaitUntilRCReadyWithSidecar 

func (fi *Invocation) WaitUntilRCReadyWithSidecar(meta metav1.ObjectMeta) error

func (*Invocation) WaitUntilRSReadyWithSidecar 

func (fi *Invocation) WaitUntilRSReadyWithSidecar(meta metav1.ObjectMeta) error

func (*Invocation) WaitUntilStatefulSetReadyWithSidecar 

func (fi *Invocation) WaitUntilStatefulSetReadyWithSidecar(meta metav1.ObjectMeta) error

type KindMetaReplicas 

type KindMetaReplicas struct {
	Kind     string
	Meta     metav1.ObjectMeta
	Replicas int
}

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.