service

Documentation

Index

• Constants
• type SyncService
  • func NewSyncService(store *storage.Storage, feedFetcher fetch.FeedFetcher, ...) *SyncService
  • func (s *SyncService) Run(ctx context.Context) error
  • func (s *SyncService) SyncAllBlogs() error
  • func (s *SyncService) SyncBlog(feedURL string) error

Constants

const (
	SyncInterval = 1 * time.Hour
	SyncCooldown = 30 * time.Minute

	SyncConcurrency = 8
)

Types

type SyncService

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

func NewSyncService

func NewSyncService(store *storage.Storage, feedFetcher fetch.FeedFetcher, pageFetcher fetch.PageFetcher) *SyncService

func (*SyncService) Run

func (s *SyncService) Run(ctx context.Context) error

func (*SyncService) SyncAllBlogs

func (s *SyncService) SyncAllBlogs() error

Start with the current time and a list of all known blogs. For each blog, compare its syncedAt time to the current time. If the difference is less than SyncCooldown, skip it. Otherwise, check for and sync new content.

func (*SyncService) SyncBlog

func (s *SyncService) SyncBlog(feedURL string) error