worker

Documentation

Index

• type Annotator
  • func NewAnnotator(poolSize int, orasClient api.ORASClientInterface, loginURL string, ...) (*Annotator, error)
  • func (a *Annotator) Annotate(ctx context.Context, digests *[]string) (int, error)
• type Executer
• type Purger
  • func NewPurger(poolSize int, acrClient api.AcrCLIClientInterface, loginURL string, ...) *Purger
  • func (p *Purger) PurgeManifests(ctx context.Context, manifests *[]string) (int, error)
  • func (p *Purger) PurgeTags(ctx context.Context, tags *[]acr.TagAttributesBase) (int, error)

Types

type Annotator

type Annotator struct {
	Executer
	// contains filtered or unexported fields
}

Annotator annotates tags or manifests concurrently.

func NewAnnotator

func NewAnnotator(poolSize int, orasClient api.ORASClientInterface, loginURL string, repoName string, artifactType string, annotations []string) (*Annotator, error)

NewAnnotator creates a new Annotator.

func (*Annotator) Annotate

func (a *Annotator) Annotate(ctx context.Context, digests *[]string) (int, error)

AnnotateManifests annotates a list of digests (tags and manifests) concurrently and returns a count of annotated tags & manifests and the first error occurred.

type Executer

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

type Purger

type Purger struct {
	Executer
	// contains filtered or unexported fields
}

Purger purges tags or manifests concurrently.

func NewPurger

func NewPurger(poolSize int, acrClient api.AcrCLIClientInterface, loginURL string, repoName string) *Purger

NewPurger creates a new Purger.

func (*Purger) PurgeManifests

func (p *Purger) PurgeManifests(ctx context.Context, manifests *[]string) (int, error)

PurgeManifests purges a list of manifests concurrently, and returns a count of deleted manifests and the first error occurred.

func (*Purger) PurgeTags

func (p *Purger) PurgeTags(ctx context.Context, tags *[]acr.TagAttributesBase) (int, error)

PurgeTags purges a list of tags concurrently, and returns a count of deleted tags and the first error occurred.