Skip to content

Queue

In-memory and Redis message queue operations.

3 modules

ModuleDescription
Keluarkan ItemHapus dan kembalikan item dari antrian
Tambahkan ItemTambahkan item ke antrian dalam memori atau Redis
Ukuran AntrianDapatkan ukuran antrian saat ini

Modules

Keluarkan Item

queue.dequeue

Hapus dan kembalikan item dari antrian

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Nama antrian untuk mengeluarkan item
backendstringNomemoryBackend antrian yang digunakan
redis_urlstringNoredis://localhost:6379URL koneksi Redis
timeoutnumberNo0Waktu habis dalam detik (0 = non-blok)

Output:

FieldTypeDescription
dataanyItem yang dikeluarkan (null jika antrian kosong)
queue_namestringNama antrian
remainingnumberSisa item dalam antrian
emptybooleanApakah antrian kosong

Tambahkan Item

queue.enqueue

Tambahkan item ke antrian dalam memori atau Redis

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Nama antrian untuk menambahkan item
datastringYes-Data untuk ditambahkan ke antrian (nilai yang dapat diserialisasi JSON)
backendstringNomemoryBackend antrian yang digunakan
redis_urlstringNoredis://localhost:6379URL koneksi Redis

Output:

FieldTypeDescription
queue_namestringNama antrian
positionnumberPosisi item dalam antrian
queue_sizenumberUkuran antrian saat ini setelah penambahan

Ukuran Antrian

queue.size

Dapatkan ukuran antrian saat ini

Parameters:

NameTypeRequiredDefaultDescription
queue_namestringYes-Nama antrian untuk diperiksa
backendstringNomemoryBackend antrian yang digunakan
redis_urlstringNoredis://localhost:6379URL koneksi Redis

Output:

FieldTypeDescription
queue_namestringNama antrian
sizenumberJumlah item saat ini dalam antrian

Released under the Apache 2.0 License.