engine

package

v0.3.1 Latest Latest Go to latest Published: Feb 28, 2026 License: MIT Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Engine orchestrates the dispatch loop.

func New(cfg *config.Config, m *metrics.Metrics) (*Engine, error)

New creates an Engine wired with all dependencies.

func (e *Engine) Run(ctx context.Context)

Run starts the engine and blocks until ctx is cancelled. After ctx is cancelled it waits for all in-flight tasks to complete.

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

Pool manages a global concurrency semaphore and an optional browser sub-semaphore.

func NewPool(maxWorkers, maxBrowserWorkers int) *Pool

NewPool creates a Pool with the given global and browser worker limits.

func (p *Pool) Acquire(ctx context.Context, taskType string) error

Acquire obtains a global slot (and a browser slot for browser tasks). Blocks until slots are available or ctx is cancelled.

func (p *Pool) Release(taskType string)

Release frees the slots acquired for the given task type.

func (p *Pool) Wait()

Wait blocks until all in-flight tasks have completed.

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

Scheduler controls inter-request timing based on the configured pacing mode.

func NewScheduler(cfg config.PacingConfig) *Scheduler

NewScheduler creates a Scheduler from the pacing config.

func (s *Scheduler) Start(ctx context.Context)

Start launches background goroutines needed by the scheduler (cron for scheduled mode).

func (s *Scheduler) Wait(ctx context.Context) error

Wait implements the pacing delay for the current mode. It blocks until it is appropriate to dispatch the next request.