Versions in this module Expand all Collapse all v0 v0.1.0 Jan 6, 2026 Changes in this version + type DB struct + func Open(path string) (*DB, error) + func (d *DB) ClearFileMessages(filePath string) error + func (d *DB) Close() error + func (d *DB) DeleteState(filePath string) error + func (d *DB) GetAllStates() ([]*SyncState, error) + func (d *DB) GetState(filePath string) (*SyncState, error) + func (d *DB) IsSynced(filePath, messageHash string) (bool, error) + func (d *DB) RecordError(filePath, errorMsg string) error + func (d *DB) RecordSyncedMessage(filePath, messageHash, spanID string) error + func (d *DB) SaveState(state *SyncState) error + func (d *DB) Stats() (*Stats, error) + type Stats struct + SyncedMessages int + TotalMessages int + TrackedFiles int + type SyncState struct + Backend string + FilePath string + LastMtime int64 + LastOffset int64 + LastSize int64 + LastSyncAt int64 + MessageCount int + TraceID string
Go to main page