bosh

package
v6.11.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2018 License: Apache-2.0 Imports: 17 Imported by: 3

Documentation

Index

Constants

View Source 
const AWSBoshDirectorEphemeralIPOps = `
- type: replace
  path: /resource_pools/name=vms/cloud_properties/auto_assign_public_ip?
  value: true
`
View Source 
const GCPBoshDirectorEphemeralIPOps = `
- type: replace
  path: /networks/name=default/subnets/0/cloud_properties/ephemeral_external_ip?
  value: true
`
View Source 
const OpenStackJumpboxKeystoneV3Ops = `` /* 644-byte string literal not displayed */
View Source 
const VSphereJumpboxNetworkOps = `---
- type: remove
  path: /instance_groups/name=jumpbox/networks/name=public
`

Variables

This section is empty.

Functions

func Asset 

func Asset(name string) ([]byte, error)

Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetDir 

func AssetDir(name string) ([]string, error)

AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy: 

data/
  foo.txt
  img/
    a.png
    b.png

then AssetDir("data") would return []string{"foo.txt", "img"} AssetDir("data/img") would return []string{"a.png", "b.png"} AssetDir("foo.txt") and AssetDir("notexist") would return an error AssetDir("") will return []string{"data"}.

func AssetInfo 

func AssetInfo(name string) (os.FileInfo, error)

AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetNames 

func AssetNames() []string

AssetNames returns the names of the assets.

func MustAsset 

func MustAsset(name string) []byte

MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.

func RestoreAsset 

func RestoreAsset(dir, name string) error

RestoreAsset restores an asset under the given directory

func RestoreAssets 

func RestoreAssets(dir, name string) error

RestoreAssets restores an asset under the given directory recursively

Types

type AllProxyGetter 

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

func NewAllProxyGetter 

func NewAllProxyGetter(sshKeyGetter sshKeyGetter, fs allProxyFs) AllProxyGetter

func (AllProxyGetter) BoshAllProxy 

func (a AllProxyGetter) BoshAllProxy(jumpboxURL, privateKeyPath string) string

func (AllProxyGetter) GeneratePrivateKey 

func (a AllProxyGetter) GeneratePrivateKey() (string, error)

type AuthenticatedCLI 

type AuthenticatedCLI struct {
	GlobalArgs         []string
	BOSHAllProxy       string
	Stderr             io.Writer
	BOSHExecutablePath string
}

func NewAuthenticatedCLI 

func NewAuthenticatedCLI(stderr io.Writer, boshPath, directorAddress, username, password, caCert, boshAllProxy string) AuthenticatedCLI

func (AuthenticatedCLI) Run 

func (c AuthenticatedCLI) Run(stdout io.Writer, workingDirectory string, args []string) error

type AuthenticatedCLIRunner 

type AuthenticatedCLIRunner interface {
	Run(stdout io.Writer, workingDirectory string, args []string) error
}

type BOSHVersionError 

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

func NewBOSHVersionError 

func NewBOSHVersionError(err error) BOSHVersionError

func (BOSHVersionError) Error 

func (b BOSHVersionError) Error() string

type CIDRBlock 

type CIDRBlock struct {
	CIDRSize int
	// contains filtered or unexported fields
}

func ParseCIDRBlock 

func ParseCIDRBlock(cidrBlock string) (CIDRBlock, error)

func (CIDRBlock) GetFirstIP 

func (c CIDRBlock) GetFirstIP() IP

func (CIDRBlock) GetLastIP 

func (c CIDRBlock) GetLastIP() IP

func (CIDRBlock) GetNthIP 

func (c CIDRBlock) GetNthIP(n int) IP

type CLI 

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

func NewCLI 

func NewCLI(stderr io.Writer, path string) CLI

func (CLI) GetBOSHPath 

func (c CLI) GetBOSHPath() string

func (CLI) Run 

func (c CLI) Run(stdout io.Writer, workingDirectory string, args []string) error

type CLIProvider 

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

func NewCLIProvider 

func NewCLIProvider(allProxyGetter allProxyGetter, boshCLIPath string) CLIProvider

func (CLIProvider) AuthenticatedCLI 

func (c CLIProvider) AuthenticatedCLI(jumpbox storage.Jumpbox, stderr io.Writer, directorAddress, directorUsername, directorPassword, directorCACert string) (AuthenticatedCLIRunner, error)

type ConfigUpdater 

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

func NewConfigUpdater 

func NewConfigUpdater(boshCLIProvider boshCLIProvider) ConfigUpdater

func (ConfigUpdater) InitializeAuthenticatedCLI 

func (c ConfigUpdater) InitializeAuthenticatedCLI(state storage.State) (AuthenticatedCLIRunner, error)

func (ConfigUpdater) UpdateCloudConfig 

func (c ConfigUpdater) UpdateCloudConfig(boshCLI AuthenticatedCLIRunner, filepath string, opsFilepaths []string, varsFilepath string) error

func (ConfigUpdater) UpdateRuntimeConfig 

func (c ConfigUpdater) UpdateRuntimeConfig(boshCLI AuthenticatedCLIRunner, filepath string, opsFilepaths []string, name string) error

type CredhubGetter 

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

func NewCredhubGetter 

func NewCredhubGetter(stateStore stateStore, fileIO fileio.FileReader) CredhubGetter

func (CredhubGetter) GetCerts 

func (c CredhubGetter) GetCerts() (string, error)

func (CredhubGetter) GetPassword 

func (c CredhubGetter) GetPassword() (string, error)

func (CredhubGetter) GetServer 

func (c CredhubGetter) GetServer() (string, error)

type DirInput 

type DirInput struct {
	StateDir   string
	VarsDir    string
	Deployment string
}

type Executor 

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

func NewExecutor 

func NewExecutor(cmd cli, fs executorFs) Executor

func (Executor) CreateEnv 

func (e Executor) CreateEnv(input DirInput, state storage.State) (string, error)

func (Executor) DeleteEnv 

func (e Executor) DeleteEnv(input DirInput, state storage.State) error

func (Executor) Path 

func (e Executor) Path() string

func (Executor) PlanDirector 

func (e Executor) PlanDirector(input DirInput, deploymentDir, iaas string) error

func (Executor) PlanJumpbox 

func (e Executor) PlanJumpbox(input DirInput, deploymentDir, iaas string) error

func (Executor) Version 

func (e Executor) Version() (string, error)

func (Executor) WriteDeploymentVars 

func (e Executor) WriteDeploymentVars(input DirInput, deploymentVars string) error

type IP 

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

func ParseIP 

func ParseIP(ip string) (IP, error)

func (IP) Add 

func (i IP) Add(offset int) IP

func (IP) String 

func (i IP) String() string

func (IP) Subtract 

func (i IP) Subtract(offset int) IP

type Manager 

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

func NewManager 

func NewManager(executor executor, logger logger, stateStore stateStore, sshKeyGetter sshKeyGetter, fs deleterFs) *Manager

func (*Manager) CreateDirector 

func (m *Manager) CreateDirector(state storage.State, terraformOutputs terraform.Outputs) (storage.State, error)

func (*Manager) CreateJumpbox 

func (m *Manager) CreateJumpbox(state storage.State, terraformOutputs terraform.Outputs) (storage.State, error)

func (*Manager) DeleteDirector 

func (m *Manager) DeleteDirector(state storage.State, terraformOutputs terraform.Outputs) error

func (*Manager) DeleteJumpbox 

func (m *Manager) DeleteJumpbox(state storage.State, terraformOutputs terraform.Outputs) error

func (*Manager) GetDirectorDeploymentVars 

func (m *Manager) GetDirectorDeploymentVars(state storage.State, terraformOutputs terraform.Outputs) string

func (*Manager) GetJumpboxDeploymentVars 

func (m *Manager) GetJumpboxDeploymentVars(state storage.State, terraformOutputs terraform.Outputs) string

func (*Manager) InitializeDirector 

func (m *Manager) InitializeDirector(state storage.State) error

func (*Manager) InitializeJumpbox 

func (m *Manager) InitializeJumpbox(state storage.State) error

func (*Manager) Path 

func (m *Manager) Path() string

func (*Manager) Version 

func (m *Manager) Version() (string, error)

type ManagerCreateError 

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

func NewManagerCreateError 

func NewManagerCreateError(state storage.State, err error) ManagerCreateError

func (ManagerCreateError) Error 

func (b ManagerCreateError) Error() string

func (ManagerCreateError) State 

func (b ManagerCreateError) State() storage.State

type ManagerDeleteError 

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

func NewManagerDeleteError 

func NewManagerDeleteError(state storage.State, err error) ManagerDeleteError

func (ManagerDeleteError) Error 

func (b ManagerDeleteError) Error() string

func (ManagerDeleteError) State 

func (b ManagerDeleteError) State() storage.State

type SSHKeyDeleter 

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

func NewSSHKeyDeleter 

func NewSSHKeyDeleter(stateStore stateStore, fs deleterFs) SSHKeyDeleter

func (SSHKeyDeleter) Delete 

func (s SSHKeyDeleter) Delete() error

type SSHKeyGetter 

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

func NewSSHKeyGetter 

func NewSSHKeyGetter(stateStore stateStore, fReader fileio.FileReader) SSHKeyGetter

func (SSHKeyGetter) Get 

func (j SSHKeyGetter) Get(deployment string) (string, error)

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.