Skip to main content

Module timer_request

Module timer_request 

Source

Structs§

NormalizedTimerRequest
Canonical result shared by Broker, remoting, and Proxy admission adapters.
TimerPolicySnapshot
Immutable admission policy used while normalizing one timer request.

Enums§

TimerRequestKind
Property selected according to RocketMQ’s timer-property precedence.

Constants§

JAVA_COMPAT_TIMER_PRECISIONS_MS
Timer precisions supported by the Java-compatible timer engine.

Functions§

normalize_timer_request
Normalizes RocketMQ timer properties without reading the system clock.
normalize_timer_request_fields
Normalizes timer fields for adapters that do not use RocketMQ’s internal property-map type.