Documentation
¶
Index ¶
- Constants
- func MarkComplete(conn redis.Conn, qType string, token WorkerToken) error
- func PushOntoQueue(conn redis.Conn, qType string, queue string, tps int, value string, ...) error
- func StartDethrottler(redis *redis.Pool, quitter chan bool, wg *sync.WaitGroup, qType string)
- type Priority
- type WorkerToken
Constants ¶
const ( // HighPriority is typically used for replies to ensure they sent as soon as possible. HighPriority = 1 // LowPriority is typically used for bulk messages (sent in batches). These will only be // processed after all high priority messages are dealt with. LowPriority = 0 )
const ( // EmptyQueue means there are no items to retrive, caller should sleep and try again later EmptyQueue = WorkerToken("empty") // Retry means the caller should immediately call again to get the next value Retry = WorkerToken("retry") )
Variables ¶
This section is empty.
Functions ¶
func MarkComplete ¶
func MarkComplete(conn redis.Conn, qType string, token WorkerToken) error
MarkComplete marks a task as complete for the passed in queue and queue result. It is important for callers to call this so that workers are evenly spread across all queues with jobs in them
func PushOntoQueue ¶
func PushOntoQueue(conn redis.Conn, qType string, queue string, tps int, value string, priority Priority) error
PushOntoQueue pushes the passed in value to the passed in queue, making sure that no more than the specified transactions per second are popped off at a time. A tps value of 0 means there is no limit to the rate that messages can be consumed
Types ¶
type WorkerToken ¶
type WorkerToken string
WorkerToken represents a token that a worker should return when a task is complete
func PopFromQueue ¶
PopFromQueue pops the next available message from the passed in queue. If QueueRetry is returned the caller should immediately make another call to get the next value. A worker token of EmptyQueue will be returned if there are no more items to retrive. Otherwise the WorkerToken should be saved in order to mark the task as complete later.
Source Files