repo

package
v0.0.0-...-3dc0db1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 18, 2023 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// DefaultBranch represents the branch used by default when cloning a
	// repository if no branch has been configured on it.
	DefaultBranch = "master"
)
View Source
const (
	// MetadataLayerMediaType represents the media type used for the layer that
	// contains the repository metadata in an OCI image.
	MetadataLayerMediaType = "application/vnd.cncf.artifacthub.repository-metadata.layer.v1.yaml"
)

Variables

View Source
var (

	// ErrInvalidMetadata indicates that the repository metadata is not valid.
	ErrInvalidMetadata = errors.New("invalid metadata")

	// ErrMetadataNotFound indicates that the repository metadata was not found.
	ErrMetadataNotFound = errors.New("metadata not found")

	// ErrSchemeNotSupported error indicates that the scheme used in the
	// repository url is not supported.
	ErrSchemeNotSupported = errors.New("scheme not supported")

	// GitRepoURLRE is a regexp used to validate and parse an http based git
	// repository URL.
	GitRepoURLRE = regexp.MustCompile(`^(https:\/\/([A-Za-z0-9_.-]+)\/[A-Za-z0-9_.-]+\/[A-Za-z0-9_.-]+)\/?(.*)$`)
)

Functions

func GetBranch

func GetBranch(r *hub.Repository) string

GetBranch returns the branch configured in the repository or the default one if none was provided.

func SchemeIsHTTP

func SchemeIsHTTP(u *url.URL) bool

SchemeIsHTTP is a helper that checks if the scheme of the url provided is http or https.

func SchemeIsOCI

func SchemeIsOCI(u *url.URL) bool

SchemeIsOCI is a helper that checks if the scheme of the url provided is oci.

func WithHelmIndexLoader

func WithHelmIndexLoader(l hub.HelmIndexLoader) func(m *Manager)

WithHelmIndexLoader allows providing a specific HelmIndexLoader implementation for a Manager instance.

func WithOCIPuller

func WithOCIPuller(p hub.OCIPuller) func(m *Manager)

WithOCIPuller allows providing a specific OCIPuller implementation for a Manager instance.

func WithOCITagsGetter

func WithOCITagsGetter(tg hub.OCITagsGetter) func(m *Manager)

WithOCITagsGetter allows providing a specific OCITagsGetter implementation for a Manager instance.

Types

type Cloner

type Cloner struct{}

Cloner is a hub.RepositoryCloner implementation.

func (*Cloner) CloneRepository

func (c *Cloner) CloneRepository(ctx context.Context, r *hub.Repository) (string, string, error)

CloneRepository implements the hub.RepositoryCloner interface.

type ClonerMock

type ClonerMock struct {
	mock.Mock
}

ClonerMock is a mock implementation of the RepositoryCloner interface.

func (*ClonerMock) CloneRepository

func (m *ClonerMock) CloneRepository(ctx context.Context, r *hub.Repository) (string, string, error)

CloneRepository implements the RepositoryCloner interface.

type ErrorsCollector

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

ErrorsCollector is in charge of collecting errors that happen while repositories are being processed. Once all the processing is done, the collected errors can be flushed, which will store them in the database.

func NewErrorsCollector

func NewErrorsCollector(repoManager hub.RepositoryManager, kind ErrorsCollectorKind) *ErrorsCollector

NewErrorsCollector creates a new ErrorsCollector instance.

func (*ErrorsCollector) Append

func (c *ErrorsCollector) Append(repositoryID string, err string)

Append adds the error provided to the repository's list of errors.

func (*ErrorsCollector) Flush

func (c *ErrorsCollector) Flush()

Flush aggregates all errors collected per repository as a single text and stores it in the database.

func (*ErrorsCollector) Init

func (c *ErrorsCollector) Init(repositoryID string)

Init initializes the list of errors for the repository provided. This will allow the errors collector to reset the errors from a previous tracker or scanner run when no errors have been collected from the current run.

type ErrorsCollectorKind

type ErrorsCollectorKind int64

ErrorsCollectorKind represents the kind of a given errors collector.

const (
	// Scanner represents an errors collector for a scanner instance.
	Scanner ErrorsCollectorKind = 0

	// Tracker represents an errors collector for a tracker instance.
	Tracker ErrorsCollectorKind = 1
)

type ErrorsCollectorMock

type ErrorsCollectorMock struct {
	mock.Mock
}

ErrorsCollectorMock is mock ErrorsCollector implementation.

func (*ErrorsCollectorMock) Append

func (m *ErrorsCollectorMock) Append(repositoryID string, err string)

Append implements the ErrorsCollector interface.

func (*ErrorsCollectorMock) Flush

func (m *ErrorsCollectorMock) Flush()

Flush implements the ErrorsCollector interface.

func (*ErrorsCollectorMock) Init

func (m *ErrorsCollectorMock) Init(repositoryID string)

Init implements the ErrorsCollector interface.

type HelmIndexLoader

type HelmIndexLoader struct{}

HelmIndexLoader provides a mechanism to load a Helm repository index file, verifying it is valid.

func (*HelmIndexLoader) LoadIndex

LoadIndex downloads and parses the index file of the provided repository.

type HelmIndexLoaderMock

type HelmIndexLoaderMock struct {
	mock.Mock
}

HelmIndexLoaderMock is a mock implementation of the HelmIndexLoader interface.

func (*HelmIndexLoaderMock) LoadIndex

LoadIndex implements the HelmIndexLoader interface.

type Manager

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

Manager provides an API to manage repositories.

func NewManager

func NewManager(
	cfg *viper.Viper,
	db hub.DB,
	az hub.Authorizer,
	hc hub.HTTPClient,
	opts ...func(m *Manager),
) *Manager

NewManager creates a new Manager instance.

func (*Manager) Add

func (m *Manager) Add(ctx context.Context, orgName string, r *hub.Repository) error

Add adds the provided repository to the database.

func (*Manager) CheckAvailability

func (m *Manager) CheckAvailability(ctx context.Context, resourceKind, value string) (bool, error)

CheckAvailability checks the availability of a given value for the provided resource kind.

func (*Manager) ClaimOwnership

func (m *Manager) ClaimOwnership(ctx context.Context, repoName, orgName string) error

ClaimOwnership allows a user to claim the ownership of a given repository. The repository will be transferred to the destination entity requested if the user is listed as one of the owners in the repository metadata file.

func (*Manager) Delete

func (m *Manager) Delete(ctx context.Context, name string) error

Delete deletes the provided repository from the database.

func (*Manager) GetByID

func (m *Manager) GetByID(
	ctx context.Context,
	repositoryID string,
	includeCredentials bool,
) (*hub.Repository, error)

GetByID returns the repository identified by the id provided.

func (*Manager) GetByName

func (m *Manager) GetByName(
	ctx context.Context,
	name string,
	includeCredentials bool,
) (*hub.Repository, error)

GetByName returns the repository identified by the name provided.

func (*Manager) GetMetadata

func (m *Manager) GetMetadata(r *hub.Repository, basePath string) (*hub.RepositoryMetadata, error)

GetMetadata reads and parses the metadata file of the repository provided. When needed, the repository must be previously cloned and the path pointing to the location of the packages must be provided (basePath).

func (*Manager) GetPackagesDigest

func (m *Manager) GetPackagesDigest(
	ctx context.Context,
	repositoryID string,
) (map[string]string, error)

GetPackagesDigest returns the digests for all packages in the repository identified by the id provided.

func (*Manager) GetRemoteDigest

func (m *Manager) GetRemoteDigest(ctx context.Context, r *hub.Repository) (string, error)

GetRemoteDigest gets the repository's digest available in the remote.

func (*Manager) Search

Search searches for repositories in the database that the criteria defined in the input provided.

func (*Manager) SearchJSON

func (m *Manager) SearchJSON(
	ctx context.Context,
	input *hub.SearchRepositoryInput,
) (*hub.JSONQueryResult, error)

SearchJSON returns a json object with the search results produced by the input provided. The json object is built by the database.

func (*Manager) SetLastScanningResults

func (m *Manager) SetLastScanningResults(ctx context.Context, repositoryID, errs string) error

SetLastScanningResults updates the timestamp and errors of the last scanning of the provided repository in the database.

func (*Manager) SetLastTrackingResults

func (m *Manager) SetLastTrackingResults(ctx context.Context, repositoryID, errs string) error

SetLastTrackingResults updates the timestamp and errors of the last tracking of the provided repository in the database.

func (*Manager) SetVerifiedPublisher

func (m *Manager) SetVerifiedPublisher(ctx context.Context, repositoryID string, verified bool) error

SetVerifiedPublisher updates the verified publisher flag of the provided repository in the database.

func (*Manager) Transfer

func (m *Manager) Transfer(ctx context.Context, repoName, orgName string, ownershipClaim bool) error

Transfer transfers the provided repository to a different owner. A user owned repo can be transferred to an organization the requesting user belongs to. An org owned repo can be transfer to the requesting user, provided the user belongs to the owning org, or to a different organization the user belongs to.

func (*Manager) Update

func (m *Manager) Update(ctx context.Context, r *hub.Repository) error

Update updates the provided repository in the database.

func (*Manager) UpdateDigest

func (m *Manager) UpdateDigest(ctx context.Context, repositoryID, digest string) error

UpdateDigest updates the digest of the provided repository in the database.

type ManagerMock

type ManagerMock struct {
	mock.Mock
}

ManagerMock is a mock implementation of the RepositoryManager interface.

func (*ManagerMock) Add

func (m *ManagerMock) Add(ctx context.Context, orgName string, r *hub.Repository) error

Add implements the RepositoryManager interface.

func (*ManagerMock) CheckAvailability

func (m *ManagerMock) CheckAvailability(ctx context.Context, resourceKind, value string) (bool, error)

CheckAvailability implements the RepositoryManager interface.

func (*ManagerMock) ClaimOwnership

func (m *ManagerMock) ClaimOwnership(ctx context.Context, name, orgName string) error

ClaimOwnership implements the RepositoryManager interface.

func (*ManagerMock) Delete

func (m *ManagerMock) Delete(ctx context.Context, name string) error

Delete implements the RepositoryManager interface.

func (*ManagerMock) GetByID

func (m *ManagerMock) GetByID(
	ctx context.Context,
	repositoryID string,
	includeCredentials bool,
) (*hub.Repository, error)

GetByID implements the RepositoryManager interface.

func (*ManagerMock) GetByName

func (m *ManagerMock) GetByName(
	ctx context.Context,
	name string,
	includeCredentials bool,
) (*hub.Repository, error)

GetByName implements the RepositoryManager interface.

func (*ManagerMock) GetMetadata

func (m *ManagerMock) GetMetadata(r *hub.Repository, basePath string) (*hub.RepositoryMetadata, error)

GetMetadata implements the RepositoryManager interface.

func (*ManagerMock) GetPackagesDigest

func (m *ManagerMock) GetPackagesDigest(
	ctx context.Context,
	repositoryID string,
) (map[string]string, error)

GetPackagesDigest implements the RepositoryManager interface.

func (*ManagerMock) GetRemoteDigest

func (m *ManagerMock) GetRemoteDigest(ctx context.Context, r *hub.Repository) (string, error)

GetRemoteDigest implements the RepositoryManager interface.

func (*ManagerMock) Search

Search implements the RepositoryManager interface.

func (*ManagerMock) SearchJSON

func (m *ManagerMock) SearchJSON(
	ctx context.Context,
	input *hub.SearchRepositoryInput,
) (*hub.JSONQueryResult, error)

SearchJSON implements the RepositoryManager interface.

func (*ManagerMock) SetLastScanningResults

func (m *ManagerMock) SetLastScanningResults(ctx context.Context, repositoryID, errs string) error

SetLastScanningResults implements the RepositoryManager interface.

func (*ManagerMock) SetLastTrackingResults

func (m *ManagerMock) SetLastTrackingResults(ctx context.Context, repositoryID, errs string) error

SetLastTrackingResults implements the RepositoryManager interface.

func (*ManagerMock) SetVerifiedPublisher

func (m *ManagerMock) SetVerifiedPublisher(ctx context.Context, repositoryID string, verified bool) error

SetVerifiedPublisher implements the RepositoryManager interface.

func (*ManagerMock) Transfer

func (m *ManagerMock) Transfer(ctx context.Context, name, orgName string, ownershipClaim bool) error

Transfer implements the RepositoryManager interface.

func (*ManagerMock) Update

func (m *ManagerMock) Update(ctx context.Context, r *hub.Repository) error

Update implements the RepositoryManager interface.

func (*ManagerMock) UpdateDigest

func (m *ManagerMock) UpdateDigest(ctx context.Context, repositoryID, digest string) error

UpdateDigest implements the RepositoryManager interface.

type OLMOCIExporter

type OLMOCIExporter struct{}

OLMOCIExporter provides a mechanism to export the packages available in an OLM repository stored in an OCI registry.

func (*OLMOCIExporter) ExportRepository

func (e *OLMOCIExporter) ExportRepository(ctx context.Context, r *hub.Repository) (string, error)

ExportRepository exports the packages available in a repository stored in a OCI registry using the appregistry manifest format. It returns the temporary directory where the packages will be stored. It's the caller's responsibility to delete it when done.

type OLMOCIExporterMock

type OLMOCIExporterMock struct {
	mock.Mock
}

OLMOCIExporterMock is a mock implementation of the OLMOCIExporter interface.

func (*OLMOCIExporterMock) ExportRepository

func (m *OLMOCIExporterMock) ExportRepository(ctx context.Context, r *hub.Repository) (string, error)

ExportRepository implements the OLMOCIExporter interface.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL