Versions in this module Expand all Collapse all v0 v0.2.1 Oct 9, 2026 v0.2.0 Oct 8, 2026 Changes in this version + var ErrNotFound = errors.New("celerity: not found") + func AllVersions(ctx context.Context, store Store, prefix string, opts ...ListOption) iter.Seq2[ObjectVersion, error] + func Objects(ctx context.Context, store Store, prefix string, opts ...ListOption) iter.Seq2[ObjectInfo, error] + type CopyOption func(*CopyOptions) + type CopyOptions struct + ContentType string + Metadata map[string]string + func (o CopyOptions) Replaces() bool + type CopyResult struct + ETag string + VersionID string + type Cursor string + func (c Cursor) More() bool + type DeleteFailure struct + Code string + Message string + Ref ObjectRef + type DeleteManyResult struct + Deleted []ObjectRef + Failed []DeleteFailure + Unsent []DeleteUnsent + type DeleteOption func(*DeleteOptions) + type DeleteOptions struct + VersionID string + type DeleteUnsent struct + Err error + Ref ObjectRef + type Destination struct + Key string + Store Store + type ExistsOption func(*ExistsOptions) + type ExistsOptions struct + VersionID string + type GetOption func(*GetOptions) + type GetOptions struct + Range Range + VersionID string + type InfoOption func(*InfoOptions) + type InfoOptions struct + VersionID string + type ListOption func(*ListOptions) + type ListOptions struct + Cursor string + Limit int + type Object struct + Body io.ReadCloser + ContentLength int64 + Info ObjectInfo + type ObjectInfo struct + ContentType string + ETag string + Key string + LastModified time.Time + Metadata map[string]string + Size int64 + VersionID string + type ObjectRef struct + Key string + VersionID string + type ObjectVersion struct + Current bool + DeleteMarker bool + ETag string + Key string + LastModified time.Time + Size int64 + VersionID string + type PutOption func(*PutOptions) + type PutOptions struct + ContentType string + Metadata map[string]string + type PutResult struct + ETag string + VersionID string + type Range struct + Length int64 + Start int64 + func (r Range) Whole() bool + type SignAction string + const SignRead + const SignWrite + type SignOption func(*SignOptions) + type SignOptions struct + ContentType string + type SignedURL struct + ExpiresAt time.Time + URL string + type Store interface + Copy func(ctx context.Context, sourceKey string, dest Destination, opts ...CopyOption) (CopyResult, error) + Delete func(ctx context.Context, key string, opts ...DeleteOption) error + DeleteMany func(ctx context.Context, refs []ObjectRef) (DeleteManyResult, error) + Exists func(ctx context.Context, key string, opts ...ExistsOption) (bool, error) + Get func(ctx context.Context, key string, opts ...GetOption) (*Object, error) + Info func(ctx context.Context, key string, opts ...InfoOption) (ObjectInfo, error) + List func(ctx context.Context, prefix string, opts ...ListOption) ([]ObjectInfo, Cursor, error) + Put func(ctx context.Context, key string, body io.Reader, opts ...PutOption) (PutResult, error) + SignedURL func(ctx context.Context, key string, action SignAction, expiry time.Duration, ...) (SignedURL, error) + Versions func(ctx context.Context, prefix string, opts ...ListOption) ([]ObjectVersion, Cursor, error)
Go to main page