synchronizing

type FeedFetchMetadata struct {
	UUID string

	ETag         string
	LastModified time.Time

	UpdatedAt time.Time
	FetchedAt time.Time
}

type FeedMetadata struct {
	UUID string

	Title       string
	Description string

	Hash uint64

	UpdatedAt time.Time
}

type Repository interface {
	// FeedGetNByLastSynchronizationTime returns at most n feeds that have last been synchronized before
	// a given time.Time.
	//
	// This method must return only feeds with at least one active user Subscription.
	FeedGetNByLastSynchronizationTime(n uint, before time.Time) ([]feed.Feed, error)

	// FeedUpdateFetchMetadata updates fetch metadata (ETag, FetchedAt, UpdatedAt) for a given feed.Feed.
	FeedUpdateFetchMetadata(feedFetchMetadata FeedFetchMetadata) error

	// FeedUpdateMetadata updates metadata (Title, Description) for a given feed.Feed.
	FeedUpdateMetadata(feedMetadata FeedMetadata) error

	// FeedEntryUpsertMany adds a collection of new entries and updates existing entries.
	FeedEntryUpsertMany(entries []feed.Entry) (int64, error)
}

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

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