nominal_api/conjure/endpoints/ingest/api/
streaming_session_service.rs

1use conjure_http::endpoint;
2#[conjure_http::conjure_endpoints(
3    name = "StreamingSessionService",
4    use_legacy_error_serialization
5)]
6pub trait StreamingSessionService {
7    #[endpoint(
8        method = POST,
9        path = "/ingest/v1/internal/streaming-session/dataset/{datasetRid}/resolve",
10        name = "resolve",
11        produces = conjure_http::server::StdResponseSerializer
12    )]
13    fn resolve(
14        &self,
15        #[auth]
16        auth_: conjure_object::BearerToken,
17        #[path(
18            name = "datasetRid",
19            decoder = conjure_http::server::conjure::FromPlainDecoder,
20            log_as = "datasetRid"
21        )]
22        dataset_rid: conjure_object::ResourceIdentifier,
23        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
24        request: super::super::super::super::objects::ingest::api::ResolveStreamingSessionRequest,
25    ) -> Result<
26        super::super::super::super::objects::ingest::api::ResolveStreamingSessionResponse,
27        conjure_http::private::Error,
28    >;
29    #[endpoint(
30        method = PUT,
31        path = "/ingest/v1/internal/streaming-session/{sessionRid}/heartbeat",
32        name = "heartbeat"
33    )]
34    fn heartbeat(
35        &self,
36        #[auth]
37        auth_: conjure_object::BearerToken,
38        #[path(
39            name = "sessionRid",
40            decoder = conjure_http::server::conjure::FromPlainDecoder,
41            log_as = "sessionRid"
42        )]
43        session_rid: conjure_object::ResourceIdentifier,
44        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
45        request: super::super::super::super::objects::ingest::api::HeartbeatStreamingSessionRequest,
46    ) -> Result<(), conjure_http::private::Error>;
47    /// Returns a paginated list of streaming sessions, optionally filtered by dataset.
48    #[endpoint(
49        method = POST,
50        path = "/ingest/v1/streaming-sessions/search",
51        name = "searchStreamingSessions",
52        produces = conjure_http::server::StdResponseSerializer
53    )]
54    fn search_streaming_sessions(
55        &self,
56        #[auth]
57        auth_: conjure_object::BearerToken,
58        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
59        request: super::super::super::super::objects::ingest::api::SearchStreamingSessionsRequest,
60    ) -> Result<
61        super::super::super::super::objects::ingest::api::SearchStreamingSessionsResponse,
62        conjure_http::private::Error,
63    >;
64}
65#[conjure_http::conjure_endpoints(
66    name = "StreamingSessionService",
67    use_legacy_error_serialization
68)]
69pub trait AsyncStreamingSessionService {
70    #[endpoint(
71        method = POST,
72        path = "/ingest/v1/internal/streaming-session/dataset/{datasetRid}/resolve",
73        name = "resolve",
74        produces = conjure_http::server::StdResponseSerializer
75    )]
76    async fn resolve(
77        &self,
78        #[auth]
79        auth_: conjure_object::BearerToken,
80        #[path(
81            name = "datasetRid",
82            decoder = conjure_http::server::conjure::FromPlainDecoder,
83            log_as = "datasetRid"
84        )]
85        dataset_rid: conjure_object::ResourceIdentifier,
86        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
87        request: super::super::super::super::objects::ingest::api::ResolveStreamingSessionRequest,
88    ) -> Result<
89        super::super::super::super::objects::ingest::api::ResolveStreamingSessionResponse,
90        conjure_http::private::Error,
91    >;
92    #[endpoint(
93        method = PUT,
94        path = "/ingest/v1/internal/streaming-session/{sessionRid}/heartbeat",
95        name = "heartbeat"
96    )]
97    async fn heartbeat(
98        &self,
99        #[auth]
100        auth_: conjure_object::BearerToken,
101        #[path(
102            name = "sessionRid",
103            decoder = conjure_http::server::conjure::FromPlainDecoder,
104            log_as = "sessionRid"
105        )]
106        session_rid: conjure_object::ResourceIdentifier,
107        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
108        request: super::super::super::super::objects::ingest::api::HeartbeatStreamingSessionRequest,
109    ) -> Result<(), conjure_http::private::Error>;
110    /// Returns a paginated list of streaming sessions, optionally filtered by dataset.
111    #[endpoint(
112        method = POST,
113        path = "/ingest/v1/streaming-sessions/search",
114        name = "searchStreamingSessions",
115        produces = conjure_http::server::StdResponseSerializer
116    )]
117    async fn search_streaming_sessions(
118        &self,
119        #[auth]
120        auth_: conjure_object::BearerToken,
121        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
122        request: super::super::super::super::objects::ingest::api::SearchStreamingSessionsRequest,
123    ) -> Result<
124        super::super::super::super::objects::ingest::api::SearchStreamingSessionsResponse,
125        conjure_http::private::Error,
126    >;
127}
128#[conjure_http::conjure_endpoints(
129    name = "StreamingSessionService",
130    use_legacy_error_serialization,
131    local
132)]
133pub trait LocalAsyncStreamingSessionService {
134    #[endpoint(
135        method = POST,
136        path = "/ingest/v1/internal/streaming-session/dataset/{datasetRid}/resolve",
137        name = "resolve",
138        produces = conjure_http::server::StdResponseSerializer
139    )]
140    async fn resolve(
141        &self,
142        #[auth]
143        auth_: conjure_object::BearerToken,
144        #[path(
145            name = "datasetRid",
146            decoder = conjure_http::server::conjure::FromPlainDecoder,
147            log_as = "datasetRid"
148        )]
149        dataset_rid: conjure_object::ResourceIdentifier,
150        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
151        request: super::super::super::super::objects::ingest::api::ResolveStreamingSessionRequest,
152    ) -> Result<
153        super::super::super::super::objects::ingest::api::ResolveStreamingSessionResponse,
154        conjure_http::private::Error,
155    >;
156    #[endpoint(
157        method = PUT,
158        path = "/ingest/v1/internal/streaming-session/{sessionRid}/heartbeat",
159        name = "heartbeat"
160    )]
161    async fn heartbeat(
162        &self,
163        #[auth]
164        auth_: conjure_object::BearerToken,
165        #[path(
166            name = "sessionRid",
167            decoder = conjure_http::server::conjure::FromPlainDecoder,
168            log_as = "sessionRid"
169        )]
170        session_rid: conjure_object::ResourceIdentifier,
171        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
172        request: super::super::super::super::objects::ingest::api::HeartbeatStreamingSessionRequest,
173    ) -> Result<(), conjure_http::private::Error>;
174    /// Returns a paginated list of streaming sessions, optionally filtered by dataset.
175    #[endpoint(
176        method = POST,
177        path = "/ingest/v1/streaming-sessions/search",
178        name = "searchStreamingSessions",
179        produces = conjure_http::server::StdResponseSerializer
180    )]
181    async fn search_streaming_sessions(
182        &self,
183        #[auth]
184        auth_: conjure_object::BearerToken,
185        #[body(deserializer = conjure_http::server::StdRequestDeserializer)]
186        request: super::super::super::super::objects::ingest::api::SearchStreamingSessionsRequest,
187    ) -> Result<
188        super::super::super::super::objects::ingest::api::SearchStreamingSessionsResponse,
189        conjure_http::private::Error,
190    >;
191}
nominal_api/conjure/endpoints/ingest/api/streaming_session_service.rs

nominal_api/conjure/endpoints/ingest/api/
streaming_session_service.rs
