Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
Engine orchestrates the dispatch loop.
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
Pool manages a global concurrency semaphore and an optional browser sub-semaphore.
func (*Pool) Acquire ¶
Acquire obtains a global slot (and a browser slot for browser tasks). Blocks until slots are available or ctx is cancelled.
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
Scheduler controls inter-request timing based on the configured pacing mode.
func NewScheduler ¶
func NewScheduler(cfg config.PacingConfig) *Scheduler
NewScheduler creates a Scheduler from the pacing config.
func (*Scheduler) Start ¶
Start launches background goroutines needed by the scheduler (cron for scheduled mode).
func (*Scheduler) UpdatePacing ¶ added in v0.4.0
func (s *Scheduler) UpdatePacing(cfg config.PacingConfig)
UpdatePacing updates reloadable pacing parameters at runtime. Mode changes are not supported — callers should warn and skip.
Source Files
Click to show internal directories.
Click to hide internal directories.