boshtest

Documentation

Index

• func NewSocks5Dialer(proxyURL string, logger *log.Logger) (proxy.DialFunc, error)
• func SetupSocks5Proxy()
• type CLI
  • func NewCLI(deployment string, timeout time.Duration) *CLI
  • func NewCLIWithCnfPath(deployment string, timeout time.Duration, path string) *CLI
  • func (c *CLI) DeleteDeployment() error
  • func (c *CLI) Deploy(manifestPath string, options ...DeploymentOption) error
  • func (c *CLI) Follower() (*Instance, error)
  • func (c *CLI) InstanceAddress(instance string) (string, error)
  • func (c *CLI) InstanceGroupByName(instanceGroup string) ([]Instance, error)
  • func (c *CLI) Leader() (*Instance, error)
  • func (c *CLI) MySQLExec(instance, sql string) error
  • func (c *CLI) MySQLIsReadOnly(instance string) (bool, error)
  • func (c *CLI) MySQLQuery(instance, sql string) (string, error)
  • func (c *CLI) MySQLSchemaExists(instance, schemaName string) (bool, error)
  • func (c *CLI) MySQLTableExists(instance, schemaName, tableName string) (bool, error)
  • func (c *CLI) Restart(instance string) error
  • func (c *CLI) Run(args ...string) (string, error)
  • func (c *CLI) RunErrand(errandName, instance string) (string, error)
  • func (c *CLI) Start(instance string) error
  • func (c *CLI) Stop(instance string) error
• type DeploymentOption
  • func WithOpsFiles(path ...string) DeploymentOption
  • func WithVars(varKeyValue ...string) DeploymentOption
  • func WithVarsStore(path string) DeploymentOption
• type Instance

Functions

func NewSocks5Dialer

func NewSocks5Dialer(proxyURL string, logger *log.Logger) (proxy.DialFunc, error)

func SetupSocks5Proxy

func SetupSocks5Proxy()

Types

type CLI

type CLI struct {
	Deployment string
	Timeout    time.Duration
	// contains filtered or unexported fields
}

func NewCLI

func NewCLI(deployment string, timeout time.Duration) *CLI

func NewCLIWithCnfPath

func NewCLIWithCnfPath(deployment string, timeout time.Duration, path string) *CLI

func (*CLI) DeleteDeployment

func (c *CLI) DeleteDeployment() error

func (*CLI) Deploy

func (c *CLI) Deploy(manifestPath string, options ...DeploymentOption) error

func (*CLI) Follower

func (c *CLI) Follower() (*Instance, error)

func (*CLI) InstanceAddress

func (c *CLI) InstanceAddress(instance string) (string, error)

func (*CLI) InstanceGroupByName

func (c *CLI) InstanceGroupByName(instanceGroup string) ([]Instance, error)

func (*CLI) Leader

func (c *CLI) Leader() (*Instance, error)

func (*CLI) MySQLExec

func (c *CLI) MySQLExec(instance, sql string) error

func (*CLI) MySQLIsReadOnly

func (c *CLI) MySQLIsReadOnly(instance string) (bool, error)

func (*CLI) MySQLQuery

func (c *CLI) MySQLQuery(instance, sql string) (string, error)

func (*CLI) MySQLSchemaExists

func (c *CLI) MySQLSchemaExists(instance, schemaName string) (bool, error)

func (*CLI) MySQLTableExists

func (c *CLI) MySQLTableExists(instance, schemaName, tableName string) (bool, error)

func (*CLI) Restart

func (c *CLI) Restart(instance string) error

func (*CLI) Run

func (c *CLI) Run(args ...string) (string, error)

func (*CLI) RunErrand

func (c *CLI) RunErrand(errandName, instance string) (string, error)

func (*CLI) Start

func (c *CLI) Start(instance string) error

func (*CLI) Stop

func (c *CLI) Stop(instance string) error

type DeploymentOption

type DeploymentOption func(args *[]string)

func WithOpsFiles

func WithOpsFiles(path ...string) DeploymentOption

func WithVars

func WithVars(varKeyValue ...string) DeploymentOption

func WithVarsStore

func WithVarsStore(path string) DeploymentOption

type Instance

type Instance struct {
	Group        string
	IP           string
	Index        string
	UUID         string
	VmCid        string
	ProcessState string
}