Tubes

Named queue (also known is other queues as Topics or Groups)

A core concept of AllQ is the "tube".

A tube acts as a named queue where you can PUT jobs and GET jobs out of.

An example of tubes might be

  • emails_to_send

  • csv_loading

  • long_running_processes

When working with AllQ you will PUT a job into a tube, and then later GET a job out of a tube.

Tubes are created automatically when you PUT a job into one, and stats from the server will give you information about jobs stored within tubes.

Tubes can have the following actions performed on them

  • Throttle (sets max TPS on tube)

  • Pause (sets TPS=0 on tube, pausing workers from getting jobs)

  • Drain (only allow outbound jobs, won't accept inbound ones)

Last updated