autosync

Apr 24, 2026

Changes in this version

+ const PhaseDisabled

type Manager

+ func (m *Manager) ResumeAfterUpgrade(project string) error

+ func (m *Manager) Stop()

+ func (m *Manager) StopForUpgrade(project string) error

+ type MutationEntry struct

+ Entity string

+ EntityKey string

+ Op string

+ Payload json.RawMessage

+ Project string

+ type PullMutationsResponse struct

+ HasMore bool

+ LatestSeq int64

+ Mutations []PulledMutation

+ type PulledMutation struct

+ Entity string

+ EntityKey string

+ OccurredAt string

+ Op string

+ Payload json.RawMessage

+ Seq int64

+ type PushMutationsResult struct

+ AcceptedSeqs []int64

type Status

+ ReasonCode string

+ ReasonMessage string

Mar 7, 2026

Changes in this version

+ const PhaseBackoff

+ const PhaseHealthy

+ const PhaseIdle

+ const PhasePullFailed

+ const PhasePulling

+ const PhasePushFailed

+ const PhasePushing

+ type CloudTransport interface

+ PullMutations func(sinceSeq int64, limit int) (*remote.PullMutationsResponse, error)

+ PushMutations func(mutations []remote.MutationEntry) (*remote.PushMutationsResult, error)

+ type Config struct

+ BaseBackoff time.Duration

+ DebounceDuration time.Duration

+ LeaseInterval time.Duration

+ LeaseOwner string

+ MaxBackoff time.Duration

+ MaxConsecutiveFailures int

+ PollInterval time.Duration

+ PullBatchSize int

+ PushBatchSize int

+ TargetKey string

+ func DefaultConfig() Config

+ type LocalStore interface

+ AckSyncMutationSeqs func(targetKey string, seqs []int64) error

+ AckSyncMutations func(targetKey string, lastAckedSeq int64) error

+ AcquireSyncLease func(targetKey, owner string, ttl time.Duration, now time.Time) (bool, error)

+ ApplyPulledMutation func(targetKey string, mutation store.SyncMutation) error

+ GetSyncState func(targetKey string) (*store.SyncState, error)

+ ListPendingSyncMutations func(targetKey string, limit int) ([]store.SyncMutation, error)

+ MarkSyncFailure func(targetKey, message string, backoffUntil time.Time) error

+ MarkSyncHealthy func(targetKey string) error

+ ReleaseSyncLease func(targetKey, owner string) error

+ SkipAckNonEnrolledMutations func(targetKey string) (int64, error)

+ type Manager struct

+ func New(localStore LocalStore, transport CloudTransport, cfg Config) *Manager

+ func (m *Manager) NotifyDirty()

+ func (m *Manager) Run(ctx context.Context)

+ func (m *Manager) Status() Status

+ func (m *Manager) SyncStatus() Status

+ type Status struct

+ BackoffUntil *time.Time

+ ConsecutiveFailures int

+ LastError string

+ LastSyncAt *time.Time

+ Phase string