engine

type Account struct{ Bytes, Rows, Folders int64 }

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

type BlobStore interface {
	Put(context.Context, string, string, io.Reader) (int64, error)
	Open(context.Context, string, string) (io.ReadCloser, error)
	Size(context.Context, string, string) (int64, error)
	Delete(context.Context, string, string) error
}

type BlobURLStore interface {
	DownloadURL(ctx context.Context, folder, id string, ttl time.Duration) (string, error)
}

type Client interface {
	PrepareFolder(context.Context) (FolderChallenge, error)
	CreateFolder(context.Context, FolderSpec) (Folder, error)
	Grant(context.Context, string, Principal, Role) error
	Revoke(context.Context, string, Principal) error
	DeleteFolder(context.Context, string) error
	SetLimits(context.Context, string, Limits) error
	ListFolders(context.Context) ([]Folder, error)
	GetFolder(context.Context, string) (Folder, error)
	Reserve(context.Context, string, UploadRequest) (Ticket, error)
	Upload(context.Context, string, Ticket, io.Reader) error
	CancelUpload(context.Context, string, string) error
	Commit(context.Context, string, []Mutation) (Delta, error)
	Changes(context.Context, string, uint64) (Delta, error)
	Download(context.Context, string, string) (io.ReadCloser, error)
	DownloadURLs(context.Context, string, []string) ([]string, error)
	// Snapshot returns a packed snapshot's version and a short-lived bearer
	// URL, or zero and "" when none is offered. Decode it with ReadSnapshot.
	Snapshot(context.Context, string) (uint64, string, error)
	Wait(context.Context, string, uint64) (uint64, error)
}

type ConflictError struct{ Paths []string }

type Delta struct {
	Full    bool
	Horizon uint64
	Next    string `json:",omitempty"`
	Version uint64
	Rows    []Row
}

type DirectoryBlobStore struct {
	// contains filtered or unexported fields
}

type Entry struct {
	Path        string
	Size        int64
	Directory   bool
	Placeholder bool
}

type Event struct {
	Version uint64
	Err     error
}

type FetchResult struct {
	// Fetched lists the placeholders this call downloaded; Bytes is their plaintext size.
	Fetched []string
	Bytes   int64
	// Present counts matched files that were already downloaded.
	Present int
	// Unmatched lists patterns that matched no tracked file.
	Unmatched []string
	Failed    []Rejection
}

type FileMetadata struct {
	Path, BlobID string
	Size         int64
	Mode         uint32
	Directory    bool
	Hash         string
}

type Folder struct {
	ID                string
	Owner             Principal
	Name, Description string
	Limits            Limits
	KeyCheck          []byte
	Version           uint64
	Horizon           uint64
	Usage             Usage
	Role              Role
}

type FolderChallenge struct {
	ID    string
	Proof []byte
}

type FolderKey [32]byte

type FolderRecord struct {
	AuthEpoch     string
	Folder        Folder
	Grants        map[string]Role `json:"-"`
	Allocated     bool
	Deleted       bool
	FileUsage     Usage
	TransferUsage Usage
}

type FolderSpec struct {
	ID                string
	CreationProof     []byte
	Name, Description string
	Limits            Limits
	KeyCheck          []byte
}

type Garbage struct {
	FolderID, BlobID string
	Owner            Principal
	Size             int64
	Writing          bool
	// Writer and Lease are copied from the ticket that became this garbage.
	// Another authority's lease is still live until Lease, so collection must
	// not delete the blob early.
	Writer string
	Lease  time.Time
}

type HTTPClient struct {
	BaseURL          string
	HTTP             *http.Client
	Headers          http.Header
	MaxResponseBytes int64
}

type InProcessClient struct {
	Server    *Server
	Principal Principal
}

type IndexEntry struct {
	Path, Local                                           string
	Hash                                                  [32]byte
	Blob                                                  [16]byte
	Version                                               uint64
	Size                                                  int64
	Dev, Inode                                            uint64
	Mode                                                  uint32
	Placeholder, RemoteOnly, Deleted, Awaiting, Directory bool
}

type LimitError struct {
	Limit              string
	Maximum, Requested int64
}

type Limits struct{ MaxFileBytes, MaxTotalBytes, MaxFiles, MaxRows int64 }

type LocalFile struct {
	Path, Local, Hash string
	Size              int64
	Mode              uint32
	Directory         bool
}

type MemoryBlobStore struct {
	// contains filtered or unexported fields
}

type MetaStore interface {
	Transaction(context.Context, func(*Metadata) error) error
}

type Metadata struct {
	Folders  map[string]FolderRecord
	Files    map[string]map[string]Row
	Tickets  map[string]Ticket
	Garbage  map[string]Garbage
	Accounts map[string]Account
	// contains filtered or unexported fields
}

type Mutation struct {
	PathID      string
	BaseVersion uint64
	TicketID    string
	Metadata    []byte
	Deleted     bool
}

type NotificationSource interface{ Notifications() *Notifications }

type Notifications = notifications

type Options struct {
	Name, StateDir                          string
	Debounce, RescanInterval, RetryInterval time.Duration
	Ignore                                  []string
	Manual                                  bool
	// Moved reports that dir is the attached root renamed on the same volume.
	Moved bool
	// OnDemand keeps undownloaded files as empty, unreadable placeholders.
	OnDemand bool
	// Downloads bounds concurrent blob downloads; zero selects 8.
	Downloads int
	// MaxPlaceholders (default 20,000, breadth first) and MaxFolderPlaceholders
	// (default 1,000 direct entries) bound placeholders; past either, a folder collapses.
	MaxPlaceholders, MaxFolderPlaceholders int
	// GuideName and Guide write a local-only guide at the root and in collapsed folders.
	GuideName, Guide string
}

type PostgresMetaStore struct {
	// contains filtered or unexported fields
}

type Principal struct{ Tenant, Subject string }

type QuarantinedRow struct {
	Path    string
	PathID  string
	Version uint64
}

type Quota struct{ MaxTotalBytes, MaxFolders, MaxFileBytes, MaxFiles int64 }

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

type QuotaPolicy interface {
	Quota(context.Context, Principal) (Quota, error)
}

type Rejection struct {
	Path, Reason string
	Hash         string
	RetryAt      time.Time
}

type Replica struct {
	// contains filtered or unexported fields
}

type Role string

type Row struct {
	FolderID, PathID, BlobID string
	Version                  uint64
	SealedSize               int64
	Metadata                 []byte
	Deleted                  bool
	DeletedAt                int64
}

type SQLiteMetaStore struct {
	// contains filtered or unexported fields
}

type Scope struct {
	TicketPaths []string
	Principal   Principal
	Folder      string
	Create      bool
	GC          bool
	NoFiles     bool
	ReadOnly    bool
	Paths       []string
	Tickets     []string
	Garbage     []string
	Write       bool
	Owner       bool
}

type Server struct {
	Meta           MetaStore
	Blobs          BlobStore
	Quotas         QuotaPolicy
	ReservationTTL time.Duration
	Now            func() time.Time

	TombstoneTTL time.Duration

	// SnapshotRows is the live-row count at which Snapshot offers a packed
	// snapshot. Zero selects 1,000; negative disables snapshots.
	SnapshotRows int
	// contains filtered or unexported fields
}

type Status struct {
	Quarantined                      []QuarantinedRow
	PendingUpBytes, PendingDownBytes int64
	Conflicts                        []string
	Rejected                         []Rejection
	Skipped                          []string
	LastSync                         time.Time
	Errors                           []string
	Version                          uint64
	Watcher                          string
	Placeholders, PlaceholderBytes   int64
}

type Ticket struct {
	AuthEpoch                                string
	SessionID                                string
	ID, FolderID, BlobID, PathID             string
	Principal                                Principal
	BaseVersion                              uint64
	SealedSize, ReservedBytes, ReservedFiles int64
	ReservedRows                             int64
	Expires                                  time.Time
	Uploaded                                 bool
	Writing                                  bool
	// Writer is the process publishing this ticket. Lease is when that claim
	// expires. Recovery and garbage collection treat a writing ticket as live
	// until Lease, including across processes. A zero Lease is already expired.
	Writer string
	Lease  time.Time
}

type UploadRequest struct {
	// SessionID identifies one replica state directory (random 128-bit hex).
	// Only the same principal/session can replace its previous ticket; empty or
	// different sessions get ErrBusy. This is contention control, not a grant.
	SessionID     string
	PathID        string
	BaseVersion   uint64
	SealedSize    int64
	MetadataBytes int64
}

type Usage struct{ Bytes, Files, Rows, Reserved, ReservedFiles, ReservedRows, GarbageRows int64 }

type WireRequest struct {
	Op, Folder, Ticket, Blob string
	Blobs                    []string `json:",omitempty"`
	Spec                     FolderSpec
	Grantee                  Principal
	Role                     Role
	Limits                   Limits
	Upload                   UploadRequest
	Mutations                []Mutation
	After                    uint64
	Page                     string
	Until                    uint64
}