framework

package
v0.9.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2019 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RepoSecretMountPath = "/etc/repository/secret"

	PVCBackupTaskName    = "pvc-backup-task"
	PVCRestoreTaskName   = "pvc-restore-task"
	FunctionPvcBackup    = "pvc-backup"
	FunctionPvcRestore   = "pvc-restore"
	FunctionUpdateStatus = "update-status"
)
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"
	TestSafeDataMountPath    = "/safe/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

View Source 
var (
	DockerRegistry string
	DockerImageTag string
)
View Source 
var (
	StashProjectRoot string
)

Functions

func CleanupMinikubeHostPath 

func CleanupMinikubeHostPath() error

func FileGroupsForHostPathVolumeWithMultipleDirectory 

func FileGroupsForHostPathVolumeWithMultipleDirectory() []api.FileGroup

func GetPathsFromResticFileGroups 

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

func GetPathsFromRestoreSession 

func GetPathsFromRestoreSession(restoreSession *v1beta1.RestoreSession) []string

func WaitUntilBackupConfigurationDeleted 

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

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 WaitUntilRepositoryDeleted 

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

func WaitUntilResticDeleted 

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

func WaitUntilRestoreSessionDeleted 

func WaitUntilRestoreSessionDeleted(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
	ClientConfig *rest.Config
	StorageClass string
	// contains filtered or unexported fields
}

func New 

func New(kubeClient kubernetes.Interface, extClient cs.Interface, kaClient ka.Interface, clientConfig *rest.Config, storageClass string) *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, modifier 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) CreateOrPatchService 

func (f *Framework) CreateOrPatchService(obj core.Service) 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) CreateRepository 

func (f *Framework) CreateRepository(repo *api.Repository) error

func (*Framework) CreateRestic 

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

func (*Framework) CreateSampleDataInsideWorkload 

func (f *Framework) CreateSampleDataInsideWorkload(meta metav1.ObjectMeta, resourceKind string) 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) DeleteRepository 

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

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

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

func (*Framework) EventuallyBackupSessionPhase 

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

func (*Framework) EventuallyBackupSessionTotalHost 

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

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

func (*Framework) EventuallyPodAccessible 

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

func (f *Framework) EventuallyRestoreSessionPhase(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) GetAllPod 

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

func (*Framework) GetBackupSession 

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

func (*Framework) GetLeaderIdentity 

func (f *Framework) GetLeaderIdentity(meta metav1.ObjectMeta, kind string, modifier 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) InstallStashOperator 

func (f *Framework) InstallStashOperator(kubeConfigPath string, options *srvr.ExtraOptions)

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

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

func (*Framework) ReadSampleDataFromFromWorkload 

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

func (*Framework) ReadSampleDataFromMountedDirectory 

func (f *Framework) ReadSampleDataFromMountedDirectory(meta metav1.ObjectMeta, paths []string, resourceKind 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) StatefulSetRepos 

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

func (*Framework) UninstallStashOperator 

func (f *Framework) UninstallStashOperator()

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

func (f *Invocation) BackupConfiguration(repoName string, targetref v1beta1.TargetRef) v1beta1.BackupConfiguration

func (*Invocation) BackupTask 

func (f *Invocation) BackupTask() v1beta1.Task

func (*Invocation) CleanupRecoveredVolume 

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

func (*Invocation) CleanupSampleDataFromWorkload 

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

func (*Invocation) CreateBackupConfiguration 

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

func (*Invocation) CreateDeploymentForMinioServer 

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

func (*Invocation) CreateFunction 

func (f *Invocation) CreateFunction(function v1beta1.Function) error

func (*Invocation) CreateMinioServer 

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

func (*Invocation) CreatePersistentVolumeClaim 

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

func (*Invocation) CreatePersistentVolumeClaimForMinioServer 

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

func (*Invocation) CreatePod 

func (f *Invocation) CreatePod(pod core.Pod) error

func (*Invocation) CreateRestoreSession 

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

func (*Invocation) CreateServiceForMinioServer 

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

func (*Invocation) CreateTask 

func (f *Invocation) CreateTask(task v1beta1.Task) error

func (*Invocation) DaemonSet 

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

func (*Invocation) DeleteBackupConfiguration 

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

func (*Invocation) DeleteFunction 

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

func (*Invocation) DeleteMinioServer 

func (fi *Invocation) DeleteMinioServer()

func (*Invocation) DeletePersistentVolumeClaim 

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

func (*Invocation) DeletePod 

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

func (Invocation) DeleteRestoreSession 

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

func (*Invocation) DeleteTask 

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

func (*Invocation) Deployment 

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

func (*Invocation) DeploymentForMinioServer 

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

func (*Invocation) GetPersistentVolumeClaim 

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

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

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

func (*Invocation) PodTemplate 

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

func (*Invocation) PvcBackupFunction 

func (f *Invocation) PvcBackupFunction() v1beta1.Function

func (*Invocation) PvcBackupTarget 

func (f *Invocation) PvcBackupTarget(pvcName string) *v1beta1.BackupTarget

func (*Invocation) PvcRestoreFunction 

func (f *Invocation) PvcRestoreFunction() v1beta1.Function

func (*Invocation) PvcRestoreTarget 

func (f *Invocation) PvcRestoreTarget(pvcName string) *v1beta1.RestoreTarget

func (*Invocation) ReadDataFromPod 

func (f *Invocation) ReadDataFromPod(meta metav1.ObjectMeta) (data string, err error)

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(pvcName string) apps.ReplicaSet

func (*Invocation) ReplicationController 

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

func (*Invocation) Repository 

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

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

func (f *Invocation) RestoreSession(repoName string, targetref v1beta1.TargetRef, rules []v1beta1.Rule) v1beta1.RestoreSession

func (*Invocation) RestoreTask 

func (f *Invocation) RestoreTask() v1beta1.Task

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(pvcName string) apps.StatefulSet

func (*Invocation) StatefulSetForV1beta1API 

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

func (*Invocation) UpdateStatusFunction 

func (f *Invocation) UpdateStatusFunction() v1beta1.Function

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.