bosh

package
v6.10.45+incompatible Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2018 License: Apache-2.0 Imports: 27 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 VSphereJumpboxNetworkOps = `---
- type: remove
  path: /instance_groups/name=jumpbox/networks/name=public
`

Variables

View Source 
var (
	MAX_RETRIES = 5
	RETRY_DELAY = 10 * time.Second
)

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 BOSHCLI 

type BOSHCLI struct {
	GlobalArgs   []string
	BOSHAllProxy string
	Stderr       io.Writer
	BOSHCLIPath  string
}

func NewBOSHCLI 

func NewBOSHCLI(stderr io.Writer, boshPath, directorAddress, username, password, caCert, boshAllProxy string) BOSHCLI

func (BOSHCLI) Run 

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

func (BOSHCLI) UpdateRuntimeConfig 

func (c BOSHCLI) UpdateRuntimeConfig(filepath, name 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 Client 

type Client struct {
	DirectorAddress string
	UAAAddress      string
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(httpClient *http.Client, DirectorAddress, uaaAddress, username, password, caCert string) Client

func (Client) Info 

func (c Client) Info() (Info, error)

func (Client) UpdateCloudConfig 

func (c Client) UpdateCloudConfig(yaml []byte) error

func (Client) UpdateConfig 

func (c Client) UpdateConfig(configType, name string, content []byte) error

type ClientProvider 

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

func NewClientProvider 

func NewClientProvider(allProxyGetter allProxyGetter, socks5Proxy socks5Proxy, sshKeyGetter sshKeyGetter, boshCLIPath string) ClientProvider

func (ClientProvider) BoshCLI 

func (c ClientProvider) BoshCLI(jumpbox storage.Jumpbox, stderr io.Writer, directorAddress, directorUsername, directorPassword, directorCACert string) (RuntimeConfigUpdater, error)

func (ClientProvider) Client 

func (c ClientProvider) Client(jumpbox storage.Jumpbox, directorAddress, directorUsername, directorPassword, directorCACert string) (ConfigUpdater, error)

func (ClientProvider) Dialer 

func (c ClientProvider) Dialer(jumpbox storage.Jumpbox) (proxy.Dialer, error)

func (ClientProvider) HTTPClient 

func (ClientProvider) HTTPClient(dialer proxy.Dialer, directorCACert []byte) *http.Client

type ConfigRequestBody 

type ConfigRequestBody struct {
	Name    string `json:"name"`
	Type    string `json:"type"`
	Content string `json:"content"`
}

type ConfigUpdater 

type ConfigUpdater interface {
	UpdateCloudConfig(yaml []byte) error
	Info() (Info, 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 Info 

type Info struct {
	Name    string `json:"name"`
	UUID    string `json:"uuid"`
	Version string `json:"version"`
}

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 RuntimeConfigUpdater 

type RuntimeConfigUpdater interface {
	UpdateRuntimeConfig(filepath, name string) error
}

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.