drive

Oct 6, 2026

Changes in this version

+ func NoneMatch(ifNoneMatch, etag string) bool

Sep 30, 2026

Changes in this version

+ const ModeAllow

+ const ModeDeny

+ const VerbCreate

+ const VerbDelete

+ const VerbMoveIn

+ const VerbMoveOut

+ const VerbWrite

+ func PolicyVerbs() []string

type Collection

+ Policy Policy

type DeleteOpts

+ IfNoneMatch string

+ type Policy map[string]map[string]string

+ func ParsePolicy(raw string) (Policy, error)

+ func (p Policy) Allows(path, verb string) bool

+ func (p Policy) String() string

+ func (p Policy) Validate() error

+ type RangeReader interface

+ GetRange func(ctx context.Context, key string, off, length int64) (io.ReadCloser, error)

type Store

+ func (s *Store) SetCollectionPolicy(ctx context.Context, tenant, name string, p Policy) (Collection, error)

Sep 16, 2026

Changes in this version

+ const EventResourceCreated

+ const EventResourceDeleted

+ const EventResourceMoved

+ const EventResourceUpdated

+ const KindDir

+ const KindFile

+ const MaxPathBytes

+ const MaxPathSegments

+ const MaxSegmentBytes

+ const StatusActive

+ const StatusDisabled

+ var ErrBadPath = errors.New("drive: invalid path")

+ var ErrCycle = errors.New("drive: destination is the source or inside it")

+ var ErrDisabled = errors.New("drive: account disabled")

+ var ErrExists = errors.New("drive: resource exists")

+ var ErrIsDirectory = errors.New("drive: is a directory")

+ var ErrNoParent = errors.New("drive: parent directory does not exist")

+ var ErrNotDirectory = errors.New("drive: not a directory")

+ var ErrNotEmpty = errors.New("drive: collection is not empty")

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

+ var ErrPrecondition = errors.New("drive: precondition failed")

+ var ErrQuota = errors.New("drive: collection quota exceeded")

+ var ErrSizeMismatch = errors.New("drive: body size does not match declared size")

+ var ErrTooLarge = errors.New("drive: file too large")

+ var ErrUsernameTaken = errors.New("drive: username belongs to another tenant")

+ func BaseOf(p string) string

+ func DefaultContentType(p string) string

+ func Depth(p string) int

+ func ETagOf(b []byte) string

+ func IdempotencyKey(m Mutation) string

+ func IsInside(p, dir string) bool

+ func JoinPath(parent, seg string) string

+ func LikePrefix(p string) string

+ func NewResourceID() string

+ func NormalizePath(p string) (string, error)

+ func NormalizeUsername(u string) string

+ func ParentOf(p string) string

+ func Register(name string, c Constructor)

+ func RegisterObjects(name string, c ObjectsConstructor)

+ func ValidCollectionName(name string) bool

+ func ValidKeySegment(seg string) bool

+ type Account struct

+ CollectionID string

+ CreatedAt time.Time

+ PwHash string

+ Status string

+ Tenant string

+ UpdatedAt time.Time

+ Username string

+ type Collection struct

+ BytesUsed int64

+ CreatedAt time.Time

+ ID string

+ Name string

+ ResourceCount int64

+ SyncToken int64

+ Tenant string

+ UpdatedAt time.Time

+ type Config struct

+ DBPath string

+ Objects ObjectStore

+ type Constructor func(Config) (*Store, error)

+ type DeleteOpts struct

+ IfMatch string

+ type Limits struct

+ MaxCollectionBytes int64

+ MaxFileBytes int64

+ MaxResources int64

+ type ListOpts struct

+ After string

+ IncludeDeleted bool

+ Limit int

+ Path string

+ Recursive bool

+ SinceModSeq int64

+ type Mutation struct

+ At time.Time

+ Collection string

+ CollectionID string

+ ContentType string

+ ETag string

+ Event string

+ FromPath string

+ Kind string

+ ModSeq int64

+ Path string

+ ResourceID string

+ Size int64

+ Tenant string

+ type MutationSink interface

+ Enqueue func(ctx context.Context, m Mutation) error

+ type NopSink struct

+ func (NopSink) Enqueue(context.Context, Mutation) error

+ type ObjectCopier interface

+ Copy func(ctx context.Context, from, to string) error

+ type ObjectInfo struct

+ ContentType string

+ ModTime time.Time

+ Size int64

+ type ObjectStore interface

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

+ Get func(ctx context.Context, key string) (io.ReadCloser, ObjectInfo, error)

+ List func(ctx context.Context, prefix string, fn func(key string, info ObjectInfo) error) error

+ Name func() string

+ Put func(ctx context.Context, key string, r io.Reader, size int64, contentType string) error

+ Stat func(ctx context.Context, key string) (ObjectInfo, error)

+ func OpenObjects(name string, cfg ObjectsConfig) (ObjectStore, error)

+ type ObjectsConfig struct

+ FileDir string

+ type ObjectsConstructor func(ObjectsConfig) (ObjectStore, error)

+ type PutOpts struct

+ ContentType string

+ IfMatch string

+ IfNoneMatch string

+ type PutResult struct

+ Created bool

+ ETag string

+ ModSeq int64

+ Noop bool

+ ResourceID string

+ Size int64

+ type Resource struct

+ CollectionID string

+ ContentType string

+ CreatedAt time.Time

+ Deleted bool

+ DeletedAt time.Time

+ Depth int

+ ETag string

+ Kind string

+ ModSeq int64

+ ObjectKey string

+ ParentPath string

+ Path string

+ ResourceID string

+ Size int64

+ UpdatedAt time.Time

+ func (r Resource) IsDir() bool

+ type Store struct

+ func NewStore(db *sql.DB, d registry.Dialect, objects ObjectStore) *Store

+ func Open(name string, cfg Config) (*Store, error)

+ func (s *Store) Close() error

+ func (s *Store) Copy(ctx context.Context, collID, from, to string, overwrite bool) (Resource, error)

+ func (s *Store) DB() *sql.DB

+ func (s *Store) Delete(ctx context.Context, collID, p string, opts DeleteOpts) (Resource, error)

+ func (s *Store) DeleteByID(ctx context.Context, collID, resID string, opts DeleteOpts) (Resource, error)

+ func (s *Store) DeleteCollection(ctx context.Context, tenant, name string, force bool) (bool, error)

+ func (s *Store) EnsureCollection(ctx context.Context, tenant, name string) (Collection, bool, error)

+ func (s *Store) EnsureSchema(ctx context.Context) error

+ func (s *Store) GetAccount(ctx context.Context, username string) (Account, bool, error)

+ func (s *Store) GetCollection(ctx context.Context, tenant, name string) (Collection, bool, error)

+ func (s *Store) GetCollectionByID(ctx context.Context, id string) (Collection, bool, error)

+ func (s *Store) Limits() Limits

+ func (s *Store) List(ctx context.Context, collID string, opts ListOpts) ([]Resource, error)

+ func (s *Store) ListCollections(ctx context.Context, tenant string) ([]Collection, error)

+ func (s *Store) Mkdir(ctx context.Context, collID, p string) (Resource, error)

+ func (s *Store) Move(ctx context.Context, collID, from, to string, overwrite bool) (Resource, error)

+ func (s *Store) Objects() ObjectStore

+ func (s *Store) Open(ctx context.Context, collID, p string) (io.ReadCloser, Resource, error)

+ func (s *Store) OpenByID(ctx context.Context, collID, resID string) (io.ReadCloser, Resource, error)

+ func (s *Store) Put(ctx context.Context, collID, p string, r io.Reader, size int64, opts PutOpts) (PutResult, error)

+ func (s *Store) SetClock(now func() time.Time)

+ func (s *Store) SetLimits(l Limits)

+ func (s *Store) SetSink(sink MutationSink)

+ func (s *Store) SetSinkErrorHandler(fn func(Mutation, error))

+ func (s *Store) Stat(ctx context.Context, collID, p string) (Resource, bool, error)

+ func (s *Store) StatByID(ctx context.Context, collID, resID string) (Resource, bool, error)

+ func (s *Store) Sweep(ctx context.Context, grace, tombstoneRetention time.Duration) (SweepReport, error)

+ func (s *Store) UpsertAccount(ctx context.Context, tenant, username, pwHash, status, collectionID string) (created bool, err error)

+ type SweepReport struct

+ Collections int64

+ Errors int

+ OrphanBytes int64

+ Orphans int

+ Scanned int

+ Tombstones int64

+ type TransactionalMutationSink interface

+ EnqueueTx func(ctx context.Context, tx *sql.Tx, m Mutation) error