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

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

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