job

Documentation

Index

• Constants
• func NewParserFeedJob(logger *logger.Logger, articleRepository *storage.ArticleRepository, ...) quartz.Job
• type Daemon
  • func NewDaemon(logger *logger.Logger, config *DaemonConfig, jobs []quartz.Job) *Daemon
  • func (d *Daemon) Start(ctx context.Context) error
• type DaemonConfig
• type ParserFeedJob
  • func (p *ParserFeedJob) Description() string
  • func (p *ParserFeedJob) Execute(ctx context.Context) error
  • func (p *ParserFeedJob) Key() int

Constants

const (
	FeedParser = iota
)

Functions

func NewParserFeedJob

func NewParserFeedJob(logger *logger.Logger,
	articleRepository *storage.ArticleRepository,
	resourceRepository *storage.ResourceRepository,
	tracerProvider traces.ShutdownTracerProvider,
	manager *notifier.SubscriptionManager[*model.FeedArticle],
) quartz.Job

Types

type Daemon

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

func NewDaemon

func NewDaemon(logger *logger.Logger, config *DaemonConfig, jobs []quartz.Job) *Daemon

func (*Daemon) Start

func (d *Daemon) Start(ctx context.Context) error

type DaemonConfig

type DaemonConfig struct {
	Cron string `envconfig:"CRON" default:"1/60 * * * * *"`
}

type ParserFeedJob

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

func (*ParserFeedJob) Description

func (p *ParserFeedJob) Description() string

func (*ParserFeedJob) Execute

func (p *ParserFeedJob) Execute(ctx context.Context) error

func (*ParserFeedJob) Key

func (p *ParserFeedJob) Key() int