librarymanager

Aug 10, 2026

Changes in this version

type Downloader

+ func NewDownloaderWithKeychain(keychain authn.Keychain) *Downloader

Jul 1, 2026

Changes in this version

+ const LibrariesBucket

+ const VolumesBucket

type CleanupStrategy

+ Name func() string

type Database

+ func (db *Database) AddLibrary(libraryID, packageName string, sizeBytes int64) error

+ func (db *Database) GetLibrary(libraryID string) (LibraryInfo, bool, error)

+ func (db *Database) RemoveLibrary(libraryID string) error

+ func (db *Database) Snapshot() (libraryevents.Snapshot, error)

type DelayedCleanupStrategy

+ func (s *DelayedCleanupStrategy) Name() string

type ImmediateCleanupStrategy

+ func (s *ImmediateCleanupStrategy) Name() string

type Library

+ func (l *Library) Name() string

+ func (l *Library) Registry() string

+ type LibraryInfo struct

+ Package string

+ SizeBytes int64

+ VolumeCount int

type LibraryManagerOption

+ func WithEventListener(l libraryevents.Listener) LibraryManagerOption

Feb 3, 2026

Changes in this version

+ type CleanupFunc func(libraryID string) error

+ type CleanupStrategy interface

+ ScheduleCleanup func(libraryID string, cleanupFunc CleanupFunc)

+ Stop func()

+ type DelayedCleanupStrategy struct

+ func NewDelayedCleanupStrategy(delay time.Duration) *DelayedCleanupStrategy

+ func (s *DelayedCleanupStrategy) ScheduleCleanup(libraryID string, cleanupFunc CleanupFunc)

+ func (s *DelayedCleanupStrategy) Stop()

+ type ImmediateCleanupStrategy struct

+ func NewImmediateCleanupStrategy() *ImmediateCleanupStrategy

+ func (s *ImmediateCleanupStrategy) ScheduleCleanup(libraryID string, cleanupFunc CleanupFunc)

+ func (s *ImmediateCleanupStrategy) Stop()

type LibraryManager

+ func (lm *LibraryManager) HasVolume(volumeID string) (bool, error)

type LibraryManagerOption

+ func WithCleanupStrategy(s CleanupStrategy) LibraryManagerOption

Jan 13, 2026

Changes in this version

+ const DatabaseDirectory

+ const DatabaseFileName

+ const DefaultImageCacheTTL

+ const LibraryMappingBucket

+ const ScratchDirectory

+ const StoreDirectory

+ const VolumeMappingBucket

+ var ErrItemNotFound = errors.New("item not found in store")

+ type ArchiveExtractor struct

+ func NewArchiveExtractor(afs afero.Afero, src string, dst string) (*ArchiveExtractor, error)

+ func (fp *ArchiveExtractor) Extract(ctx context.Context, reader io.Reader) error

+ type Database struct

+ func NewDatabase(basePath string) (*Database, error)

+ func (db *Database) Close() error

+ func (db *Database) GetLibraryForVolume(volumeID string) (string, error)

+ func (db *Database) GetVolumeCount(libraryID string) (int, error)

+ func (db *Database) LinkVolume(libraryID string, volumeID string) error

+ func (db *Database) UnlinkVolume(libraryID string, volumeID string) error

+ type Downloader struct

+ func NewDownloader() *Downloader

+ func NewDownloaderWithRoundTripper(roundTripper http.RoundTripper) *Downloader

+ func (d *Downloader) Download(ctx context.Context, afs afero.Afero, image string, src string, dst string) error

+ func (d *Downloader) FetchDigest(ctx context.Context, image string) (string, error)

+ type ImageCache struct

+ func NewImageCache(d *Downloader, ttl time.Duration) *ImageCache

+ func (ic *ImageCache) FetchDigest(ctx context.Context, image string, pull bool) (string, error)

+ type Library struct

+ func NewLibrary(name string, registry string, version string, path string, pull bool) (*Library, error)

+ func (l *Library) Image() string

+ func (l *Library) Pull() bool

+ func (l *Library) Source() string

+ type LibraryManager struct

+ func NewLibraryManager(basePath string, opts ...LibraryManagerOption) (*LibraryManager, error)

+ func (lm *LibraryManager) GetLibraryForVolume(ctx context.Context, volumeID string, lib *Library) (string, error)

+ func (lm *LibraryManager) RemoveVolume(ctx context.Context, volumeID string) error

+ func (lm *LibraryManager) Stop() error

+ type LibraryManagerOption func(*LibraryManager)

+ func WithDownloader(d *Downloader) LibraryManagerOption

+ func WithFilesystem(fs afero.Afero) LibraryManagerOption

+ type Locker struct

+ func NewLocker() *Locker

+ func (l *Locker) Lock(id string)

+ func (l *Locker) Unlock(id string)

+ type Store struct

+ func NewStore(afs afero.Afero, basePath string) (*Store, error)

+ func (s *Store) Add(id string, src string) (string, error)

+ func (s *Store) Exists(id string) (bool, error)

+ func (s *Store) Get(id string) (string, error)

+ func (s *Store) Remove(id string) error