use crate::clients::base::{get_or_create_named, list_resource, ResourceContext};
use crate::common::{PaginationList, QueryParams, StorageListOptions};
use crate::error::ApifyClientResult;
use crate::http_client::HttpClient;
use crate::models::RequestQueue;
#[derive(Debug, Clone)]
pub struct RequestQueueCollectionClient {
ctx: ResourceContext,
}
impl RequestQueueCollectionClient {
pub(crate) fn new(http: HttpClient, base_url: &str) -> Self {
Self {
ctx: ResourceContext::collection(http, base_url, "request-queues"),
}
}
pub async fn list(
&self,
options: StorageListOptions,
) -> ApifyClientResult<PaginationList<RequestQueue>> {
let mut params = QueryParams::new();
options.apply(&mut params);
list_resource(&self.ctx, None, ¶ms).await
}
pub async fn get_or_create(&self, name: Option<&str>) -> ApifyClientResult<RequestQueue> {
get_or_create_named(&self.ctx, name).await
}
}