Skip to content

Queue System

Queue System is developed using RQ, a library that provides a job management system with a Redis backend. Currently isard-api and isard-storage containers are using the Queue System. So, these containers should have access to TCP port 6379 of isard-redis container.

Queues

core

Consumed by isard-core_worker

Tasks:

  • feedback: Send feedback to user via socketio about job status.

storage.<storage_pool_id>.high

Consumed by isard-storage that have this storage_pool_id configured with best priority

Tasks:

  • upload: Create a unique URL to upload media or disks.
  • create_disk: Create a disk.

storage.<storage_pool_id>.default

Consumed by isard-storage that have this storage_pool_id configured with medium priority

Tasks:

  • create_snapshot: Create snapshot via qemu-img.
  • download: Create a downoadable item and create a unique URL to upload media or disks.
  • unarchive_disk: Recover an archived disk decompressing it and moving it to high performance storage.
  • resize: Resize disk via qemu-img.

storage.<storage_pool_id>.low

Consumed by isard-storage that have this storage_pool_id configured with poor priority

Tasks:

  • convert: Convert disks via qemu-img.
  • commit: Commit disks via qemu-img.
  • rebase: Rebase disk via qemu-img.
  • sparsify: Sparsify disk via virt-sparsify.
  • archive_disk: Compress disk and move to low cost storage.
  • delete_disk: Delete disk safely.
  • delete_media: Delete media.

hypervisor.<storage_pool_id>.high

Consumed by isard-hypervisor that have this storage_pool_id configured with best priority

Tasks:

hypervisor.<storage_pool_id>.default

Consumed by isard-hypervisor that have this storage_pool_id configured with medium priority

Tasks:

  • check_domain: Start a domain paused.
  • start_domain: Start a domain.

hypervisor.<storage_pool_id>.low

Consumed by isard-hypervisor that have this storage_pool_id configured with poor priority

Tasks:

hypervisor.<hypervisor_id>.high

Consumed by hypervisor_id with best priority

Tasks:

  • stop_domain: Stop a domain.

hypervisor.<hypervisor_id>.default

Consumed by hypervisor_id with medium priority

Tasks:

  • stop_domain: Stop a domain.
  • revert_snapshot: Revert snapshot via virsh/libvirt.

hypervisor.<hypervisor_id>.low

Consumed by hypervisor_id with poor priority

Tasks:

  • create_snapshot: Create snapshot via virsh/libvirt.

Last update: May 23, 2023