artifactcache

type Maintenance ¶ added in v0.9.0

type Maintenance struct {
	RemovedFiles int   `json:"removed_files"`
	RemovedBytes int64 `json:"removed_bytes"`
}

func Maintain(ctx context.Context, root string, policy Policy, try bool) (Maintenance, error)

type Options ¶

type Options struct {
	// Client is a trusted integration hook, primarily for network policy/tests.
	// Nil selects a client with a fifteen-minute timeout. HTTPS remains required.
	Client *http.Client
	// PreferredSource selects the first URL to try. -1 uses the canonical URL.
	// Remaining trusted URLs are tried in catalog order after it fails.
	PreferredSource int
	// OnProgress may stop acquisition by returning an error.
	OnProgress func(Progress) error
}

type Policy ¶ added in v0.9.0

type Policy struct {
	MaxIdleAge time.Duration
	MaxBytes   int64
}

Policy is opt-in. Zero disables the corresponding eviction limit. MaxBytes counts verified archive files, not locks or temporary bundles.

type Progress ¶

type Progress struct {
	Phase         string
	ReceivedBytes int64
	TotalBytes    int64
}

Progress reports absolute byte counts. Phase is checking, downloading or verifying. Cache validation performs no network request.

type Result ¶

type Result struct {
	Path      string
	FromCache bool
}

func Acquire(ctx context.Context, root string, spec Spec, options Options) (Result, error)

type Session ¶ added in v0.9.0

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

Session owns an exclusive OS lease until Close. Consumers must keep it open through their last archive read. Methods are used sequentially by the owner. A session is not an authorization boundary; root belongs to the trusted host.

func OpenSession(ctx context.Context, root string, options SessionOptions) (*Session, error)

func (s *Session) Acquire(ctx context.Context, spec Spec, options Options) (Result, error)

func (s *Session) Close() error

func (s *Session) Path(spec Spec) (string, error)

func (s *Session) Prune(ctx context.Context, policy Policy) (Maintenance, error)

func (s *Session) Touch(spec Spec) error

func (s *Session) Verify(ctx context.Context, spec Spec) error

type SessionOptions ¶ added in v0.9.0

type SessionOptions struct {
	Try    bool
	OnWait func() error
}

type Spec ¶

type Spec struct {
	URL       string
	Mirrors   []string
	SHA256    string
	SizeBytes int64
}

Spec describes exact original publisher bytes selected by the trusted host.