domain

Documentation

Index

• Variables
• type ChecksumDownloader
• type Checksums
• type ConfigReader
• type CosignInstaller
• 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 MockCosignInstaller
  • func (mock *MockCosignInstaller) InstallCosign(ctx context.Context, logE *logrus.Entry, version string) 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, logE *logrus.Entry, cfg *aqua.Config, cfgFilePath string) (map[string]*registry.Config, error)
• type MockWhichController
  • func (ctrl *MockWhichController) Which(ctx context.Context, logE *logrus.Entry, param *config.Param, exeName string) (*FindResult, error)
• type PackageInstaller
• type ParamInstallPackage
• type ParamInstallPackages
• type PolicyChecker
• type PolicyConfigReader
• type RegistryInstaller
• type RepositoriesService
• type WhichController

Variables

var ErrInvalidPackageType = errors.New("package type is invalid")

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 CosignInstaller

type CosignInstaller interface {
	InstallCosign(ctx context.Context, logE *logrus.Entry, version string) 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 MockCosignInstaller

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

func (*MockCosignInstaller) InstallCosign

func (mock *MockCosignInstaller) InstallCosign(ctx context.Context, logE *logrus.Entry, version string) 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, logE *logrus.Entry, cfg *aqua.Config, cfgFilePath string) (map[string]*registry.Config, error)

type MockWhichController

type MockWhichController struct {
	FindResult *FindResult
	Err        error
}

func (*MockWhichController) Which

func (ctrl *MockWhichController) Which(ctx context.Context, logE *logrus.Entry, param *config.Param, exeName string) (*FindResult, 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
	CosignExePath   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, logE *logrus.Entry, cfg *aqua.Config, cfgFilePath string) (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, logE *logrus.Entry, param *config.Param, exeName string) (*FindResult, error)
}