worker

package

v0.0.0-...-3198091 Latest Latest Go to latest Published: Jan 13, 2026 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Azure/acr-cli

Links

Documentation ¶

Overview ¶

Package worker provides concurrent workers for container registry operations.

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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, manifests []string) (int, error)

Annotate annotates a list of manifests concurrently and returns a count of annotated images and the first error occurred.

type Executer ¶

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

Executer provides the base functionality for concurrent task execution.

type Purger ¶

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

Purger purges tags or manifests concurrently.

func NewPurger ¶

func NewPurger(repoParallelism int, acrClient api.AcrCLIClientInterface, loginURL string, repoName string, includeLocked bool) *Purger

NewPurger creates a new Purger. Purgers are currently repository specific

func (*Purger) PurgeManifests ¶

func (p *Purger) PurgeManifests(ctx context.Context, manifests []acr.ManifestAttributesBase) (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.

Source Files ¶

View all Source files

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