Documentation
¶
Index ¶
Constants ¶
const ( StatusPending = "pending" StatusProcessing = "processing" StatusCompleted = "completed" StatusFailed = "failed" )
Job statuses
Variables ¶
This section is empty.
Functions ¶
func CoolDownBucket ¶
CoolDownBucket calculates which time bucket the current time falls into based on the duration period. It returns an integer representing the number of complete duration periods since the Unix epoch (January 1, 1970 UTC).
This function is useful for implementing rate limiting and cooldown periods by grouping requests into fixed time windows. For example: - With a 1 hour duration, CoolDownBucket returns same value for all times within same hour - With a 5 minute duration, CoolDownBucket groups times into 5 minute buckets
The bucket number increases monotonically over time and can be used as a cache key for rate limiting. Multiple requests within the same duration period will get same bucket number.
Parameters: - duration: The fixed time window size to bucket time into (e.g. time.Hour, 5*time.Minute) - t: The time to calculate the bucket for (defaults to time.Now() if nil)
Returns: int: The bucket number, calculated as floor(t.Unix() / duration)
Errors: - Panics if duration is zero or negative to prevent undefined behavior
Types ¶
type PayloadRecurrent ¶
PayloadRecurrent is used as the unique payload for recurrent jobs. The ScheduledFor field makes each instance unique.
Source Files
Directories