cfmysql

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

type BindingResult struct {
	Bindings *pluginResources.PaginatedServiceBindingResources
	Err      error
}

type CfSshRunner struct{}

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

type ExecWrapper struct{}

type FreePortFinder struct{}

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

type HttpWrapper struct{}

type MysqlClientRunner struct {
	ExecWrapper Exec
}

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

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
}

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

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

type NetWrapper struct{}

type PortFinder interface {
	GetPort() int
}

type PortWaiter interface {
	WaitUntilOpen(localPort int)
}

type SdkApiClient struct {
	SshRunner  SshRunner
	PortWaiter PortWaiter
	HttpClient Http
}

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

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

type TcpPortWaiter struct {
	NetWrapper Net
}