Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

metronome

package module

Go to main page

Versions in this module

v0

v0.4.0

Aug 16, 2026

Changes in this version

type Snapshot

+ func (s Snapshot) String() string

v0.3.2

Aug 16, 2026

v0.3.1

Aug 16, 2026

v0.3.0

Aug 16, 2026

Changes in this version

type Snapshot

+ MaxScheduleLag time.Duration

v0.2.2

Aug 16, 2026

Changes in this version

type Snapshot

+ CorrectedClamped int64

+ Saturated int64

v0.2.1

Aug 16, 2026

v0.2.0

Aug 16, 2026

Changes in this version

+ const DefaultResultBuffer

+ const DefaultWorkers

+ var ErrSaturated = errors.New("metronome: no worker free at scheduled time")

type Clock

+ Sleep func(ctx context.Context, d time.Duration) error

type Driver

+ Burst int

+ Pacing PacingMode

+ ResultBuffer int

type ManualClock

+ func (m *ManualClock) BlockUntilSleepers(n int)

+ func (m *ManualClock) Sleep(ctx context.Context, d time.Duration) error

+ type PacingMode int

+ const ClosedLoop

+ const OpenLoop

+ type PanicError struct

+ Stack []byte

+ Value any

+ func (e *PanicError) Error() string

type Result

+ Scheduled time.Time

type Snapshot

+ Bytes int64

+ Clamped int64

+ Codes map[string]int64

+ CorrectedCount int64

+ CorrectedP50 time.Duration

+ CorrectedP95 time.Duration

+ CorrectedP99 time.Duration

+ Throughput float64

type Stats

+ func NewStatsRange(lo, hi time.Duration, sigfigs int) *Stats

v0.1.0

Aug 15, 2026

Changes in this version

+ type Adaptive struct

+ func NewAdaptive(initial float64) *Adaptive

+ func (a *Adaptive) Rate(time.Duration) float64

+ func (a *Adaptive) SetRate(rps float64)

+ type Clock interface

+ Now func() time.Time

+ func SystemClock() Clock

+ type Constant float64

+ func (c Constant) Rate(time.Duration) float64

+ type Driver struct

+ Clock Clock

+ MaxRequests int

+ Rate RateController

+ Runner Runner

+ Workers int

+ func (d *Driver) Run(ctx context.Context) <-chan Result

+ type ManualClock struct

+ func NewManualClock(t time.Time) *ManualClock

+ func (m *ManualClock) Advance(d time.Duration)

+ func (m *ManualClock) Now() time.Time

+ type Phase struct

+ Duration time.Duration

+ TargetRPS float64

+ type Phased struct

+ Phases []Phase

+ func (p Phased) Rate(elapsed time.Duration) float64

+ type Ramp struct

+ End float64

+ Over time.Duration

+ Start float64

+ func (r Ramp) Rate(elapsed time.Duration) float64

+ type RateController interface

+ Rate func(elapsed time.Duration) float64

+ type Result struct

+ Bytes int64

+ Code string

+ Err error

+ Labels map[string]string

+ Latency time.Duration

+ Start time.Time

+ func (r Result) Success() bool

+ type Runner interface

+ Do func(ctx context.Context) Result

+ func Mix(ws ...Weighted) Runner

+ type RunnerFunc func(ctx context.Context) Result

+ func (f RunnerFunc) Do(ctx context.Context) Result

+ type Snapshot struct

+ Count int64

+ ErrorRate float64

+ Errors int64

+ Max time.Duration

+ P50 time.Duration

+ P95 time.Duration

+ P99 time.Duration

+ RPS float64

+ type Stats struct

+ func NewStats() *Stats

+ func (s *Stats) Record(r Result)

+ func (s *Stats) Snapshot() Snapshot

+ type Weighted struct

+ Runner Runner

+ Weight int