storage

May 22, 2026

Changes in this version

type Blob

+ func (b *Blob) ListPrefix(ctx context.Context, prefix string) ([]ObjectInfo, error)

type Filesystem

+ func (fs *Filesystem) ListPrefix(ctx context.Context, prefix string) ([]ObjectInfo, error)

+ type ObjectInfo struct

+ ModTime time.Time

+ Path string

+ Size int64

May 2, 2026

Changes in this version

+ var ErrNotFound = errors.New("artifact not found")

+ var ErrSignedURLUnsupported = errors.New("signed URLs not supported by storage backend")

+ func ArtifactPath(ecosystem, namespace, name, version, filename string) string

+ type Blob struct

+ func OpenBucket(ctx context.Context, urlStr string) (*Blob, error)

+ func (b *Blob) Close() error

+ func (b *Blob) Delete(ctx context.Context, path string) error

+ func (b *Blob) Exists(ctx context.Context, path string) (bool, error)

+ func (b *Blob) Open(ctx context.Context, path string) (io.ReadCloser, error)

+ func (b *Blob) SignedURL(ctx context.Context, path string, expiry time.Duration) (string, error)

+ func (b *Blob) Size(ctx context.Context, path string) (int64, error)

+ func (b *Blob) Store(ctx context.Context, path string, r io.Reader) (int64, string, error)

+ func (b *Blob) URL() string

+ func (b *Blob) UsedSpace(ctx context.Context) (int64, error)

+ type Filesystem struct

+ func NewFilesystem(root string) (*Filesystem, error)

+ func (fs *Filesystem) Close() error

+ func (fs *Filesystem) Delete(ctx context.Context, path string) error

+ func (fs *Filesystem) Exists(ctx context.Context, path string) (bool, error)

+ func (fs *Filesystem) FullPath(path string) (string, error)

+ func (fs *Filesystem) Open(ctx context.Context, path string) (io.ReadCloser, error)

+ func (fs *Filesystem) Root() string

+ func (fs *Filesystem) SignedURL(_ context.Context, _ string, _ time.Duration) (string, error)

+ func (fs *Filesystem) Size(ctx context.Context, path string) (int64, error)

+ func (fs *Filesystem) Store(ctx context.Context, path string, r io.Reader) (int64, string, error)

+ func (fs *Filesystem) URL() string

+ func (fs *Filesystem) UsedSpace(ctx context.Context) (int64, error)

+ type HashingReader struct

+ func NewHashingReader(r io.Reader) *HashingReader

+ func (hr *HashingReader) Read(p []byte) (n int, err error)

+ func (hr *HashingReader) Size() int64

+ func (hr *HashingReader) Sum() string

+ type Storage interface

+ Close func() error

+ Delete func(ctx context.Context, path string) error

+ Exists func(ctx context.Context, path string) (bool, error)

+ Open func(ctx context.Context, path string) (io.ReadCloser, error)

+ SignedURL func(ctx context.Context, path string, expiry time.Duration) (string, error)

+ Size func(ctx context.Context, path string) (int64, error)

+ Store func(ctx context.Context, path string, r io.Reader) (size int64, hash string, err error)

+ URL func() string

+ UsedSpace func(ctx context.Context) (int64, error)