orchestrator

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

type ArtifactCopier interface {
	DownloadBackupFromDeployment(Backup, Deployment) error
	UploadBackupToDeployment(Backup, Deployment) error
}

type ArtifactIdentifier interface {
	InstanceName() string
	InstanceIndex() string
	InstanceID() string
	Name() string
	HasCustomName() bool
}

type AuthInfo struct {
	Type   string
	UaaUrl string
}

type Backup interface {
	CreateArtifact(ArtifactIdentifier) (io.WriteCloser, error)
	ReadArtifact(ArtifactIdentifier) (io.ReadCloser, error)
	AddChecksum(ArtifactIdentifier, BackupChecksum) error
	CreateMetadataFileWithStartTime(time.Time) error
	AddFinishTime(time.Time) error
	FetchChecksum(ArtifactIdentifier) (BackupChecksum, error)
	CalculateChecksum(ArtifactIdentifier) (BackupChecksum, error)
	DeploymentMatches(string, []Instance) (bool, error)
	SaveManifest(manifest string) error
	Valid() (bool, error)
}

type BackupArtifact interface {
	ArtifactIdentifier
	Size() (string, error)
	Checksum() (BackupChecksum, error)
	StreamFromRemote(io.Writer) error
	Delete() error
	StreamToRemote(io.Reader) error
}

type BackupChecker struct {
	*Workflow
}

type BackupChecksum map[string]string

type BackupCleaner struct {
	Logger
	*Workflow
}

type BackupDownloadExecutable struct {
	Logger
	// contains filtered or unexported fields
}

type BackupError customError

type BackupManager interface {
	Create(string, string, Logger, func() time.Time) (Backup, error)
	Open(string, Logger) (Backup, error)
}

type BackupStep struct{}

type BackupUploadExecutable struct {
	Logger
	// contains filtered or unexported fields
}

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

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

type CleanupError customError

type CleanupPreviousStep struct{}

type CleanupStep struct{}

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

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

type Deployment interface {
	IsBackupable() bool
	BackupableInstances() []Instance
	HasUniqueCustomArtifactNames() bool
	CheckArtifactDir() error
	IsRestorable() bool
	RestorableInstances() []Instance
	PreBackupLock(LockOrderer, executor.Executor) error
	Backup() error
	PostBackupUnlock(LockOrderer, executor.Executor) error
	Restore() error
	Cleanup() error
	CleanupPrevious() error
	Instances() []Instance
	CustomArtifactNamesMatch() error
	PreRestoreLock(LockOrderer, executor.Executor) error
	PostRestoreUnlock(LockOrderer, executor.Executor) error
	ValidateLockingDependencies(orderer LockOrderer) error
}

type DeploymentManager interface {
	Find(deploymentName string) (Deployment, error)
	SaveManifest(deploymentName string, artifact Backup) error
}

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

type Error []error

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

type Instance interface {
	InstanceIdentifer
	IsBackupable() bool
	ArtifactDirExists() (bool, error)
	ArtifactDirCreated() bool
	MarkArtifactDirCreated()
	IsRestorable() bool
	Backup() error
	Restore() error
	Cleanup() error
	CleanupPrevious() error
	ArtifactsToBackup() []BackupArtifact
	ArtifactsToRestore() []BackupArtifact
	CustomBackupArtifactNames() []string
	CustomRestoreArtifactNames() []string
	Jobs() []Job
}

type InstanceIdentifer interface {
	Name() string
	Index() string
	ID() string
}

type Job interface {
	HasBackup() bool
	HasRestore() bool
	HasNamedBackupArtifact() bool
	HasNamedRestoreArtifact() bool
	BackupArtifactName() string
	RestoreArtifactName() string
	Backup() error
	PreBackupLock() error
	PostBackupUnlock() error
	PreRestoreLock() error
	Restore() error
	PostRestoreUnlock() error
	Name() string
	Release() string
	InstanceIdentifier() string
	BackupArtifactDirectory() string
	RestoreArtifactDirectory() string
	BackupShouldBeLockedBefore() []JobSpecifier
	RestoreShouldBeLockedBefore() []JobSpecifier
}

type JobPostBackupUnlockExecutor struct {
	Job
}

type JobPostRestoreUnlockExecutor struct {
	Job
}

type JobPreBackupLockExecutor struct {
	Job
}

type JobPreRestoreLockExecutor struct {
	Job
}

type JobSpecifier struct {
	Name    string
	Release string
}

type Jobs []Job

type LockError customError

type LockOrderer interface {
	Order(jobs []Job) ([][]Job, error)
}

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

type Logger interface {
	Debug(tag, msg string, args ...interface{})
	Info(tag, msg string, args ...interface{})
	Warn(tag, msg string, args ...interface{})
	Error(tag, msg string, args ...interface{})
}

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

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

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

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

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

type RestoreCleaner struct {
	Logger
	*Workflow
}

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

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

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

type Step interface {
	Run(*Session) error
}

type UnlockError customError

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

type Workflow struct {
	StartingNode *Node
	Nodes        []*Node
}