command

Documentation

Index

• func BindDrain(cli plugin.CliConnection, df DrainFetcher, args []string, log Logger)
• func CreateDrain(cli plugin.CliConnection, args []string, d Downloader, log Logger)
• func DeleteDrain(cli plugin.CliConnection, args []string, log Logger, in io.Reader, ...)
• func DeleteSpaceDrain(cli plugin.CliConnection, args []string, log Logger, in io.Reader, ...)
• func Drains(cli plugin.CliConnection, args []string, log Logger, tableWriter io.Writer, ...)
• func MigrateSpaceDrain(cli plugin.CliConnection, args []string, d Downloader, f RefreshTokenFetcher, ...)
• func PushServiceDrain(cli plugin.CliConnection, args []string, f RefreshTokenFetcher, log Logger, ...)
• func PushSpaceDrain(cli plugin.CliConnection, args []string, d Downloader, f RefreshTokenFetcher, ...)
• func PushSpaceServiceDrain(cli plugin.CliConnection, args []string, d Downloader, f RefreshTokenFetcher, ...)
• type DeleteDrainFunc
• type Downloader
• type DrainFetcher
• type GUIDProvider
• type GithubReleaseDownloader
  • func NewGithubReleaseDownloader(c HTTPClient, log Logger) GithubReleaseDownloader
  • func (d GithubReleaseDownloader) Download(assetName string) string
• type GroupNameProvider
• type HTTPClient
• type Logger
• type RefreshTokenFetcher
• type TokenFetcher
  • func NewTokenFetcher(configPath string) *TokenFetcher
  • func (tf *TokenFetcher) RefreshToken() (string, error)

Functions

func BindDrain

func BindDrain(cli plugin.CliConnection, df DrainFetcher, args []string, log Logger)

func CreateDrain

func CreateDrain(
	cli plugin.CliConnection,
	args []string,
	d Downloader,
	log Logger,
)

func DeleteDrain

func DeleteDrain(cli plugin.CliConnection, args []string, log Logger, in io.Reader, serviceDrainFetcher DrainFetcher)

func DeleteSpaceDrain

func DeleteSpaceDrain(cli plugin.CliConnection, args []string, log Logger, in io.Reader, df DrainFetcher, deleteDrain DeleteDrainFunc)

func Drains

func Drains(
	cli plugin.CliConnection,
	args []string,
	log Logger,
	tableWriter io.Writer,
	fetchers ...DrainFetcher,
)

func MigrateSpaceDrain

func MigrateSpaceDrain(
	cli plugin.CliConnection,
	args []string,
	d Downloader,
	f RefreshTokenFetcher,
	fetcher DrainFetcher,
	log Logger,
	guid GUIDProvider,
)

func PushServiceDrain

func PushServiceDrain(
	cli plugin.CliConnection,
	args []string,
	f RefreshTokenFetcher,
	log Logger,
	g GroupNameProvider,
)

func PushSpaceDrain

func PushSpaceDrain(
	cli plugin.CliConnection,
	args []string,
	d Downloader,
	f RefreshTokenFetcher,
	log Logger,
)

func PushSpaceServiceDrain

func PushSpaceServiceDrain(
	cli plugin.CliConnection,
	args []string,
	d Downloader,
	f RefreshTokenFetcher,
	log Logger,
	group GroupNameProvider,
	guid GUIDProvider,
)

Types

type DeleteDrainFunc

type DeleteDrainFunc func(plugin.CliConnection, []string, Logger, io.Reader, DrainFetcher)

type Downloader

type Downloader interface {
	Download(assetName string) string
}

type DrainFetcher

type DrainFetcher interface {
	Drains(spaceGUID string) ([]drain.Drain, error)
}

type GUIDProvider

type GUIDProvider func() string

type GithubReleaseDownloader

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

func NewGithubReleaseDownloader

func NewGithubReleaseDownloader(c HTTPClient, log Logger) GithubReleaseDownloader

func (GithubReleaseDownloader) Download

func (d GithubReleaseDownloader) Download(assetName string) string

type GroupNameProvider

type GroupNameProvider func() string

type HTTPClient

type HTTPClient interface {
	Do(r *http.Request) (*http.Response, error)
}

type Logger

type Logger interface {
	Printf(format string, args ...interface{})
	Fatalf(format string, args ...interface{})
	Print(...interface{})
}

Logger is used for outputting log-cache results and errors

type RefreshTokenFetcher

type RefreshTokenFetcher interface {
	RefreshToken() (string, error)
}

type TokenFetcher

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

func NewTokenFetcher

func NewTokenFetcher(configPath string) *TokenFetcher

func (*TokenFetcher) RefreshToken

func (tf *TokenFetcher) RefreshToken() (string, error)