drivesync

package module

Go to main page

Versions in this module

v0

v0.4.1

Oct 31, 2026

Changes in this version

type Client

+ func NewHTTPClientWithClient(url string, headers http.Header, client *http.Client) *Client

v0.4.0

Oct 27, 2026

Changes in this version

+ type BlobURLStore interface

+ DownloadURL func(ctx context.Context, folder, id string, ttl time.Duration) (string, error)

+ type Entry struct

+ Directory bool

+ Path string

+ Placeholder bool

+ Size int64

+ type FetchResult struct

+ Bytes int64

+ Failed []Rejection

+ Fetched []string

+ Present int

+ Unmatched []string

type Options

+ Downloads int

+ Guide string

+ GuideName string

+ MaxFolderPlaceholders int

+ MaxPlaceholders int

+ OnDemand bool

type Replica

+ func (r *Replica) Entries(patterns ...string) ([]Entry, error)

+ func (r *Replica) Fetch(ctx context.Context, patterns ...string) (FetchResult, error)

type ServerOptions

+ SnapshotRows int

type Status

+ PlaceholderBytes int64

+ Placeholders int64

v0.3.1

Oct 27, 2026

v0.3.0

Oct 6, 2026

Changes in this version

type FolderKey

+ func (k FolderKey) String() string

type Options

+ Moved bool

type ServerOptions

+ MaxWaitsPerPrincipal int

v0.2.0

Oct 4, 2026

Changes in this version

type MetaStore

+ func OpenPostgresMetaStore(ctx context.Context, db *sql.DB, schema string) (*MetaStore, error)

v0.1.0

Oct 3, 2026

Changes in this version

+ var ErrBusy = engine.ErrBusy

+ var ErrConflict = engine.ErrConflict

+ var ErrDenied = engine.ErrDenied

+ var ErrExpired = engine.ErrExpired

+ var ErrIntegrity = engine.ErrIntegrity

+ var ErrInvalid = engine.ErrInvalid

+ var ErrKey = engine.ErrKey

+ var ErrQuota = engine.ErrQuota

+ var ErrWaitLimit = engine.ErrWaitLimit

+ type Authenticator func(*http.Request) (Principal, error)

+ type BlobStore interface

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

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

+ Put func(context.Context, string, string, io.Reader) (int64, error)

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

+ type Client struct

+ func NewHTTPClient(url string, headers http.Header) *Client

+ func (c *Client) CreateFolder(ctx context.Context, spec FolderSpec, key FolderKey) (Folder, error)

+ func (c *Client) DeleteFolder(ctx context.Context, id string) error

+ func (c *Client) GetFolder(ctx context.Context, id string) (Folder, error)

+ func (c *Client) Grant(ctx context.Context, id string, p Principal, role Role) error

+ func (c *Client) ListFolders(ctx context.Context) ([]Folder, error)

+ func (c *Client) Revoke(ctx context.Context, id string, p Principal) error

+ func (c *Client) SetLimits(ctx context.Context, id string, limits Limits) error

+ type DirectoryBlobStore struct

+ func OpenDirectoryBlobStore(path string) (*DirectoryBlobStore, error)

+ func (b *DirectoryBlobStore) Close() error

+ func (b *DirectoryBlobStore) Delete(ctx context.Context, folder, id string) error

+ func (b *DirectoryBlobStore) Open(ctx context.Context, folder, id string) (io.ReadCloser, error)

+ func (b *DirectoryBlobStore) Put(ctx context.Context, folder, id string, r io.Reader) (int64, error)

+ func (b *DirectoryBlobStore) Size(ctx context.Context, folder, id string) (int64, error)

+ type Folder struct

+ Description string

+ ID string

+ Limits Limits

+ Name string

+ Owner Principal

+ Role Role

+ Usage Usage

+ type FolderKey [32]byte

+ func NewFolderKey() FolderKey

+ func ParseFolderKey(s string) (FolderKey, error)

+ type FolderSpec struct

+ Description string

+ Limits Limits

+ Name string

+ type LimitError struct

+ Limit string

+ Maximum int64

+ Requested int64

+ func (e *LimitError) Error() string

+ func (e *LimitError) Unwrap() error

+ type Limits struct

+ MaxFileBytes int64

+ MaxFiles int64

+ MaxRows int64

+ MaxTotalBytes int64

+ type MemoryBlobStore struct

+ func NewMemoryBlobStore() *MemoryBlobStore

+ func (b *MemoryBlobStore) Delete(ctx context.Context, folder, id string) error

+ func (b *MemoryBlobStore) Open(ctx context.Context, folder, id string) (io.ReadCloser, error)

+ func (b *MemoryBlobStore) Put(ctx context.Context, folder, id string, r io.Reader) (int64, error)

+ func (b *MemoryBlobStore) Size(ctx context.Context, folder, id string) (int64, error)

+ type MetaStore struct

+ func OpenSQLiteMetaStore(path string) (*MetaStore, error)

+ func (m *MetaStore) Close() error

+ type Options struct

+ Debounce time.Duration

+ Ignore []string

+ Manual bool

+ Name string

+ RescanInterval time.Duration

+ RetryInterval time.Duration

+ StateDir string

+ type Principal struct

+ Subject string

+ Tenant string

+ type Quota struct

+ MaxFileBytes int64

+ MaxFiles int64

+ MaxFolders int64

+ MaxTotalBytes int64

+ type QuotaFunc func(context.Context, Principal) (Quota, error)

+ func (f QuotaFunc) Quota(ctx context.Context, p Principal) (Quota, error)

+ type QuotaPolicy interface

+ Quota func(context.Context, Principal) (Quota, error)

+ type Rejection struct

+ Path string

+ Reason string

+ type Replica struct

+ func Attach(ctx context.Context, c *Client, id string, key FolderKey, dir string, ...) (*Replica, error)

+ func (r *Replica) Close() error

+ func (r *Replica) Retry()

+ func (r *Replica) Status() Status

+ func (r *Replica) Sync(ctx context.Context) error

+ type Role string

+ const Owner

+ const Reader

+ const Writer

+ type Server struct

+ func NewServer(meta *MetaStore, blobs BlobStore, opts ServerOptions) *Server

+ func (s *Server) Client(p Principal) *Client

+ func (s *Server) Handler(auth Authenticator) http.Handler

+ func (s *Server) Run(ctx context.Context) error

+ type ServerOptions struct

+ Clock func() time.Time

+ GCInterval time.Duration

+ Quotas QuotaPolicy

+ ReservationTTL time.Duration

+ TombstoneTTL time.Duration

+ type Status struct

+ Conflicts []string

+ Errors []string

+ LastSync time.Time

+ PendingDownBytes int64

+ PendingUpBytes int64

+ Quarantined []string

+ Rejected []Rejection

+ type Usage struct

+ Bytes int64

+ Files int64

+ Reserved int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL