bosh

Documentation

Index

• func NewBoshDeployedInstance(instanceGroupName, instanceIndex, instanceID string, ...) orchestrator.Instance
• func NewBoshManifestQuerier(manifest string) (instance.ManifestQuerier, error)
• type BoshClient
• type BoshDeployedInstance
  • func (i *BoshDeployedInstance) Cleanup() error
  • func (i *BoshDeployedInstance) CleanupPrevious() error
• type BoshManifestQuerier
  • func (mq BoshManifestQuerier) FindReleaseName(instanceGroupName, jobName string) (string, error)
  • func (mq BoshManifestQuerier) IsJobBackupOneRestoreAll(instanceGroupName, jobName string) (bool, error)
• type Client
  • func BuildClient(targetUrl, username, password, caCert, bbrVersion string, ...) (Client, error)
  • func NewClient(boshDirector director.Director, sshOptsGenerator ssh.SSHOptsGenerator, ...) Client
  • func (c Client) FindInstances(deploymentName string) ([]orchestrator.Instance, error)
  • func (c Client) GetManifest(deploymentName string) (string, error)
• type DeploymentManager
  • func NewDeploymentManager(boshDirector BoshClient, logger Logger, downloadManifest bool) *DeploymentManager
  • func (b *DeploymentManager) Find(deploymentName string) (orchestrator.Deployment, error)
  • func (b *DeploymentManager) SaveManifest(deploymentName string, backup orchestrator.Backup) error
• type JobVMInfo
• type Logger

Functions

func NewBoshDeployedInstance

func NewBoshDeployedInstance(instanceGroupName,
	instanceIndex,
	instanceID string,
	remoteRunner ssh.RemoteRunner,
	deployment director.Deployment,
	artifactDirectoryCreated bool,
	logger Logger,
	jobs orchestrator.Jobs,
) orchestrator.Instance

func NewBoshManifestQuerier

func NewBoshManifestQuerier(manifest string) (instance.ManifestQuerier, error)

Types

type BoshClient

type BoshClient interface {
	FindInstances(deploymentName string) ([]orchestrator.Instance, error)
	GetManifest(deploymentName string) (string, error)
}

type BoshDeployedInstance

type BoshDeployedInstance struct {
	Deployment director.Deployment
	*instance.DeployedInstance
}

func (*BoshDeployedInstance) Cleanup

func (i *BoshDeployedInstance) Cleanup() error

func (*BoshDeployedInstance) CleanupPrevious

func (i *BoshDeployedInstance) CleanupPrevious() error

type BoshManifestQuerier

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

func (BoshManifestQuerier) FindReleaseName

func (mq BoshManifestQuerier) FindReleaseName(instanceGroupName, jobName string) (string, error)

func (BoshManifestQuerier) IsJobBackupOneRestoreAll

func (mq BoshManifestQuerier) IsJobBackupOneRestoreAll(instanceGroupName, jobName string) (bool, error)

type Client

type Client struct {
	director.Director
	ssh.SSHOptsGenerator
	ssh.RemoteRunnerFactory
	Logger
	// contains filtered or unexported fields
}

func BuildClient

func BuildClient(targetUrl, username, password, caCert, bbrVersion string, logger boshlog.Logger) (Client, error)

func NewClient

func NewClient(boshDirector director.Director,
	sshOptsGenerator ssh.SSHOptsGenerator,
	remoteRunnerFactory ssh.RemoteRunnerFactory,
	logger Logger,
	jobFinder instance.JobFinder,
	manifestQuerierCreator instance.ManifestQuerierCreator) Client

func (Client) FindInstances

func (c Client) FindInstances(deploymentName string) ([]orchestrator.Instance, error)

func (Client) GetManifest

func (c Client) GetManifest(deploymentName string) (string, error)

type DeploymentManager

type DeploymentManager struct {
	BoshClient
	Logger
	// contains filtered or unexported fields
}

func NewDeploymentManager

func NewDeploymentManager(boshDirector BoshClient, logger Logger, downloadManifest bool) *DeploymentManager

func (*DeploymentManager) Find

func (b *DeploymentManager) Find(deploymentName string) (orchestrator.Deployment, error)

func (*DeploymentManager) SaveManifest

func (b *DeploymentManager) SaveManifest(deploymentName string, backup orchestrator.Backup) error

type JobVMInfo

type JobVMInfo struct {
	JobName string
	VMInfo  director.VMInfo
}

type Logger

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{})
}