use conjure_http::endpoint;
#[conjure_http::conjure_client(name = "IngestJobService")]
pub trait IngestJobService<
#[response_body]
I: Iterator<
Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
>,
> {
#[endpoint(
method = GET,
path = "/ingest/v1/ingest-job/{ingestJobRid}",
name = "getIngestJob",
accept = conjure_http::client::StdResponseDeserializer
)]
fn get_ingest_job(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
ingest_job_rid: &super::super::super::super::objects::ingest::api::IngestJobRid,
) -> Result<
super::super::super::super::objects::ingest::api::IngestJob,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/ingest/v1/ingest-jobs/search",
name = "searchIngestJobs",
accept = conjure_http::client::StdResponseDeserializer
)]
fn search_ingest_jobs(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::ingest::api::SearchIngestJobsRequest,
) -> Result<
super::super::super::super::objects::ingest::api::SearchIngestJobsResponse,
conjure_http::private::Error,
>;
}
#[conjure_http::conjure_client(name = "IngestJobService")]
pub trait AsyncIngestJobService<
#[response_body]
I: conjure_http::private::Stream<
Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
>,
> {
#[endpoint(
method = GET,
path = "/ingest/v1/ingest-job/{ingestJobRid}",
name = "getIngestJob",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_ingest_job(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
ingest_job_rid: &super::super::super::super::objects::ingest::api::IngestJobRid,
) -> Result<
super::super::super::super::objects::ingest::api::IngestJob,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/ingest/v1/ingest-jobs/search",
name = "searchIngestJobs",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn search_ingest_jobs(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::ingest::api::SearchIngestJobsRequest,
) -> Result<
super::super::super::super::objects::ingest::api::SearchIngestJobsResponse,
conjure_http::private::Error,
>;
}
#[conjure_http::conjure_client(name = "IngestJobService", local)]
pub trait LocalAsyncIngestJobService<
#[response_body]
I: conjure_http::private::Stream<
Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
>,
> {
#[endpoint(
method = GET,
path = "/ingest/v1/ingest-job/{ingestJobRid}",
name = "getIngestJob",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn get_ingest_job(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
encoder = conjure_http::client::conjure::PlainEncoder
)]
ingest_job_rid: &super::super::super::super::objects::ingest::api::IngestJobRid,
) -> Result<
super::super::super::super::objects::ingest::api::IngestJob,
conjure_http::private::Error,
>;
#[endpoint(
method = POST,
path = "/ingest/v1/ingest-jobs/search",
name = "searchIngestJobs",
accept = conjure_http::client::StdResponseDeserializer
)]
async fn search_ingest_jobs(
&self,
#[auth]
auth_: &conjure_object::BearerToken,
#[body(serializer = conjure_http::client::StdRequestSerializer)]
request: &super::super::super::super::objects::ingest::api::SearchIngestJobsRequest,
) -> Result<
super::super::super::super::objects::ingest::api::SearchIngestJobsResponse,
conjure_http::private::Error,
>;
}