Function create_queue

crates/hyperqueue/src/server/autoalloc/process.rs:677–712

(
    autoalloc: &mut AutoAllocState,
    events: &EventStreamer,
    server_directory: PathBuf,
    params: QueueParameters,
    queue_id: Option<QueueId>,
    worker_resources: Option<ResourceDescri

}

fn create_queue(
    autoalloc: &mut AutoAllocState,
    events: &EventStreamer,
    server_directory: PathBuf,
    params: QueueParameters,
    queue_id: Option<QueueId>,
    worker_resources: Option<ResourceDescriptor>,
) -> anyhow::Result<QueueId> {
    let name = params.name.clone();
    let handler = create_allocation_handler(&params.manager, name.clone(), server_directory);
    let queue_info = QueueInfo::new(params.clone());

    match handler {
        Ok(handler) => {
            let queue = AllocationQueue::new(
                queue_info,
                name,
                handler,
                create_rate_limiter(),
                worker_resources,
            );
            let id = {
                let id = autoalloc.add_queue(queue, queue_id);
                if queue_id.is_none() {
                    // When queue_id is provided, then we are restoring journal,
                    // so we do not want to double log the event
                    events.on_allocation_queue_created(id, params);
                }
                id
            };

            Ok(id)
        }
        Err(error) => Err(anyhow::anyhow!("Could not create autoalloc queue: {error}")),
    }
}

// TODO: use proper error type
async fn remove_queue(