devicesync

type DirectoryStore interface {
	ApplyDirectorySnapshotAt(
		context.Context,
		domain.DirectorySnapshot,
		domain.DirectorySyncState,
		time.Time,
	) (aggregate.DirectoryApplyResult, error)
	UpdateDirectorySyncStateAt(context.Context, domain.DirectorySyncState, time.Time) error
	DeviceDirectory() domain.DeviceDirectory
}

type Options struct {
	Logger *slog.Logger
	Now    func() time.Time
	Jitter func(time.Duration) time.Duration
	Wait   func(context.Context, time.Duration) bool
}

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