domain

Documentation

Index

• type ChecksumDownloader
• type Checksums
• type ConfigReader
• type DownloadGitHubReleaseParam
• type FindResult
• type GitHubContentFile
• type GitHubContentFileDownloader
• type GitHubContentFileParam
• type GitHubReleaseDownloader
• type Linker
  • func NewMockLinker(fs afero.Fs) Linker
• type MockChecksumDownloader
  • func (chkDL *MockChecksumDownloader) DownloadChecksum(ctx context.Context, logE *logrus.Entry, rt *runtime.Runtime, ...) (io.ReadCloser, int64, error)
• type MockConfigReader
  • func (reader *MockConfigReader) Read(configFilePath string, cfg *aqua.Config) error
• type MockPackageDownloader
  • func (dl *MockPackageDownloader) GetReadCloser(ctx context.Context, pkg *config.Package, assetName string, logE *logrus.Entry, ...) (io.ReadCloser, int64, error)
• type MockPolicyChecker
  • func (pc *MockPolicyChecker) ValidatePackage(param *policy.ParamValidatePackage) error
• type MockPolicyConfigReader
  • func (reader *MockPolicyConfigReader) Read(files []string) ([]*policy.Config, error)
• type MockRegistryInstaller
  • func (inst *MockRegistryInstaller) InstallRegistries(ctx context.Context, cfg *aqua.Config, cfgFilePath string, logE *logrus.Entry) (map[string]*registry.Config, error)
• type MockWhichController
  • func (ctrl *MockWhichController) Which(ctx context.Context, param *config.Param, exeName string, logE *logrus.Entry) (*FindResult, error)
• type PackageDownloader
• type PackageInstaller
• type ParamInstallPackage
• type ParamInstallPackages
• type PolicyChecker
• type PolicyConfigReader
• type RegistryInstaller
• type RepositoriesService
• type WhichController

Types

type ChecksumDownloader

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

type Checksums

type Checksums interface {
	Get(key string) string
	Set(key, value string)
	ReadFile(fs afero.Fs, p string) error
	UpdateFile(fs afero.Fs, p string) error
}

type ConfigReader

type ConfigReader interface {
	Read(configFilePath string, cfg *aqua.Config) error
}

type DownloadGitHubReleaseParam

type DownloadGitHubReleaseParam struct {
	RepoOwner string
	RepoName  string
	Version   string
	Asset     string
}

type FindResult

type FindResult struct {
	Package        *config.Package
	File           *registry.File
	Config         *aqua.Config
	ExePath        string
	ConfigFilePath string
	EnableChecksum bool
}

type GitHubContentFile

type GitHubContentFile struct {
	ReadCloser io.ReadCloser
	String     string
}

type GitHubContentFileDownloader

type GitHubContentFileDownloader interface {
	DownloadGitHubContentFile(ctx context.Context, logE *logrus.Entry, param *GitHubContentFileParam) (*GitHubContentFile, error)
}

type GitHubContentFileParam

type GitHubContentFileParam struct {
	RepoOwner string
	RepoName  string
	Ref       string
	Path      string
}

type GitHubReleaseDownloader

type GitHubReleaseDownloader interface {
	DownloadGitHubRelease(ctx context.Context, logE *logrus.Entry, param *DownloadGitHubReleaseParam) (io.ReadCloser, int64, error)
}

type Linker

type Linker interface {
	Lstat(s string) (os.FileInfo, error)
	Symlink(dest, src string) error
	Readlink(src string) (string, error)
}

func NewMockLinker

func NewMockLinker(fs afero.Fs) Linker

type MockChecksumDownloader

type MockChecksumDownloader struct {
	Body string
	Code int64
	Err  error
}

func (*MockChecksumDownloader) DownloadChecksum

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

type MockConfigReader

type MockConfigReader struct {
	Cfg *aqua.Config
	Err error
}

func (*MockConfigReader) Read

func (reader *MockConfigReader) Read(configFilePath string, cfg *aqua.Config) error

type MockPackageDownloader

type MockPackageDownloader struct {
	Body string
	Code int64
	Err  error
}

func (*MockPackageDownloader) GetReadCloser

func (dl *MockPackageDownloader) GetReadCloser(ctx context.Context, pkg *config.Package, assetName string, logE *logrus.Entry, rt *runtime.Runtime) (io.ReadCloser, int64, error)

type MockPolicyChecker

type MockPolicyChecker struct {
	Err error
}

func (*MockPolicyChecker) ValidatePackage

func (pc *MockPolicyChecker) ValidatePackage(param *policy.ParamValidatePackage) error

type MockPolicyConfigReader

type MockPolicyConfigReader struct {
	Cfgs []*policy.Config
	Err  error
}

func (*MockPolicyConfigReader) Read

func (reader *MockPolicyConfigReader) Read(files []string) ([]*policy.Config, error)

type MockRegistryInstaller

type MockRegistryInstaller struct {
	M   map[string]*registry.Config
	Err error
}

func (*MockRegistryInstaller) InstallRegistries

func (inst *MockRegistryInstaller) InstallRegistries(ctx context.Context, cfg *aqua.Config, cfgFilePath string, logE *logrus.Entry) (map[string]*registry.Config, error)

type MockWhichController

type MockWhichController struct {
	FindResult *FindResult
	Err        error
}

func (*MockWhichController) Which

func (ctrl *MockWhichController) Which(ctx context.Context, param *config.Param, exeName string, logE *logrus.Entry) (*FindResult, error)

type PackageDownloader

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

type PackageInstaller

type PackageInstaller interface {
	InstallPackage(ctx context.Context, logE *logrus.Entry, param *ParamInstallPackage) error
	InstallPackages(ctx context.Context, logE *logrus.Entry, param *ParamInstallPackages) error
	InstallProxy(ctx context.Context, logE *logrus.Entry) error
}

type ParamInstallPackage

type ParamInstallPackage struct {
	Pkg             *config.Package
	Checksums       *checksum.Checksums
	RequireChecksum bool
	PolicyConfigs   []*policy.Config
	ConfigFileDir   string
}

type ParamInstallPackages

type ParamInstallPackages struct {
	ConfigFilePath string
	Config         *aqua.Config
	Registries     map[string]*registry.Config
	Tags           map[string]struct{}
	ExcludedTags   map[string]struct{}
	SkipLink       bool
	PolicyConfigs  []*policy.Config
}

type PolicyChecker

type PolicyChecker interface {
	ValidatePackage(param *policy.ParamValidatePackage) error
}

type PolicyConfigReader

type PolicyConfigReader interface {
	Read([]string) ([]*policy.Config, error)
}

type RegistryInstaller

type RegistryInstaller interface {
	InstallRegistries(ctx context.Context, cfg *aqua.Config, cfgFilePath string, logE *logrus.Entry) (map[string]*registry.Config, error)
}

type RepositoriesService

type RepositoriesService interface {
	GetArchiveLink(ctx context.Context, owner, repo string, archiveformat github.ArchiveFormat, opts *github.RepositoryContentGetOptions, followRedirects bool) (*url.URL, *github.Response, error)
	GetReleaseByTag(ctx context.Context, owner, repoName, version string) (*github.RepositoryRelease, *github.Response, error)
	DownloadReleaseAsset(ctx context.Context, owner, repoName string, assetID int64, httpClient *http.Client) (io.ReadCloser, string, error)
	GetContents(ctx context.Context, repoOwner, repoName, path string, opt *github.RepositoryContentGetOptions) (*github.RepositoryContent, []*github.RepositoryContent, *github.Response, error)
}

type WhichController

type WhichController interface {
	Which(ctx context.Context, param *config.Param, exeName string, logE *logrus.Entry) (*FindResult, error)
}