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)