Documentation ¶ Index ¶ type Options type Service func NewService(repo repository, matcher subjectMatcher, fetcher articleFetcher, log logger, ...) *Service func (s *Service) RunOnce(ctx context.Context) error func (s *Service) RunOnceWithMetrics(ctx context.Context) (map[string]any, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Options ¶ type Options struct { BatchSize int ClaimOwner string ClaimLease time.Duration Concurrency int MaxYEncRecoveryAttempts int BinaryUpsertDBChunkSize int Lane string LaneATargetPct int LaneBMinPct int LaneATimeWindowMinutes int } type Service ¶ type Service struct { // contains filtered or unexported fields } func NewService ¶ func NewService(repo repository, matcher subjectMatcher, fetcher articleFetcher, log logger, opts Options) *Service func (*Service) RunOnce ¶ func (s *Service) RunOnce(ctx context.Context) error RunOnce assembles one batch of article headers into binaries + binary_parts. func (*Service) RunOnceWithMetrics ¶ added in v0.7.0 func (s *Service) RunOnceWithMetrics(ctx context.Context) (map[string]any, error) Source Files ¶ View all Source files service.go Click to show internal directories. Click to hide internal directories.
Documentation
¶
Source Files