sync

type PeerState ¶

type PeerState struct {
	Addr        string
	LastSeenSeq uint64
	Priority    SyncPriority
}

type SyncPriority ¶

type SyncPriority int

SyncPriority defines how often to check a peer for updates

const (
	PriorityHigh   SyncPriority = iota // Check every 100ms
	PriorityNormal                     // Check every 1s
	PriorityLow                        // Check every 10s
)

type SyncWorker ¶

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

SyncWorker manages background delta replication from peers

func NewSyncWorker(s *store.VectorStore, logger *zap.Logger) *SyncWorker

func (w *SyncWorker) AddPeer(addr string)

func (w *SyncWorker) Start()

func (w *SyncWorker) Stop()