Skip to main content

nominal_api/conjure/clients/scout/jobs/api/
internal_job_service.rs

1use conjure_http::endpoint;
2/// The Internal Job Service is responsible for running jobs for checklist executions.
3#[conjure_http::conjure_client(name = "InternalJobService")]
4pub trait InternalJobService<
5    #[response_body]
6    I: Iterator<
7            Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
8        >,
9> {
10    /// Runs the requested job specs.
11    #[endpoint(
12        method = POST,
13        path = "/internal/jobs/v1/submitJobs",
14        name = "submitJobs",
15        accept = conjure_http::client::StdResponseDeserializer
16    )]
17    fn submit_jobs(
18        &self,
19        #[auth]
20        auth_: &conjure_object::BearerToken,
21        #[body(serializer = conjure_http::client::StdRequestSerializer)]
22        request: &super::super::super::super::super::objects::scout::checks::api::SubmitJobsRequest,
23    ) -> Result<
24        super::super::super::super::super::objects::scout::checks::api::SubmitJobsResponse,
25        conjure_http::private::Error,
26    >;
27}
28/// The Internal Job Service is responsible for running jobs for checklist executions.
29#[conjure_http::conjure_client(name = "InternalJobService")]
30pub trait AsyncInternalJobService<
31    #[response_body]
32    I: conjure_http::private::Stream<
33            Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
34        >,
35> {
36    /// Runs the requested job specs.
37    #[endpoint(
38        method = POST,
39        path = "/internal/jobs/v1/submitJobs",
40        name = "submitJobs",
41        accept = conjure_http::client::StdResponseDeserializer
42    )]
43    async fn submit_jobs(
44        &self,
45        #[auth]
46        auth_: &conjure_object::BearerToken,
47        #[body(serializer = conjure_http::client::StdRequestSerializer)]
48        request: &super::super::super::super::super::objects::scout::checks::api::SubmitJobsRequest,
49    ) -> Result<
50        super::super::super::super::super::objects::scout::checks::api::SubmitJobsResponse,
51        conjure_http::private::Error,
52    >;
53}
54/// The Internal Job Service is responsible for running jobs for checklist executions.
55#[conjure_http::conjure_client(name = "InternalJobService", local)]
56pub trait LocalAsyncInternalJobService<
57    #[response_body]
58    I: conjure_http::private::Stream<
59            Item = Result<conjure_http::private::Bytes, conjure_http::private::Error>,
60        >,
61> {
62    /// Runs the requested job specs.
63    #[endpoint(
64        method = POST,
65        path = "/internal/jobs/v1/submitJobs",
66        name = "submitJobs",
67        accept = conjure_http::client::StdResponseDeserializer
68    )]
69    async fn submit_jobs(
70        &self,
71        #[auth]
72        auth_: &conjure_object::BearerToken,
73        #[body(serializer = conjure_http::client::StdRequestSerializer)]
74        request: &super::super::super::super::super::objects::scout::checks::api::SubmitJobsRequest,
75    ) -> Result<
76        super::super::super::super::super::objects::scout::checks::api::SubmitJobsResponse,
77        conjure_http::private::Error,
78    >;
79}