bosh

package
v6.0.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2018 License: Apache-2.0 Imports: 27 Imported by: 0

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 AWSEncryptDiskOps = `` /* 145-byte string literal not displayed */
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 AWSYAML 

type AWSYAML struct {
	AccessKeyID     string `yaml:"access_key_id,omitempty"`
	SecretAccessKey string `yaml:"secret_access_key,omitempty"`
}

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 AzureYAML 

type AzureYAML struct {
	SubscriptionID string `yaml:"subscription_id,omitempty"`
	TenantID       string `yaml:"tenant_id,omitempty"`
	ClientID       string `yaml:"client_id,omitempty"`
	ClientSecret   string `yaml:"client_secret,omitempty"`
}

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 Client 

type Client interface {
	UpdateCloudConfig(yaml []byte) error
	Info() (Info, error)
}

func NewClient 

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

type ClientProvider 

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

func NewClientProvider 

func NewClientProvider(socks5Proxy socks5Proxy, sshKeyGetter sshKeyGetter) ClientProvider

func (ClientProvider) Client 

func (c ClientProvider) Client(jumpbox storage.Jumpbox, directorAddress, directorUsername, directorPassword, directorCACert string) (Client, 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 Cmd 

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

func NewCmd 

func NewCmd(stderr io.Writer) Cmd

func (Cmd) GetBOSHPath 

func (c Cmd) GetBOSHPath() (string, error)

func (Cmd) Run 

func (c Cmd) Run(stdout io.Writer, workingDirectory string, args []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 command,
	fs executorFs,
	unmarshalJSON func([]byte, interface{}) error,
	marshalJSON func(interface{}) ([]byte, error),
) 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) 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 GCPYAML 

type GCPYAML struct {
	Zone           string `yaml:"zone,omitempty"`
	ProjectID      string `yaml:"project_id,omitempty"`
	CredentialJSON string `yaml:"gcp_credentials_json,omitempty"`
}

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

type VSphereYAML 

type VSphereYAML struct {
	VCenterUser     string `yaml:"vcenter_user,omitempty"`
	VCenterPassword string `yaml:"vcenter_password,omitempty"`
}

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.