synchronizing

Documentation

Index

• type FeedFetchMetadata
• type Repository
• type Scheduler
  • func NewScheduler(service *Service, locker sync.Locker) *Scheduler
  • func (sc *Scheduler) Run()
• type Service
  • func NewService(r Repository, client *fetching.Client) *Service
  • func (s *Service) Synchronize(jobID string) error

Types

type FeedFetchMetadata

type FeedFetchMetadata struct {
	UUID string

	ETag         string
	LastModified time.Time

	UpdatedAt time.Time
	FetchedAt time.Time
}

type Repository

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(meta FeedFetchMetadata) error

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

type Scheduler

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

A Scheduler periodically synchronizes all syndication feeds.

func NewScheduler

func NewScheduler(service *Service, locker sync.Locker) *Scheduler

NewScheduler initializes and returns a Scheduler.

func (*Scheduler) Run

func (sc *Scheduler) Run()

Run periodically synchronizes all syndication feeds.

type Service

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

Service handles feed synchronization operations.

func NewService

func NewService(r Repository, client *fetching.Client) *Service

func (*Service) Synchronize

func (s *Service) Synchronize(jobID string) error

Synchronize synchronizes syndication feeds for all users.