queue

type Conflict struct {
	Path          string
	LocalVersion  *FileVersion
	RemoteVersion *FileVersion
	DetectedAt    time.Time
}

type ConflictResolution int

type ConflictResolver struct {
	Strategy ConflictResolution
	BaseDir  string // Local filesystem base directory
}

type FileVersion struct {
	Path       string
	Size       int64
	Mtime      int64  // unix nano
	Checksum   uint64 // xxHash3
	SourcePeer string // "local" or peer fingerprint prefix
}

type OperationType int

type QueuedOperation struct {
	ID        uint64 // Monotonic operation ID
	Type      OperationType
	Path      string    // Relative path in the mounted filesystem
	OldPath   string    // Source path for RENAME
	Data      []byte    // Data to write, for WRITE
	Offset    int64     // File offset, for WRITE
	Size      int64     // File size, for CREATE/EDIT
	Mode      uint32    // File mode and permissions
	Mtime     int64     // Modification time (unix nano)
	Checksum  uint64    // xxHash3 of Data, for integrity checks
	CreatedAt time.Time // Queue time
	Retries   int       // Replay attempt count
}

type ReplayFunc func(op *QueuedOperation) error

type WriteQueue struct {

	// Configuration
	MaxOps   int   // Maximum queued operations (default 1000)
	MaxBytes int64 // Maximum queued data bytes (default 100 MB)
	// contains filtered or unexported fields
}