mysql

Documentation

Index

• func CreateBackup(e exec.Executor, cfHome string, instance cf.ServiceInstance) flow.StepFunc
• func DownloadBackup(e exec.Executor, instance *cf.ServiceInstance, downloader s3.ObjectDownloader, ...) flow.StepFunc
• func GetBackupStatus(e exec.Executor, cfHome string, instance cf.ServiceInstance, ...) flow.StepFunc
• func GetLatestBackup(e exec.Executor, cfHome string, instance cf.ServiceInstance) flow.StepFunc
• func InstallADBRPlugin(e exec.Executor, cfHome string) flow.StepFunc
• func NewExportSequence(api, org, space string, instance *cf.ServiceInstance, om config.OpsManager, ...) flow.Flow
• func NewImportSequence(api, org, space string, instance *cf.ServiceInstance, om config.OpsManager, ...) flow.Flow
• func RestoreBackup(e exec.Executor, om config.OpsManager, instance *cf.ServiceInstance) flow.StepFunc
• func RetrieveEncryptionKey(e exec.Executor, om config.OpsManager, instance *cf.ServiceInstance, ...) flow.StepFunc
• func TransferBackup(e exec.Executor, om config.OpsManager, instance *cf.ServiceInstance) flow.StepFunc
• type BackupDateTimeExtractor
• type BackupFilenameExtractor
• type BackupIDExtractor
• type EncryptionKeyExtractor
• type Migrator
  • func NewMigrator(flow flow.Flow, mr config.MigrationReader) *Migrator
  • func (m *Migrator) Migrate(ctx context.Context) (*cf.ServiceInstance, error)
  • func (m *Migrator) Validate(*cf.ServiceInstance, bool) error

Functions

func CreateBackup

func CreateBackup(e exec.Executor, cfHome string, instance cf.ServiceInstance) flow.StepFunc

func DownloadBackup

func DownloadBackup(e exec.Executor, instance *cf.ServiceInstance, downloader s3.ObjectDownloader, dateTimeExtractor BackupDateTimeExtractor, idExtractor BackupIDExtractor, fso sio.FileSystemOperations, exportDir string) flow.StepFunc

func GetBackupStatus

func GetBackupStatus(e exec.Executor, cfHome string, instance cf.ServiceInstance, timeout time.Duration, pause time.Duration) flow.StepFunc

func GetLatestBackup

func GetLatestBackup(e exec.Executor, cfHome string, instance cf.ServiceInstance) flow.StepFunc

func InstallADBRPlugin

func InstallADBRPlugin(e exec.Executor, cfHome string) flow.StepFunc

func NewExportSequence

func NewExportSequence(api, org, space string, instance *cf.ServiceInstance, om config.OpsManager, downloader s3.ObjectDownloader, executor exec.Executor, exportDir string) flow.Flow

func NewImportSequence

func NewImportSequence(api, org, space string, instance *cf.ServiceInstance, om config.OpsManager, executor exec.Executor) flow.Flow

func RestoreBackup

func RestoreBackup(e exec.Executor, om config.OpsManager, instance *cf.ServiceInstance) flow.StepFunc

func RetrieveEncryptionKey

func RetrieveEncryptionKey(e exec.Executor, om config.OpsManager, instance *cf.ServiceInstance, encryptionKeyExtractor EncryptionKeyExtractor) flow.StepFunc

func TransferBackup

func TransferBackup(e exec.Executor, om config.OpsManager, instance *cf.ServiceInstance) flow.StepFunc

Types

type BackupDateTimeExtractor

type BackupDateTimeExtractor func(s string) (string, string, error)

type BackupFilenameExtractor

type BackupFilenameExtractor func(s string) (string, error)

type BackupIDExtractor

type BackupIDExtractor func(s string) (string, error)

type EncryptionKeyExtractor

type EncryptionKeyExtractor func(s string) (string, error)

type Migrator

type Migrator struct {
	// contains filtered or unexported fields
}

func NewMigrator

func NewMigrator(flow flow.Flow, mr config.MigrationReader) *Migrator

func (*Migrator) Migrate

func (m *Migrator) Migrate(ctx context.Context) (*cf.ServiceInstance, error)

func (*Migrator) Validate

func (m *Migrator) Validate(*cf.ServiceInstance, bool) error