Versions in this module Expand all Collapse all v1 v1.4.1 May 3, 2026 Changes in this version + func New(config ...Config) celeris.HandlerFunc + type Config struct + BackpressureDelay time.Duration + BackpressureStatus int + CollectorProvider func() *observe.Collector + DepthThresholds DepthThresholds + EnableReap bool + ExemptFunc func(*celeris.Context) bool + ExemptPaths []string + LatencyEMAAlpha float64 + LatencyThresholds LatencyThresholds + PollInterval time.Duration + PriorityFunc func(*celeris.Context) int + PriorityThreshold int + ReapAggressiveness int + RejectStatus int + RetryAfter time.Duration + Skip func(*celeris.Context) bool + SkipPaths []string + StopContext context.Context + Thresholds Thresholds + type Controller struct + func NewWithController(config ...Config) (celeris.HandlerFunc, *Controller) + func (c *Controller) CPUSample() float64 + func (c *Controller) InFlight() int32 + func (c *Controller) LatencyEMA() time.Duration + func (c *Controller) Stage() Stage + func (c *Controller) Stop() + type DepthThresholds struct + Backpressure int32 + Expand int32 + Hysteresis int32 + Reap int32 + Reject int32 + Reorder int32 + type LatencyThresholds struct + Backpressure time.Duration + Expand time.Duration + Hysteresis time.Duration + Reap time.Duration + Reject time.Duration + Reorder time.Duration + type Stage int32 + const StageBackpressure + const StageExpand + const StageNormal + const StageReap + const StageReject + const StageReorder + func (s Stage) String() string + type Thresholds struct + Backpressure float64 + Expand float64 + Hysteresis float64 + Reap float64 + Reject float64 + Reorder float64
Go to main page