queue

Apr 25, 2026

Changes in this version

+ type Conflict struct

+ DetectedAt time.Time

+ LocalVersion *FileVersion

+ Path string

+ RemoteVersion *FileVersion

+ type ConflictResolution int

+ const AskUser

+ const KeepBoth

+ const LastWriteWins

+ type ConflictResolver struct

+ BaseDir string

+ Strategy ConflictResolution

+ func NewConflictResolver(baseDir string) *ConflictResolver

+ func (r *ConflictResolver) CleanupConflict(conflictPath string) error

+ func (r *ConflictResolver) DetectConflict(path string, localVer, remoteVer *FileVersion) *Conflict

+ func (r *ConflictResolver) GetLocalVersion(path string) (*FileVersion, error)

+ func (r *ConflictResolver) ListConflicts() ([]string, error)

+ func (r *ConflictResolver) Resolve(conflict *Conflict) (conflictPath string, err error)

+ type FileVersion struct

+ Checksum uint64

+ Mtime int64

+ Path string

+ Size int64

+ SourcePeer string

+ type OperationType int

+ const OpCreate

+ const OpDelete

+ const OpMkdir

+ const OpRename

+ const OpRmdir

+ const OpWrite

+ func (t OperationType) String() string

+ type QueuedOperation struct

+ Checksum uint64

+ CreatedAt time.Time

+ Data []byte

+ ID uint64

+ Mode uint32

+ Mtime int64

+ Offset int64

+ OldPath string

+ Path string

+ Retries int

+ Size int64

+ Type OperationType

+ type ReplayFunc func(op *QueuedOperation) error

+ type WriteQueue struct

+ MaxBytes int64

+ MaxOps int

+ func NewWriteQueue(dir string, sessionID string, logger *slog.Logger) (*WriteQueue, error)

+ func (q *WriteQueue) Clear() error

+ func (q *WriteQueue) Close() error

+ func (q *WriteQueue) Count() int

+ func (q *WriteQueue) DisableQueueing()

+ func (q *WriteQueue) EnableQueueing()

+ func (q *WriteQueue) Enqueue(op *QueuedOperation) error

+ func (q *WriteQueue) EnqueueCreate(path string, size int64, mode uint32, mtime int64) error

+ func (q *WriteQueue) EnqueueDelete(path string) error

+ func (q *WriteQueue) EnqueueRename(oldPath, newPath string) error

+ func (q *WriteQueue) EnqueueWrite(path string, data []byte, offset int64) error

+ func (q *WriteQueue) Flush(replay ReplayFunc) []error

+ func (q *WriteQueue) IsEnabled() bool

+ func (q *WriteQueue) Stats() (enqueued, replayed, failed uint64)

+ func (q *WriteQueue) TotalBytes() int64