use conjure_http::endpoint;
#[conjure_http::conjure_endpoints(
name = "IngestJobService",
use_legacy_error_serialization
)]
pub trait IngestJobService {
#[endpoint(
method = GET,
path = "/ingest/v1/ingest-job/{ingestJobRid}",
name = "getIngestJob",
produces = conjure_http::server::StdResponseSerializer
)]
fn get_ingest_job(
&self,
#[auth]
auth_: conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
decoder = conjure_http::server::conjure::FromPlainDecoder,
log_as = "ingestJobRid",
safe
)]
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",
produces = conjure_http::server::StdResponseSerializer
)]
fn search_ingest_jobs(
&self,
#[auth]
auth_: conjure_object::BearerToken,
#[body(deserializer = conjure_http::server::StdRequestDeserializer)]
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_endpoints(
name = "IngestJobService",
use_legacy_error_serialization
)]
pub trait AsyncIngestJobService {
#[endpoint(
method = GET,
path = "/ingest/v1/ingest-job/{ingestJobRid}",
name = "getIngestJob",
produces = conjure_http::server::StdResponseSerializer
)]
async fn get_ingest_job(
&self,
#[auth]
auth_: conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
decoder = conjure_http::server::conjure::FromPlainDecoder,
log_as = "ingestJobRid",
safe
)]
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",
produces = conjure_http::server::StdResponseSerializer
)]
async fn search_ingest_jobs(
&self,
#[auth]
auth_: conjure_object::BearerToken,
#[body(deserializer = conjure_http::server::StdRequestDeserializer)]
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_endpoints(
name = "IngestJobService",
use_legacy_error_serialization,
local
)]
pub trait LocalAsyncIngestJobService {
#[endpoint(
method = GET,
path = "/ingest/v1/ingest-job/{ingestJobRid}",
name = "getIngestJob",
produces = conjure_http::server::StdResponseSerializer
)]
async fn get_ingest_job(
&self,
#[auth]
auth_: conjure_object::BearerToken,
#[path(
name = "ingestJobRid",
decoder = conjure_http::server::conjure::FromPlainDecoder,
log_as = "ingestJobRid",
safe
)]
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",
produces = conjure_http::server::StdResponseSerializer
)]
async fn search_ingest_jobs(
&self,
#[auth]
auth_: conjure_object::BearerToken,
#[body(deserializer = conjure_http::server::StdRequestDeserializer)]
request: super::super::super::super::objects::ingest::api::SearchIngestJobsRequest,
) -> Result<
super::super::super::super::objects::ingest::api::SearchIngestJobsResponse,
conjure_http::private::Error,
>;
}