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

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