cfmysql

Documentation

Index

• Constants
• type ApiClient
• type ApiClientImpl
  • func NewApiClient() *ApiClientImpl
  • func (self *ApiClientImpl) GetServiceBindings(cliConnection plugin.CliConnection) ([]pluginModels.ServiceBinding, error)
  • func (self *ApiClientImpl) GetServiceInstances(cliConnection plugin.CliConnection) ([]pluginModels.ServiceInstance, error)
  • func (self *ApiClientImpl) GetStartedApps(cliConnection plugin.CliConnection) ([]sdkModels.GetAppsModel, error)
• type BindingResult
• type CfService
• type CfServiceImpl
  • func NewCfService() *CfServiceImpl
  • func (self *CfServiceImpl) GetMysqlServices(cliConnection plugin.CliConnection) ([]MysqlService, error)
  • func (self *CfServiceImpl) GetStartedApps(cliConnection plugin.CliConnection) ([]sdkModels.GetAppsModel, error)
  • func (self *CfServiceImpl) OpenSshTunnel(cliConnection plugin.CliConnection, toService MysqlService, throughApp string, ...)
• type CfSshRunner
  • func (self *CfSshRunner) OpenSshTunnel(cliConnection plugin.CliConnection, toService MysqlService, throughApp string, ...)
• type Exec
• type ExecWrapper
  • func (self *ExecWrapper) LookPath(file string) (string, error)
  • func (self *ExecWrapper) Run(cmd *exec.Cmd) error
• type FreePortFinder
  • func (self *FreePortFinder) GetPort() int
• type Http
• type HttpWrapper
  • func (self *HttpWrapper) Get(url string, accessToken string) ([]byte, error)
• type MysqlClientRunner
  • func (self *MysqlClientRunner) MakeMysqlCommand(hostname string, port int, dbName string, username string, password string) *exec.Cmd
  • func (self *MysqlClientRunner) RunMysql(hostname string, port int, dbName string, username string, password string, ...) error
  • func (self *MysqlClientRunner) RunMysqlDump(hostname string, port int, dbName string, username string, password string, ...) error
• type MysqlPlugin
  • func NewPlugin() *MysqlPlugin
  • func (self *MysqlPlugin) GetExitCode() int
  • func (self *MysqlPlugin) GetMetadata() plugin.PluginMetadata
  • func (self *MysqlPlugin) Run(cliConnection plugin.CliConnection, args []string)
• type MysqlRunner
  • func NewMysqlRunner() MysqlRunner
• type MysqlService
• type Net
• type NetWrapper
  • func (self *NetWrapper) Close(conn net.Conn) error
  • func (self *NetWrapper) Dial(network, address string) (net.Conn, error)
• type PortFinder
• type PortWaiter
  • func NewPortWaiter() PortWaiter
• type SshRunner
• type StartedAppsResult
• type TcpPortWaiter
  • func (self *TcpPortWaiter) WaitUntilOpen(localPort int)

Constants

const SLEEP_TIME = 100

Types

type ApiClient

type ApiClient interface {
	GetServiceBindings(cliConnection plugin.CliConnection) ([]pluginModels.ServiceBinding, error)
	GetServiceInstances(cliConnection plugin.CliConnection) ([]pluginModels.ServiceInstance, error)
	GetStartedApps(cliConnection plugin.CliConnection) ([]sdkModels.GetAppsModel, error)
}

type ApiClientImpl

type ApiClientImpl struct {
	HttpClient Http
}

func NewApiClient

func NewApiClient() *ApiClientImpl

func (*ApiClientImpl) GetServiceBindings

func (self *ApiClientImpl) GetServiceBindings(cliConnection plugin.CliConnection) ([]pluginModels.ServiceBinding, error)

func (*ApiClientImpl) GetServiceInstances

func (self *ApiClientImpl) GetServiceInstances(cliConnection plugin.CliConnection) ([]pluginModels.ServiceInstance, error)

func (*ApiClientImpl) GetStartedApps

func (self *ApiClientImpl) GetStartedApps(cliConnection plugin.CliConnection) ([]sdkModels.GetAppsModel, error)

type BindingResult

type BindingResult struct {
	Bindings []pluginModels.ServiceBinding
	Err      error
}

type CfService

type CfService interface {
	GetMysqlServices(cliConnection plugin.CliConnection) ([]MysqlService, error)
	GetStartedApps(cliConnection plugin.CliConnection) ([]sdkModels.GetAppsModel, error)
	OpenSshTunnel(cliConnection plugin.CliConnection, toService MysqlService, throughApp string, localPort int)
}

type CfServiceImpl

type CfServiceImpl struct {
	ApiClient  ApiClient
	HttpClient Http
	PortWaiter PortWaiter
	SshRunner  SshRunner
}

func NewCfService

func NewCfService() *CfServiceImpl

func (*CfServiceImpl) GetMysqlServices

func (self *CfServiceImpl) GetMysqlServices(cliConnection plugin.CliConnection) ([]MysqlService, error)

func (*CfServiceImpl) GetStartedApps

func (self *CfServiceImpl) GetStartedApps(cliConnection plugin.CliConnection) ([]sdkModels.GetAppsModel, error)

func (*CfServiceImpl) OpenSshTunnel

func (self *CfServiceImpl) OpenSshTunnel(cliConnection plugin.CliConnection, toService MysqlService, throughApp string, localPort int)

type CfSshRunner

type CfSshRunner struct{}

func (*CfSshRunner) OpenSshTunnel

func (self *CfSshRunner) OpenSshTunnel(cliConnection plugin.CliConnection, toService MysqlService, throughApp string, localPort int)

type Exec

type Exec interface {
	LookPath(file string) (string, error)
	Run(*exec.Cmd) error
}

type ExecWrapper

type ExecWrapper struct{}

func (*ExecWrapper) LookPath

func (self *ExecWrapper) LookPath(file string) (string, error)

func (*ExecWrapper) Run

func (self *ExecWrapper) Run(cmd *exec.Cmd) error

type FreePortFinder

type FreePortFinder struct{}

func (*FreePortFinder) GetPort

func (self *FreePortFinder) GetPort() int

type Http

type Http interface {
	Get(endpoint string, access_token string) ([]byte, error)
}

type HttpWrapper

type HttpWrapper struct{}

func (*HttpWrapper) Get

func (self *HttpWrapper) Get(url string, accessToken string) ([]byte, error)

type MysqlClientRunner

type MysqlClientRunner struct {
	ExecWrapper Exec
}

func (*MysqlClientRunner) MakeMysqlCommand

func (self *MysqlClientRunner) MakeMysqlCommand(hostname string, port int, dbName string, username string, password string) *exec.Cmd

func (*MysqlClientRunner) RunMysql

func (self *MysqlClientRunner) RunMysql(hostname string, port int, dbName string, username string, password string, mysqlArgs ...string) error

func (*MysqlClientRunner) RunMysqlDump

func (self *MysqlClientRunner) RunMysqlDump(hostname string, port int, dbName string, username string, password string, mysqlDumpArgs ...string) error

type MysqlPlugin

type MysqlPlugin struct {
	In          io.Reader
	Out         io.Writer
	Err         io.Writer
	CfService   CfService
	MysqlRunner MysqlRunner
	PortFinder  PortFinder
	// contains filtered or unexported fields
}

func NewPlugin

func NewPlugin() *MysqlPlugin

func (*MysqlPlugin) GetExitCode

func (self *MysqlPlugin) GetExitCode() int

func (*MysqlPlugin) GetMetadata

func (self *MysqlPlugin) GetMetadata() plugin.PluginMetadata

func (*MysqlPlugin) Run

func (self *MysqlPlugin) Run(cliConnection plugin.CliConnection, args []string)

type MysqlRunner

type MysqlRunner interface {
	RunMysql(hostname string, port int, dbName string, username string, password string, args ...string) error
	RunMysqlDump(hostname string, port int, dbName string, username string, password string, args ...string) error
}

func NewMysqlRunner

func NewMysqlRunner() MysqlRunner

type MysqlService

type MysqlService struct {
	Name     string
	AppName  string
	Hostname string
	Port     string
	DbName   string
	Username string
	Password string
}

type Net

type Net interface {
	Dial(network, address string) (net.Conn, error)
	Close(conn net.Conn) error
}

type NetWrapper

type NetWrapper struct{}

func (*NetWrapper) Close

func (self *NetWrapper) Close(conn net.Conn) error

func (*NetWrapper) Dial

func (self *NetWrapper) Dial(network, address string) (net.Conn, error)

type PortFinder

type PortFinder interface {
	GetPort() int
}

type PortWaiter

type PortWaiter interface {
	WaitUntilOpen(localPort int)
}

func NewPortWaiter

func NewPortWaiter() PortWaiter

type SshRunner

type SshRunner interface {
	OpenSshTunnel(cliConnection plugin.CliConnection, toService MysqlService, throughApp string, localPort int)
}

type StartedAppsResult

type StartedAppsResult struct {
	Apps []plugin_models.GetAppsModel
	Err  error
}

type TcpPortWaiter

type TcpPortWaiter struct {
	NetWrapper Net
}

func (*TcpPortWaiter) WaitUntilOpen

func (self *TcpPortWaiter) WaitUntilOpen(localPort int)