cfmysql

type ApiClient interface {
	GetStartedApps(cliConnection plugin.CliConnection) ([]sdkModels.GetAppsModel, error)
	GetService(cliConnection plugin.CliConnection, spaceGuid string, name string) (pluginModels.ServiceInstance, error)
	GetServiceKey(cliConnection plugin.CliConnection, serviceInstanceGuid string, keyName string) (key pluginModels.ServiceKey, found bool, err error)
	CreateServiceKey(cliConnection plugin.CliConnection, serviceInstanceGuid string, keyName string) (pluginModels.ServiceKey, error)
}

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

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

type CliConfig struct {
	AccessToken string
	ApiEndpoint string
	SslDisabled bool
}

type DefaultLocaleReader struct{}

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

type HttpClientFactory interface {
	NewClient(sslDisabled bool) *http.Client
}

type HttpWrapper interface {
	Get(endpoint string, accessToken string, skipSsl bool) ([]byte, error)
	Post(url string, body io.Reader, accessToken string, sslDisabled bool) ([]byte, error)
}

type MysqlPlugin struct {
	In          io.Reader
	Out         io.Writer
	Err         io.Writer
	CfService   CfService
	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
	Hostname string
	Port     string
	DbName   string
	Username string
	Password string
}

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

type OsWrapper interface {
	LookupEnv(key string) (string, bool)
}

type PluginConf struct {
	In          io.Reader
	Out         io.Writer
	Err         io.Writer
	CfService   CfService
	MysqlRunner MysqlRunner
	PortFinder  PortFinder
}

type PortFinder interface {
	GetPort() int
}

type PortWaiter interface {
	WaitUntilOpen(localPort int)
}

type RandWrapper interface {
	Intn(n int) int
}

type ServiceKeyRequest struct {
	Name                string `json:"name"`
	ServiceInstanceGuid string `json:"service_instance_guid"`
}

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

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