tracker

Documentation

Index

• func SetVerifiedPublisherFlag(svc *Services, r *hub.Repository, mdFile string) error
• type DBErrorsCollector
  • func NewDBErrorsCollector(ctx context.Context, repoManager hub.RepositoryManager, ...) *DBErrorsCollector
  • func (c *DBErrorsCollector) Append(repositoryID string, err error)
  • func (c *DBErrorsCollector) Flush()
• type ErrorsCollector
• type ErrorsCollectorMock
  • func (m *ErrorsCollectorMock) Append(repositoryID string, err error)
  • func (m *ErrorsCollectorMock) Flush()
• type HTTPGetter
• type HTTPGetterMock
  • func (m *HTTPGetterMock) Get(url string) (*http.Response, error)
• type New
• type Services
• type Tracker

Functions

func SetVerifiedPublisherFlag

func SetVerifiedPublisherFlag(svc *Services, r *hub.Repository, mdFile string) error

SetVerifiedPublisherFlag sets the repository verified publisher flag for the repository provided when needed.

Types

type DBErrorsCollector

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

DBErrorsCollector 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 NewDBErrorsCollector

func NewDBErrorsCollector(
	ctx context.Context,
	repoManager hub.RepositoryManager,
	repos []*hub.Repository,
) *DBErrorsCollector

NewDBErrorsCollector creates a new DBErrorsCollector instance.

func (*DBErrorsCollector) Append

func (c *DBErrorsCollector) Append(repositoryID string, err error)

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

func (*DBErrorsCollector) Flush

func (c *DBErrorsCollector) Flush()

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

type ErrorsCollector

type ErrorsCollector interface {
	Append(repositoryID string, err error)
	Flush()
}

ErrorsCollector interface defines the methods that an errors collector implementation should provide.

type ErrorsCollectorMock

type ErrorsCollectorMock struct {
	mock.Mock
}

ErrorsCollectorMock is mock ErrorsCollector implementation.

func (*ErrorsCollectorMock) Append

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

Append implements the ErrorsCollector interface.

func (*ErrorsCollectorMock) Flush

func (m *ErrorsCollectorMock) Flush()

Flush implements the ErrorsCollector interface.

type HTTPGetter

type HTTPGetter interface {
	Get(url string) (*http.Response, error)
}

HTTPGetter defines the methods an HTTPGetter implementation must provide.

type HTTPGetterMock

type HTTPGetterMock struct {
	mock.Mock
}

HTTPGetterMock is a mock HTTPGetter implementation.

func (*HTTPGetterMock) Get

func (m *HTTPGetterMock) Get(url string) (*http.Response, error)

Get implements the HTTPGetter interface.

type New

type New func(svc *Services, r *hub.Repository, opts ...func(t Tracker)) Tracker

New represents a function that creates new repository trackers. Each tracker is in charge of processing a given repository, and based on the concurrency configured, the tracker cmd may run multiple Tracker instances concurrently.

type Services

type Services struct {
	Ctx context.Context
	Cfg *viper.Viper
	Rc  hub.RepositoryCloner
	Rm  hub.RepositoryManager
	Pm  hub.PackageManager
	Il  hub.HelmIndexLoader
	Is  img.Store
	Ec  ErrorsCollector
	Hg  HTTPGetter
}

Services represents a set of services that must be provided to a Tracker instance so that it can perform its tasks.

type Tracker

type Tracker interface {
	Track(wg *sync.WaitGroup) error
}

Tracker is the interface that wraps the Track method, used to ask a tracker to start running and processing packages in a given repository. A call to wg.Done() is expected once the tracker has completed.