framework

package
v0.0.0-...-6f6c25d Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2019 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

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"
)
View Source 
const (
	TestSourceDataVolumeName = "source-data"
	TestSourceDataMountPath  = "/source/data"
	OperatorNamespace        = "kube-system"
	OperatorName             = "stash-operator"
)
View Source 
const (
	DO_ACCESS_KEY_ID     = "DO_ACCESS_KEY_ID"
	DO_SECRET_ACCESS_KEY = "DO_SECRET_ACCESS_KEY"
)
View Source 
const (
	TestSoucreDemoDataPath = "/data/stash-test/demo-data"
	TestSourceDataDir1     = "/source/data/dir-1"
	TestSourceDataDir2     = "/source/data/dir-2"
	KindRestic             = "Restic"
	KindRepository         = "Repository"
	KindRecovery           = "Recovery"
	PullInterval           = time.Second * 2
	WaitTimeOut            = time.Minute * 3
)
View Source 
const (
	TEST_HEADLESS_SERVICE = "headless"
)
View Source 
const (
	TEST_RESTIC_PASSWORD = "not@secret"
)
View Source 
const (
	TestRecoveredVolumePath = "/data/stash-test/restic-restored"
)

Variables

This section is empty.

Functions

func CleanupMinikubeHostPath 

func CleanupMinikubeHostPath() error

func FileGroupsForHostPathVolumeWithMultipleDirectory 

func FileGroupsForHostPathVolumeWithMultipleDirectory() []api.FileGroup

func GetPathsFromResticFileGroups 

func GetPathsFromResticFileGroups(restic *api.Restic) []string

func WaitUntilDaemonSetDeleted 

func WaitUntilDaemonSetDeleted(kc kubernetes.Interface, meta metav1.ObjectMeta) error

func WaitUntilDeploymentDeleted 

func WaitUntilDeploymentDeleted(kc kubernetes.Interface, meta metav1.ObjectMeta) error

func WaitUntilNamespaceDeleted 

func WaitUntilNamespaceDeleted(kc kubernetes.Interface, meta metav1.ObjectMeta) error

func WaitUntilRecoveryDeleted 

func WaitUntilRecoveryDeleted(sc cs.Interface, meta metav1.ObjectMeta) error

func WaitUntilReplicaSetDeleted 

func WaitUntilReplicaSetDeleted(kc kubernetes.Interface, meta metav1.ObjectMeta) error

func WaitUntilReplicationControllerDeleted 

func WaitUntilReplicationControllerDeleted(kc kubernetes.Interface, meta metav1.ObjectMeta) error

func WaitUntilRepositoriesDeleted 

func WaitUntilRepositoriesDeleted(sc cs.Interface, repositories []*api.Repository) error

func WaitUntilResticDeleted 

func WaitUntilResticDeleted(sc cs.Interface, meta metav1.ObjectMeta) error

func WaitUntilSecretDeleted 

func WaitUntilSecretDeleted(kc kubernetes.Interface, meta metav1.ObjectMeta) error

func WaitUntilServiceDeleted 

func WaitUntilServiceDeleted(kc kubernetes.Interface, meta metav1.ObjectMeta) error

func WaitUntilStatefulSetDeleted 

func WaitUntilStatefulSetDeleted(kc kubernetes.Interface, meta metav1.ObjectMeta) error

Types

type Framework 

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

	CertStore          *certstore.CertStore
	WebhookEnabled     bool
	SelfHostedOperator bool
	ClientConfig       *rest.Config
	// contains filtered or unexported fields
}

func New 

func New(kubeClient kubernetes.Interface, extClient cs.Interface, kaClient ka.Interface, webhookEnabled bool, selfHostedOperator bool, clientConfig *rest.Config) *Framework

func (*Framework) BackupCountInRepositoriesStatus 

func (f *Framework) BackupCountInRepositoriesStatus(repos []*api.Repository) int64

func (*Framework) BrowseResticRepository 

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

func (*Framework) CheckLeaderElection 

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

func (*Framework) CountFailedSetup 

func (f *Framework) CountFailedSetup(events []core.Event) int

func (*Framework) CountSuccessfulBackups 

func (f *Framework) CountSuccessfulBackups(events []core.Event) int

func (*Framework) CreateDaemonSet 

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

func (*Framework) CreateDataOnMountedDir 

func (f *Framework) CreateDataOnMountedDir(meta metav1.ObjectMeta, paths []string, fileName string) error

func (*Framework) CreateDemoData 

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

func (*Framework) CreateDeployment 

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

func (*Framework) CreateDirectory 

func (f *Framework) CreateDirectory(meta metav1.ObjectMeta, directories []string) error

func (*Framework) CreateNamespace 

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

func (*Framework) CreateOrPatchRepository 

func (f *Framework) CreateOrPatchRepository(meta metav1.ObjectMeta, transformer func(repository *api.Repository) *api.Repository) error

func (*Framework) CreateOrPatchRestic 

func (f *Framework) CreateOrPatchRestic(meta metav1.ObjectMeta, transformer func(*api.Restic) *api.Restic) error

func (*Framework) CreateRecovery 

func (f *Framework) CreateRecovery(obj api.Recovery) 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) CreateRestic 

func (f *Framework) CreateRestic(obj api.Restic) error

func (*Framework) CreateSecret 

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

func (*Framework) CreateService 

func (f *Framework) CreateService(obj 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) DaemonSetRepos 

func (f *Framework) DaemonSetRepos(daemon *apps.DaemonSet) []*api.Repository

func (*Framework) DeleteDaemonSet 

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

func (*Framework) DeleteDeployment 

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

func (*Framework) DeleteDeploymentForMinioServer 

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

func (*Framework) DeleteJobAndDependents 

func (f *Framework) DeleteJobAndDependents(jobName string, recovery *api.Recovery)

func (*Framework) DeleteNamespace 

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

func (*Framework) DeletePVCForMinioServer 

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

func (*Framework) DeleteRecovery 

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

func (*Framework) DeleteReplicaSet 

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

func (*Framework) DeleteReplicationController 

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

func (*Framework) DeleteRepositories 

func (f *Framework) DeleteRepositories(repositories []*api.Repository)

func (*Framework) DeleteRestic 

func (f *Framework) DeleteRestic(meta metav1.ObjectMeta) 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) DeleteService 

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

func (*Framework) DeleteServiceForMinioServer 

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

func (*Framework) DeleteStatefulSet 

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

func (*Framework) DeploymentRepos 

func (f *Framework) DeploymentRepos(deployment *apps.Deployment) []*api.Repository

func (*Framework) EventualEvent 

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

func (*Framework) EventualWarning 

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

func (*Framework) EventuallyAPIServerReady 

func (f *Framework) EventuallyAPIServerReady() 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) EventuallyJobSucceed 

func (f *Framework) EventuallyJobSucceed(name string) GomegaAsyncAssertion

func (*Framework) EventuallyRecoveredData 

func (f *Framework) EventuallyRecoveredData(meta metav1.ObjectMeta, paths []string) GomegaAsyncAssertion

func (*Framework) EventuallyRecoverySucceed 

func (f *Framework) EventuallyRecoverySucceed(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) EventuallyRepository 

func (f *Framework) EventuallyRepository(workload interface{}) GomegaAsyncAssertion

func (*Framework) EventuallyRestic 

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

func (*Framework) EventuallyStatefulSet 

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

func (*Framework) ExecOnPod 

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

func (*Framework) GetLeaderIdentity 

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

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) Invoke 

func (f *Framework) Invoke() *Invocation

func (*Framework) LatestSnapshot 

func (f *Framework) LatestSnapshot(snapshots []rep.Snapshot) rep.Snapshot

func (*Framework) Namespace 

func (f *Framework) Namespace() string

func (*Framework) NewNamespace 

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

func (*Framework) NewTestStashOptions 

func (f *Framework) NewTestStashOptions(kubeConfigPath string, controllerOptions *srvr.ExtraOptions) *srvr.StashOptions

func (*Framework) ReadDataFromMountedDir 

func (f *Framework) ReadDataFromMountedDir(meta metav1.ObjectMeta, paths []string) ([]string, error)

func (*Framework) ReplicaSetRepos 

func (f *Framework) ReplicaSetRepos(rs *apps.ReplicaSet) []*api.Repository

func (*Framework) ReplicationControllerRepos 

func (f *Framework) ReplicationControllerRepos(rc *core.ReplicationController) []*api.Repository

func (*Framework) StartAPIServerAndOperator 

func (f *Framework) StartAPIServerAndOperator(kubeConfigPath string, extraOptions *srvr.ExtraOptions)

func (*Framework) StatefulSetRepos 

func (f *Framework) StatefulSetRepos(ss *apps.StatefulSet) []*api.Repository

func (*Framework) UpdateRestic 

func (f *Framework) UpdateRestic(meta metav1.ObjectMeta, transformer func(*api.Restic) *api.Restic) error

func (*Framework) WaitUntilDaemonPodReady 

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

type Invocation 

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

func (*Invocation) App 

func (f *Invocation) App() string

func (*Invocation) AppLabel 

func (f *Invocation) AppLabel() string

func (*Invocation) CleanupRecoveredVolume 

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

func (*Invocation) CreateDeploymentForMinioServer 

func (fi *Invocation) CreateDeploymentForMinioServer(obj apps.Deployment) error

func (*Invocation) CreateMinioServer 

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

func (*Invocation) CreatePersistentVolumeClaim 

func (fi *Invocation) CreatePersistentVolumeClaim(obj core.PersistentVolumeClaim) error

func (*Invocation) CreateServiceForMinioServer 

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

func (*Invocation) DaemonSet 

func (fi *Invocation) DaemonSet() apps.DaemonSet

func (*Invocation) DeleteMinioServer 

func (fi *Invocation) DeleteMinioServer()

func (*Invocation) Deployment 

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

func (*Invocation) DeploymentForMinioServer 

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

func (*Invocation) HeadlessService 

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

func (*Invocation) HostPathVolumeWithMultipleDirectory 

func (f *Invocation) HostPathVolumeWithMultipleDirectory() []core.Volume

func (*Invocation) MinioServerSANs 

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

func (*Invocation) MinioServiceAddres 

func (fi *Invocation) MinioServiceAddres() string

func (*Invocation) PVCForMinioServer 

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

func (*Invocation) PodTemplate 

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

func (*Invocation) RecoveredVolume 

func (f *Invocation) RecoveredVolume() []core.Volume

func (*Invocation) RecoveryForRestic 

func (fi *Invocation) RecoveryForRestic(restic api.Restic) api.Recovery

func (*Invocation) RemoveSecretVolumeMount 

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

func (*Invocation) ReplicaSet 

func (fi *Invocation) ReplicaSet() apps.ReplicaSet

func (*Invocation) ReplicationController 

func (fi *Invocation) ReplicationController() core.ReplicationController

func (*Invocation) ResticForAzureBackend 

func (fi *Invocation) ResticForAzureBackend() api.Restic

func (*Invocation) ResticForB2Backend 

func (fi *Invocation) ResticForB2Backend() api.Restic

func (*Invocation) ResticForDOBackend 

func (fi *Invocation) ResticForDOBackend() api.Restic

func (*Invocation) ResticForGCSBackend 

func (fi *Invocation) ResticForGCSBackend() api.Restic

func (*Invocation) ResticForHostPathLocalBackend 

func (fi *Invocation) ResticForHostPathLocalBackend() api.Restic

func (*Invocation) ResticForLocalBackend 

func (fi *Invocation) ResticForLocalBackend() api.Restic

func (*Invocation) ResticForMinioBackend 

func (fi *Invocation) ResticForMinioBackend(address string) api.Restic

func (*Invocation) ResticForS3Backend 

func (fi *Invocation) ResticForS3Backend() api.Restic

func (*Invocation) ResticForSwiftBackend 

func (fi *Invocation) ResticForSwiftBackend() api.Restic

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) SecretForMinioServer 

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

func (*Invocation) SecretForRegistry 

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

func (*Invocation) SecretForS3Backend 

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

func (*Invocation) SecretForSwiftBackend 

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

func (*Invocation) ServiceForMinioServer 

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

func (*Invocation) StatefulSet 

func (fi *Invocation) StatefulSet() apps.StatefulSet

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.