workers

type Parser interface {
	Parse(ctx context.Context, url string) (model.ParsedArticle, error)
}

type Storage interface {
	GetURLToProcess(ctx context.Context) (string, error)
	SaveParsedArticle(ctx context.Context, article model.ParsedArticle) error

	AddPendingURLs(ctx context.Context, urls ...string) error
	ResetInProgressURLs(ctx context.Context) error
	SetFailed(ctx context.Context, url string, err error) error
}

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