download

Documentation

Index

• type ChecksumDownloader
• type ChecksumDownloaderImpl
  • func NewChecksumDownloader(gh GitHub, rt *runtime.Runtime, httpDownloader HTTPDownloader) *ChecksumDownloaderImpl
  • func (dl *ChecksumDownloaderImpl) DownloadChecksum(ctx context.Context, logE *logrus.Entry, rt *runtime.Runtime, ...) (io.ReadCloser, int64, error)
• type ClientAPI
• type DownloadedFile
  • func NewDownloadedFile(fs afero.Fs, body io.ReadCloser, pb *progressbar.ProgressBar) *DownloadedFile
  • func (f *DownloadedFile) Close() error
  • func (f *DownloadedFile) Path() (string, error)
  • func (f *DownloadedFile) Read() (io.ReadCloser, error)
  • func (f *DownloadedFile) ReadLast() (io.ReadCloser, error)
  • func (f *DownloadedFile) Remove() error
  • func (f *DownloadedFile) Wrap(w io.Writer) io.Writer
• type Downloader
  • func NewDownloader(gh GitHub, httpDownloader HTTPDownloader) *Downloader
  • func (dl *Downloader) ReadCloser(ctx context.Context, logE *logrus.Entry, file *File) (io.ReadCloser, int64, error)
• type File
  • func ConvertDownloadedFileToFile(file *registry.DownloadedFile, art *File, rt *runtime.Runtime, ...) (*File, error)
  • func ConvertPackageToFile(pkg *config.Package, assetName string, rt *runtime.Runtime) (*File, error)
  • func ConvertRegistryToFile(rgst *aqua.Registry) (*File, error)
• type GitHub
• type GitHubContentAPI
• type GitHubContentFileDownloader
  • func NewGitHubContentFileDownloader(gh GitHubContentAPI, httpDL HTTPDownloader) *GitHubContentFileDownloader
  • func (dl *GitHubContentFileDownloader) DownloadGitHubContentFile(ctx context.Context, logE *logrus.Entry, param *domain.GitHubContentFileParam) (*domain.GitHubContentFile, error)
• type GitHubReleaseAPI
• type GitHubReleaseDownloader
  • func NewGitHubReleaseDownloader(gh GitHubReleaseAPI, httpDL HTTPDownloader) *GitHubReleaseDownloader
  • func (dl *GitHubReleaseDownloader) DownloadGitHubRelease(ctx context.Context, logE *logrus.Entry, ...) (io.ReadCloser, int64, error)
• type HTTPDownloader
  • func NewHTTPDownloader(httpClient *http.Client) HTTPDownloader
• type Mock
  • func (m *Mock) ReadCloser(ctx context.Context, logE *logrus.Entry, file *File) (io.ReadCloser, int64, error)
• type MockChecksumDownloader
  • func (dl *MockChecksumDownloader) DownloadChecksum(ctx context.Context, logE *logrus.Entry, rt *runtime.Runtime, ...) (io.ReadCloser, int64, error)

Types

type ChecksumDownloader

type ChecksumDownloader interface {
	DownloadChecksum(ctx context.Context, logE *logrus.Entry, rt *runtime.Runtime, pkg *config.Package) (io.ReadCloser, int64, error)
}

type ChecksumDownloaderImpl

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

func NewChecksumDownloader

func NewChecksumDownloader(gh GitHub, rt *runtime.Runtime, httpDownloader HTTPDownloader) *ChecksumDownloaderImpl

func (*ChecksumDownloaderImpl) DownloadChecksum

func (dl *ChecksumDownloaderImpl) DownloadChecksum(ctx context.Context, logE *logrus.Entry, rt *runtime.Runtime, pkg *config.Package) (io.ReadCloser, int64, error)

type ClientAPI

type ClientAPI interface {
	ReadCloser(ctx context.Context, logE *logrus.Entry, file *File) (io.ReadCloser, int64, error)
}

type DownloadedFile

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

func NewDownloadedFile

func NewDownloadedFile(fs afero.Fs, body io.ReadCloser, pb *progressbar.ProgressBar) *DownloadedFile

func (*DownloadedFile) Close

func (f *DownloadedFile) Close() error

func (*DownloadedFile) Path

func (f *DownloadedFile) Path() (string, error)

func (*DownloadedFile) Read

func (f *DownloadedFile) Read() (io.ReadCloser, error)

func (*DownloadedFile) ReadLast

func (f *DownloadedFile) ReadLast() (io.ReadCloser, error)

func (*DownloadedFile) Remove

func (f *DownloadedFile) Remove() error

func (*DownloadedFile) Wrap

func (f *DownloadedFile) Wrap(w io.Writer) io.Writer

type Downloader

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

func NewDownloader

func NewDownloader(gh GitHub, httpDownloader HTTPDownloader) *Downloader

func (*Downloader) ReadCloser

func (dl *Downloader) ReadCloser(ctx context.Context, logE *logrus.Entry, file *File) (io.ReadCloser, int64, error)

type File

type File struct {
	Type      string
	RepoOwner string
	RepoName  string
	Version   string
	Asset     string
	URL       string
	Path      string
	Private   bool
}

func ConvertDownloadedFileToFile

func ConvertDownloadedFileToFile(file *registry.DownloadedFile, art *File, rt *runtime.Runtime, tplParam *template.Artifact) (*File, error)

func ConvertPackageToFile

func ConvertPackageToFile(pkg *config.Package, assetName string, rt *runtime.Runtime) (*File, error)

func ConvertRegistryToFile

func ConvertRegistryToFile(rgst *aqua.Registry) (*File, error)

type GitHub

type GitHub interface {
	DownloadContents(ctx context.Context, logE *logrus.Entry, owner, repo, filepath string, opts *github.RepositoryContentGetOptions) (io.ReadCloser, *github.Response, error)
	GetReleaseByTag(ctx context.Context, logE *logrus.Entry, owner, repoName, version string) (*github.RepositoryRelease, *github.Response, error)
	DownloadReleaseAsset(ctx context.Context, logE *logrus.Entry, owner, repoName string, assetID int64, httpClient *http.Client) (io.ReadCloser, string, error)
	GetArchiveLink(ctx context.Context, logE *logrus.Entry, owner, repo string, archiveformat github.ArchiveFormat, opts *github.RepositoryContentGetOptions, maxRedirects int) (*url.URL, *github.Response, error)
}

type GitHubContentAPI

type GitHubContentAPI interface {
	DownloadContents(ctx context.Context, logE *logrus.Entry, owner, repo, filepath string, opts *github.RepositoryContentGetOptions) (io.ReadCloser, *github.Response, error)
}

type GitHubContentFileDownloader

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

func NewGitHubContentFileDownloader

func NewGitHubContentFileDownloader(gh GitHubContentAPI, httpDL HTTPDownloader) *GitHubContentFileDownloader

func (*GitHubContentFileDownloader) DownloadGitHubContentFile

func (dl *GitHubContentFileDownloader) DownloadGitHubContentFile(ctx context.Context, logE *logrus.Entry, param *domain.GitHubContentFileParam) (*domain.GitHubContentFile, error)

type GitHubReleaseAPI

type GitHubReleaseAPI interface {
	GetReleaseByTag(ctx context.Context, logE *logrus.Entry, owner, repoName, version string) (*github.RepositoryRelease, *github.Response, error)
	DownloadReleaseAsset(ctx context.Context, logE *logrus.Entry, owner, repoName string, assetID int64, httpClient *http.Client) (io.ReadCloser, string, error)
}

type GitHubReleaseDownloader

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

func NewGitHubReleaseDownloader

func NewGitHubReleaseDownloader(gh GitHubReleaseAPI, httpDL HTTPDownloader) *GitHubReleaseDownloader

func (*GitHubReleaseDownloader) DownloadGitHubRelease

func (dl *GitHubReleaseDownloader) DownloadGitHubRelease(ctx context.Context, logE *logrus.Entry, param *domain.DownloadGitHubReleaseParam) (io.ReadCloser, int64, error)

type HTTPDownloader

type HTTPDownloader interface {
	Download(ctx context.Context, u string) (io.ReadCloser, int64, error)
}

func NewHTTPDownloader

func NewHTTPDownloader(httpClient *http.Client) HTTPDownloader

type Mock

type Mock struct {
	RC   io.ReadCloser
	Code int64
	Err  error
}

func (*Mock) ReadCloser

func (m *Mock) ReadCloser(ctx context.Context, logE *logrus.Entry, file *File) (io.ReadCloser, int64, error)

type MockChecksumDownloader

type MockChecksumDownloader struct {
	Body string
	Code int64
	Err  error
}

func (*MockChecksumDownloader) DownloadChecksum

func (dl *MockChecksumDownloader) DownloadChecksum(ctx context.Context, logE *logrus.Entry, rt *runtime.Runtime, pkg *config.Package) (io.ReadCloser, int64, error)