1pub type OwnedGetMarketLayersRequestView = ::buffa::view::OwnedView<
5 crate::proto::polychart::v1::__buffa::view::GetMarketLayersRequestView<'static>,
6>;
7pub type OwnedGetMarketLayersResponseView = ::buffa::view::OwnedView<
9 crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<'static>,
10>;
11pub type OwnedListInboxMarketLayersRequestView = ::buffa::view::OwnedView<
13 crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersRequestView<'static>,
14>;
15pub type OwnedListInboxMarketLayersResponseView = ::buffa::view::OwnedView<
17 crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<
18 'static,
19 >,
20>;
21pub type OwnedGetLayerSnapshotRequestView = ::buffa::view::OwnedView<
23 crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotRequestView<'static>,
24>;
25pub type OwnedGetLayerSnapshotResponseView = ::buffa::view::OwnedView<
27 crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<'static>,
28>;
29pub type OwnedGetLayerSubscribeTokensRequestView = ::buffa::view::OwnedView<
31 crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensRequestView<
32 'static,
33 >,
34>;
35pub type OwnedGetLayerSubscribeTokensResponseView = ::buffa::view::OwnedView<
37 crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<
38 'static,
39 >,
40>;
41pub type OwnedResolveLayerShareTokenRequestView = ::buffa::view::OwnedView<
43 crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenRequestView<
44 'static,
45 >,
46>;
47pub type OwnedResolveLayerShareTokenResponseView = ::buffa::view::OwnedView<
49 crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<
50 'static,
51 >,
52>;
53pub type OwnedCreateLayerShareLinkRequestView = ::buffa::view::OwnedView<
55 crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkRequestView<'static>,
56>;
57pub type OwnedCreateLayerShareLinkResponseView = ::buffa::view::OwnedView<
59 crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<'static>,
60>;
61pub type OwnedRevokeLayerShareLinkRequestView = ::buffa::view::OwnedView<
63 crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkRequestView<'static>,
64>;
65pub type OwnedRevokeLayerShareLinkResponseView = ::buffa::view::OwnedView<
67 crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<'static>,
68>;
69pub type OwnedListOwnerPublishedLayersRequestView = ::buffa::view::OwnedView<
71 crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersRequestView<
72 'static,
73 >,
74>;
75pub type OwnedListOwnerPublishedLayersResponseView = ::buffa::view::OwnedView<
77 crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
78 'static,
79 >,
80>;
81pub type OwnedPublishLayerRequestView = ::buffa::view::OwnedView<
83 crate::proto::polychart::v1::__buffa::view::PublishLayerRequestView<'static>,
84>;
85pub type OwnedPublishLayerResponseView = ::buffa::view::OwnedView<
87 crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<'static>,
88>;
89pub type OwnedUnpublishLayerRequestView = ::buffa::view::OwnedView<
91 crate::proto::polychart::v1::__buffa::view::UnpublishLayerRequestView<'static>,
92>;
93pub type OwnedUnpublishLayerResponseView = ::buffa::view::OwnedView<
95 crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<'static>,
96>;
97pub type OwnedUpsertLayerRequestView = ::buffa::view::OwnedView<
99 crate::proto::polychart::v1::__buffa::view::UpsertLayerRequestView<'static>,
100>;
101pub type OwnedUpsertLayerResponseView = ::buffa::view::OwnedView<
103 crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<'static>,
104>;
105pub type OwnedDeleteLayerRequestView = ::buffa::view::OwnedView<
107 crate::proto::polychart::v1::__buffa::view::DeleteLayerRequestView<'static>,
108>;
109pub type OwnedDeleteLayerResponseView = ::buffa::view::OwnedView<
111 crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<'static>,
112>;
113pub type OwnedUpsertDrawingRequestView = ::buffa::view::OwnedView<
115 crate::proto::polychart::v1::__buffa::view::UpsertDrawingRequestView<'static>,
116>;
117pub type OwnedUpsertDrawingResponseView = ::buffa::view::OwnedView<
119 crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<'static>,
120>;
121pub type OwnedDeleteDrawingRequestView = ::buffa::view::OwnedView<
123 crate::proto::polychart::v1::__buffa::view::DeleteDrawingRequestView<'static>,
124>;
125pub type OwnedDeleteDrawingResponseView = ::buffa::view::OwnedView<
127 crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<'static>,
128>;
129pub type OwnedSetLayerSubscriptionsRequestView = ::buffa::view::OwnedView<
131 crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsRequestView<'static>,
132>;
133pub type OwnedSetLayerSubscriptionsResponseView = ::buffa::view::OwnedView<
135 crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<
136 'static,
137 >,
138>;
139impl ::connectrpc::Encodable<crate::proto::polychart::v1::GetMarketLayersResponse>
140for crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<'_> {
141 fn encode(
142 &self,
143 codec: ::connectrpc::CodecFormat,
144 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
145 ::connectrpc::__codegen::encode_view_body(self, codec)
146 }
147}
148impl ::connectrpc::Encodable<crate::proto::polychart::v1::GetMarketLayersResponse>
149for ::buffa::view::OwnedView<
150 crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<'static>,
151> {
152 fn encode(
153 &self,
154 codec: ::connectrpc::CodecFormat,
155 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
156 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
157 }
158}
159impl ::connectrpc::Encodable<crate::proto::polychart::v1::ListInboxMarketLayersResponse>
160for crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<'_> {
161 fn encode(
162 &self,
163 codec: ::connectrpc::CodecFormat,
164 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
165 ::connectrpc::__codegen::encode_view_body(self, codec)
166 }
167}
168impl ::connectrpc::Encodable<crate::proto::polychart::v1::ListInboxMarketLayersResponse>
169for ::buffa::view::OwnedView<
170 crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<
171 'static,
172 >,
173> {
174 fn encode(
175 &self,
176 codec: ::connectrpc::CodecFormat,
177 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
178 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
179 }
180}
181impl ::connectrpc::Encodable<crate::proto::polychart::v1::GetLayerSnapshotResponse>
182for crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<'_> {
183 fn encode(
184 &self,
185 codec: ::connectrpc::CodecFormat,
186 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
187 ::connectrpc::__codegen::encode_view_body(self, codec)
188 }
189}
190impl ::connectrpc::Encodable<crate::proto::polychart::v1::GetLayerSnapshotResponse>
191for ::buffa::view::OwnedView<
192 crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<'static>,
193> {
194 fn encode(
195 &self,
196 codec: ::connectrpc::CodecFormat,
197 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
198 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
199 }
200}
201impl ::connectrpc::Encodable<
202 crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
203>
204for crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<'_> {
205 fn encode(
206 &self,
207 codec: ::connectrpc::CodecFormat,
208 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
209 ::connectrpc::__codegen::encode_view_body(self, codec)
210 }
211}
212impl ::connectrpc::Encodable<
213 crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
214>
215for ::buffa::view::OwnedView<
216 crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<
217 'static,
218 >,
219> {
220 fn encode(
221 &self,
222 codec: ::connectrpc::CodecFormat,
223 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
224 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
225 }
226}
227impl ::connectrpc::Encodable<crate::proto::polychart::v1::ResolveLayerShareTokenResponse>
228for crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<'_> {
229 fn encode(
230 &self,
231 codec: ::connectrpc::CodecFormat,
232 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
233 ::connectrpc::__codegen::encode_view_body(self, codec)
234 }
235}
236impl ::connectrpc::Encodable<crate::proto::polychart::v1::ResolveLayerShareTokenResponse>
237for ::buffa::view::OwnedView<
238 crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<
239 'static,
240 >,
241> {
242 fn encode(
243 &self,
244 codec: ::connectrpc::CodecFormat,
245 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
246 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
247 }
248}
249impl ::connectrpc::Encodable<crate::proto::polychart::v1::CreateLayerShareLinkResponse>
250for crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<'_> {
251 fn encode(
252 &self,
253 codec: ::connectrpc::CodecFormat,
254 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
255 ::connectrpc::__codegen::encode_view_body(self, codec)
256 }
257}
258impl ::connectrpc::Encodable<crate::proto::polychart::v1::CreateLayerShareLinkResponse>
259for ::buffa::view::OwnedView<
260 crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<'static>,
261> {
262 fn encode(
263 &self,
264 codec: ::connectrpc::CodecFormat,
265 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
266 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
267 }
268}
269impl ::connectrpc::Encodable<crate::proto::polychart::v1::RevokeLayerShareLinkResponse>
270for crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<'_> {
271 fn encode(
272 &self,
273 codec: ::connectrpc::CodecFormat,
274 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
275 ::connectrpc::__codegen::encode_view_body(self, codec)
276 }
277}
278impl ::connectrpc::Encodable<crate::proto::polychart::v1::RevokeLayerShareLinkResponse>
279for ::buffa::view::OwnedView<
280 crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<'static>,
281> {
282 fn encode(
283 &self,
284 codec: ::connectrpc::CodecFormat,
285 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
286 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
287 }
288}
289impl ::connectrpc::Encodable<
290 crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
291>
292for crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
293 '_,
294> {
295 fn encode(
296 &self,
297 codec: ::connectrpc::CodecFormat,
298 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
299 ::connectrpc::__codegen::encode_view_body(self, codec)
300 }
301}
302impl ::connectrpc::Encodable<
303 crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
304>
305for ::buffa::view::OwnedView<
306 crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
307 'static,
308 >,
309> {
310 fn encode(
311 &self,
312 codec: ::connectrpc::CodecFormat,
313 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
314 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
315 }
316}
317impl ::connectrpc::Encodable<crate::proto::polychart::v1::PublishLayerResponse>
318for crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<'_> {
319 fn encode(
320 &self,
321 codec: ::connectrpc::CodecFormat,
322 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
323 ::connectrpc::__codegen::encode_view_body(self, codec)
324 }
325}
326impl ::connectrpc::Encodable<crate::proto::polychart::v1::PublishLayerResponse>
327for ::buffa::view::OwnedView<
328 crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<'static>,
329> {
330 fn encode(
331 &self,
332 codec: ::connectrpc::CodecFormat,
333 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
334 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
335 }
336}
337impl ::connectrpc::Encodable<crate::proto::polychart::v1::UnpublishLayerResponse>
338for crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<'_> {
339 fn encode(
340 &self,
341 codec: ::connectrpc::CodecFormat,
342 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
343 ::connectrpc::__codegen::encode_view_body(self, codec)
344 }
345}
346impl ::connectrpc::Encodable<crate::proto::polychart::v1::UnpublishLayerResponse>
347for ::buffa::view::OwnedView<
348 crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<'static>,
349> {
350 fn encode(
351 &self,
352 codec: ::connectrpc::CodecFormat,
353 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
354 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
355 }
356}
357impl ::connectrpc::Encodable<crate::proto::polychart::v1::UpsertLayerResponse>
358for crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<'_> {
359 fn encode(
360 &self,
361 codec: ::connectrpc::CodecFormat,
362 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
363 ::connectrpc::__codegen::encode_view_body(self, codec)
364 }
365}
366impl ::connectrpc::Encodable<crate::proto::polychart::v1::UpsertLayerResponse>
367for ::buffa::view::OwnedView<
368 crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<'static>,
369> {
370 fn encode(
371 &self,
372 codec: ::connectrpc::CodecFormat,
373 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
374 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
375 }
376}
377impl ::connectrpc::Encodable<crate::proto::polychart::v1::DeleteLayerResponse>
378for crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<'_> {
379 fn encode(
380 &self,
381 codec: ::connectrpc::CodecFormat,
382 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
383 ::connectrpc::__codegen::encode_view_body(self, codec)
384 }
385}
386impl ::connectrpc::Encodable<crate::proto::polychart::v1::DeleteLayerResponse>
387for ::buffa::view::OwnedView<
388 crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<'static>,
389> {
390 fn encode(
391 &self,
392 codec: ::connectrpc::CodecFormat,
393 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
394 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
395 }
396}
397impl ::connectrpc::Encodable<crate::proto::polychart::v1::UpsertDrawingResponse>
398for crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<'_> {
399 fn encode(
400 &self,
401 codec: ::connectrpc::CodecFormat,
402 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
403 ::connectrpc::__codegen::encode_view_body(self, codec)
404 }
405}
406impl ::connectrpc::Encodable<crate::proto::polychart::v1::UpsertDrawingResponse>
407for ::buffa::view::OwnedView<
408 crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<'static>,
409> {
410 fn encode(
411 &self,
412 codec: ::connectrpc::CodecFormat,
413 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
414 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
415 }
416}
417impl ::connectrpc::Encodable<crate::proto::polychart::v1::DeleteDrawingResponse>
418for crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<'_> {
419 fn encode(
420 &self,
421 codec: ::connectrpc::CodecFormat,
422 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
423 ::connectrpc::__codegen::encode_view_body(self, codec)
424 }
425}
426impl ::connectrpc::Encodable<crate::proto::polychart::v1::DeleteDrawingResponse>
427for ::buffa::view::OwnedView<
428 crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<'static>,
429> {
430 fn encode(
431 &self,
432 codec: ::connectrpc::CodecFormat,
433 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
434 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
435 }
436}
437impl ::connectrpc::Encodable<crate::proto::polychart::v1::SetLayerSubscriptionsResponse>
438for crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<'_> {
439 fn encode(
440 &self,
441 codec: ::connectrpc::CodecFormat,
442 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
443 ::connectrpc::__codegen::encode_view_body(self, codec)
444 }
445}
446impl ::connectrpc::Encodable<crate::proto::polychart::v1::SetLayerSubscriptionsResponse>
447for ::buffa::view::OwnedView<
448 crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<
449 'static,
450 >,
451> {
452 fn encode(
453 &self,
454 codec: ::connectrpc::CodecFormat,
455 ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
456 ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
457 }
458}
459pub const POLYCHART_SERVICE_SERVICE_NAME: &str = "polychart.v1.PolychartService";
461pub const POLYCHART_SERVICE_GET_MARKET_LAYERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
466 "/polychart.v1.PolychartService/GetMarketLayers",
467 ::connectrpc::StreamType::Unary,
468 )
469 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
470pub const POLYCHART_SERVICE_LIST_INBOX_MARKET_LAYERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
475 "/polychart.v1.PolychartService/ListInboxMarketLayers",
476 ::connectrpc::StreamType::Unary,
477 )
478 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
479pub const POLYCHART_SERVICE_GET_LAYER_SNAPSHOT_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
484 "/polychart.v1.PolychartService/GetLayerSnapshot",
485 ::connectrpc::StreamType::Unary,
486 )
487 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
488pub const POLYCHART_SERVICE_GET_LAYER_SUBSCRIBE_TOKENS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
493 "/polychart.v1.PolychartService/GetLayerSubscribeTokens",
494 ::connectrpc::StreamType::Unary,
495 )
496 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
497pub const POLYCHART_SERVICE_RESOLVE_LAYER_SHARE_TOKEN_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
502 "/polychart.v1.PolychartService/ResolveLayerShareToken",
503 ::connectrpc::StreamType::Unary,
504 )
505 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
506pub const POLYCHART_SERVICE_CREATE_LAYER_SHARE_LINK_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
511 "/polychart.v1.PolychartService/CreateLayerShareLink",
512 ::connectrpc::StreamType::Unary,
513 )
514 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
515pub const POLYCHART_SERVICE_REVOKE_LAYER_SHARE_LINK_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
520 "/polychart.v1.PolychartService/RevokeLayerShareLink",
521 ::connectrpc::StreamType::Unary,
522 )
523 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
524pub const POLYCHART_SERVICE_LIST_OWNER_PUBLISHED_LAYERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
529 "/polychart.v1.PolychartService/ListOwnerPublishedLayers",
530 ::connectrpc::StreamType::Unary,
531 )
532 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
533pub const POLYCHART_SERVICE_PUBLISH_LAYER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
538 "/polychart.v1.PolychartService/PublishLayer",
539 ::connectrpc::StreamType::Unary,
540 )
541 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
542pub const POLYCHART_SERVICE_UNPUBLISH_LAYER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
547 "/polychart.v1.PolychartService/UnpublishLayer",
548 ::connectrpc::StreamType::Unary,
549 )
550 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
551pub const POLYCHART_SERVICE_UPSERT_LAYER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
556 "/polychart.v1.PolychartService/UpsertLayer",
557 ::connectrpc::StreamType::Unary,
558 )
559 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
560pub const POLYCHART_SERVICE_DELETE_LAYER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
565 "/polychart.v1.PolychartService/DeleteLayer",
566 ::connectrpc::StreamType::Unary,
567 )
568 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
569pub const POLYCHART_SERVICE_UPSERT_DRAWING_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
574 "/polychart.v1.PolychartService/UpsertDrawing",
575 ::connectrpc::StreamType::Unary,
576 )
577 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
578pub const POLYCHART_SERVICE_DELETE_DRAWING_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
583 "/polychart.v1.PolychartService/DeleteDrawing",
584 ::connectrpc::StreamType::Unary,
585 )
586 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
587pub const POLYCHART_SERVICE_SET_LAYER_SUBSCRIPTIONS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
592 "/polychart.v1.PolychartService/SetLayerSubscriptions",
593 ::connectrpc::StreamType::Unary,
594 )
595 .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
596#[allow(clippy::type_complexity)]
646pub trait PolychartService: Send + Sync + 'static {
647 fn get_market_layers<'a>(
657 &'a self,
658 ctx: ::connectrpc::RequestContext,
659 request: ::connectrpc::ServiceRequest<
660 '_,
661 crate::proto::polychart::v1::GetMarketLayersRequest,
662 >,
663 ) -> impl ::std::future::Future<
664 Output = ::connectrpc::ServiceResult<
665 impl ::connectrpc::Encodable<
666 crate::proto::polychart::v1::GetMarketLayersResponse,
667 > + Send + use<'a, Self>,
668 >,
669 > + Send;
670 fn list_inbox_market_layers<'a>(
680 &'a self,
681 ctx: ::connectrpc::RequestContext,
682 request: ::connectrpc::ServiceRequest<
683 '_,
684 crate::proto::polychart::v1::ListInboxMarketLayersRequest,
685 >,
686 ) -> impl ::std::future::Future<
687 Output = ::connectrpc::ServiceResult<
688 impl ::connectrpc::Encodable<
689 crate::proto::polychart::v1::ListInboxMarketLayersResponse,
690 > + Send + use<'a, Self>,
691 >,
692 > + Send;
693 fn get_layer_snapshot<'a>(
703 &'a self,
704 ctx: ::connectrpc::RequestContext,
705 request: ::connectrpc::ServiceRequest<
706 '_,
707 crate::proto::polychart::v1::GetLayerSnapshotRequest,
708 >,
709 ) -> impl ::std::future::Future<
710 Output = ::connectrpc::ServiceResult<
711 impl ::connectrpc::Encodable<
712 crate::proto::polychart::v1::GetLayerSnapshotResponse,
713 > + Send + use<'a, Self>,
714 >,
715 > + Send;
716 fn get_layer_subscribe_tokens<'a>(
726 &'a self,
727 ctx: ::connectrpc::RequestContext,
728 request: ::connectrpc::ServiceRequest<
729 '_,
730 crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
731 >,
732 ) -> impl ::std::future::Future<
733 Output = ::connectrpc::ServiceResult<
734 impl ::connectrpc::Encodable<
735 crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
736 > + Send + use<'a, Self>,
737 >,
738 > + Send;
739 fn resolve_layer_share_token<'a>(
749 &'a self,
750 ctx: ::connectrpc::RequestContext,
751 request: ::connectrpc::ServiceRequest<
752 '_,
753 crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
754 >,
755 ) -> impl ::std::future::Future<
756 Output = ::connectrpc::ServiceResult<
757 impl ::connectrpc::Encodable<
758 crate::proto::polychart::v1::ResolveLayerShareTokenResponse,
759 > + Send + use<'a, Self>,
760 >,
761 > + Send;
762 fn create_layer_share_link<'a>(
772 &'a self,
773 ctx: ::connectrpc::RequestContext,
774 request: ::connectrpc::ServiceRequest<
775 '_,
776 crate::proto::polychart::v1::CreateLayerShareLinkRequest,
777 >,
778 ) -> impl ::std::future::Future<
779 Output = ::connectrpc::ServiceResult<
780 impl ::connectrpc::Encodable<
781 crate::proto::polychart::v1::CreateLayerShareLinkResponse,
782 > + Send + use<'a, Self>,
783 >,
784 > + Send;
785 fn revoke_layer_share_link<'a>(
795 &'a self,
796 ctx: ::connectrpc::RequestContext,
797 request: ::connectrpc::ServiceRequest<
798 '_,
799 crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
800 >,
801 ) -> impl ::std::future::Future<
802 Output = ::connectrpc::ServiceResult<
803 impl ::connectrpc::Encodable<
804 crate::proto::polychart::v1::RevokeLayerShareLinkResponse,
805 > + Send + use<'a, Self>,
806 >,
807 > + Send;
808 fn list_owner_published_layers<'a>(
818 &'a self,
819 ctx: ::connectrpc::RequestContext,
820 request: ::connectrpc::ServiceRequest<
821 '_,
822 crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
823 >,
824 ) -> impl ::std::future::Future<
825 Output = ::connectrpc::ServiceResult<
826 impl ::connectrpc::Encodable<
827 crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
828 > + Send + use<'a, Self>,
829 >,
830 > + Send;
831 fn publish_layer<'a>(
841 &'a self,
842 ctx: ::connectrpc::RequestContext,
843 request: ::connectrpc::ServiceRequest<
844 '_,
845 crate::proto::polychart::v1::PublishLayerRequest,
846 >,
847 ) -> impl ::std::future::Future<
848 Output = ::connectrpc::ServiceResult<
849 impl ::connectrpc::Encodable<
850 crate::proto::polychart::v1::PublishLayerResponse,
851 > + Send + use<'a, Self>,
852 >,
853 > + Send;
854 fn unpublish_layer<'a>(
864 &'a self,
865 ctx: ::connectrpc::RequestContext,
866 request: ::connectrpc::ServiceRequest<
867 '_,
868 crate::proto::polychart::v1::UnpublishLayerRequest,
869 >,
870 ) -> impl ::std::future::Future<
871 Output = ::connectrpc::ServiceResult<
872 impl ::connectrpc::Encodable<
873 crate::proto::polychart::v1::UnpublishLayerResponse,
874 > + Send + use<'a, Self>,
875 >,
876 > + Send;
877 fn upsert_layer<'a>(
887 &'a self,
888 ctx: ::connectrpc::RequestContext,
889 request: ::connectrpc::ServiceRequest<
890 '_,
891 crate::proto::polychart::v1::UpsertLayerRequest,
892 >,
893 ) -> impl ::std::future::Future<
894 Output = ::connectrpc::ServiceResult<
895 impl ::connectrpc::Encodable<
896 crate::proto::polychart::v1::UpsertLayerResponse,
897 > + Send + use<'a, Self>,
898 >,
899 > + Send;
900 fn delete_layer<'a>(
910 &'a self,
911 ctx: ::connectrpc::RequestContext,
912 request: ::connectrpc::ServiceRequest<
913 '_,
914 crate::proto::polychart::v1::DeleteLayerRequest,
915 >,
916 ) -> impl ::std::future::Future<
917 Output = ::connectrpc::ServiceResult<
918 impl ::connectrpc::Encodable<
919 crate::proto::polychart::v1::DeleteLayerResponse,
920 > + Send + use<'a, Self>,
921 >,
922 > + Send;
923 fn upsert_drawing<'a>(
933 &'a self,
934 ctx: ::connectrpc::RequestContext,
935 request: ::connectrpc::ServiceRequest<
936 '_,
937 crate::proto::polychart::v1::UpsertDrawingRequest,
938 >,
939 ) -> impl ::std::future::Future<
940 Output = ::connectrpc::ServiceResult<
941 impl ::connectrpc::Encodable<
942 crate::proto::polychart::v1::UpsertDrawingResponse,
943 > + Send + use<'a, Self>,
944 >,
945 > + Send;
946 fn delete_drawing<'a>(
956 &'a self,
957 ctx: ::connectrpc::RequestContext,
958 request: ::connectrpc::ServiceRequest<
959 '_,
960 crate::proto::polychart::v1::DeleteDrawingRequest,
961 >,
962 ) -> impl ::std::future::Future<
963 Output = ::connectrpc::ServiceResult<
964 impl ::connectrpc::Encodable<
965 crate::proto::polychart::v1::DeleteDrawingResponse,
966 > + Send + use<'a, Self>,
967 >,
968 > + Send;
969 fn set_layer_subscriptions<'a>(
979 &'a self,
980 ctx: ::connectrpc::RequestContext,
981 request: ::connectrpc::ServiceRequest<
982 '_,
983 crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
984 >,
985 ) -> impl ::std::future::Future<
986 Output = ::connectrpc::ServiceResult<
987 impl ::connectrpc::Encodable<
988 crate::proto::polychart::v1::SetLayerSubscriptionsResponse,
989 > + Send + use<'a, Self>,
990 >,
991 > + Send;
992}
993pub trait PolychartServiceExt: PolychartService {
1009 fn register(
1014 self: ::std::sync::Arc<Self>,
1015 router: ::connectrpc::Router,
1016 ) -> ::connectrpc::Router;
1017}
1018impl<S: PolychartService> PolychartServiceExt for S {
1019 fn register(
1020 self: ::std::sync::Arc<Self>,
1021 router: ::connectrpc::Router,
1022 ) -> ::connectrpc::Router {
1023 router
1024 .route_view(
1025 POLYCHART_SERVICE_SERVICE_NAME,
1026 "GetMarketLayers",
1027 {
1028 let svc = ::std::sync::Arc::clone(&self);
1029 ::connectrpc::view_handler_fn(move |
1030 ctx,
1031 req: ::buffa::view::OwnedView<
1032 crate::proto::polychart::v1::__buffa::view::GetMarketLayersRequestView<
1033 'static,
1034 >,
1035 >,
1036 format|
1037 {
1038 let svc = ::std::sync::Arc::clone(&svc);
1039 async move {
1040 let sreq = ::connectrpc::ServiceRequest::<
1041 crate::proto::polychart::v1::GetMarketLayersRequest,
1042 >::from_parts(req.reborrow(), req.bytes());
1043 svc.get_market_layers(ctx, sreq)
1044 .await?
1045 .encode::<
1046 crate::proto::polychart::v1::GetMarketLayersResponse,
1047 >(format)
1048 }
1049 })
1050 },
1051 )
1052 .with_spec(POLYCHART_SERVICE_GET_MARKET_LAYERS_SPEC)
1053 .route_view(
1054 POLYCHART_SERVICE_SERVICE_NAME,
1055 "ListInboxMarketLayers",
1056 {
1057 let svc = ::std::sync::Arc::clone(&self);
1058 ::connectrpc::view_handler_fn(move |
1059 ctx,
1060 req: ::buffa::view::OwnedView<
1061 crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersRequestView<
1062 'static,
1063 >,
1064 >,
1065 format|
1066 {
1067 let svc = ::std::sync::Arc::clone(&svc);
1068 async move {
1069 let sreq = ::connectrpc::ServiceRequest::<
1070 crate::proto::polychart::v1::ListInboxMarketLayersRequest,
1071 >::from_parts(req.reborrow(), req.bytes());
1072 svc.list_inbox_market_layers(ctx, sreq)
1073 .await?
1074 .encode::<
1075 crate::proto::polychart::v1::ListInboxMarketLayersResponse,
1076 >(format)
1077 }
1078 })
1079 },
1080 )
1081 .with_spec(POLYCHART_SERVICE_LIST_INBOX_MARKET_LAYERS_SPEC)
1082 .route_view(
1083 POLYCHART_SERVICE_SERVICE_NAME,
1084 "GetLayerSnapshot",
1085 {
1086 let svc = ::std::sync::Arc::clone(&self);
1087 ::connectrpc::view_handler_fn(move |
1088 ctx,
1089 req: ::buffa::view::OwnedView<
1090 crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotRequestView<
1091 'static,
1092 >,
1093 >,
1094 format|
1095 {
1096 let svc = ::std::sync::Arc::clone(&svc);
1097 async move {
1098 let sreq = ::connectrpc::ServiceRequest::<
1099 crate::proto::polychart::v1::GetLayerSnapshotRequest,
1100 >::from_parts(req.reborrow(), req.bytes());
1101 svc.get_layer_snapshot(ctx, sreq)
1102 .await?
1103 .encode::<
1104 crate::proto::polychart::v1::GetLayerSnapshotResponse,
1105 >(format)
1106 }
1107 })
1108 },
1109 )
1110 .with_spec(POLYCHART_SERVICE_GET_LAYER_SNAPSHOT_SPEC)
1111 .route_view(
1112 POLYCHART_SERVICE_SERVICE_NAME,
1113 "GetLayerSubscribeTokens",
1114 {
1115 let svc = ::std::sync::Arc::clone(&self);
1116 ::connectrpc::view_handler_fn(move |
1117 ctx,
1118 req: ::buffa::view::OwnedView<
1119 crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensRequestView<
1120 'static,
1121 >,
1122 >,
1123 format|
1124 {
1125 let svc = ::std::sync::Arc::clone(&svc);
1126 async move {
1127 let sreq = ::connectrpc::ServiceRequest::<
1128 crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
1129 >::from_parts(req.reborrow(), req.bytes());
1130 svc.get_layer_subscribe_tokens(ctx, sreq)
1131 .await?
1132 .encode::<
1133 crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
1134 >(format)
1135 }
1136 })
1137 },
1138 )
1139 .with_spec(POLYCHART_SERVICE_GET_LAYER_SUBSCRIBE_TOKENS_SPEC)
1140 .route_view(
1141 POLYCHART_SERVICE_SERVICE_NAME,
1142 "ResolveLayerShareToken",
1143 {
1144 let svc = ::std::sync::Arc::clone(&self);
1145 ::connectrpc::view_handler_fn(move |
1146 ctx,
1147 req: ::buffa::view::OwnedView<
1148 crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenRequestView<
1149 'static,
1150 >,
1151 >,
1152 format|
1153 {
1154 let svc = ::std::sync::Arc::clone(&svc);
1155 async move {
1156 let sreq = ::connectrpc::ServiceRequest::<
1157 crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
1158 >::from_parts(req.reborrow(), req.bytes());
1159 svc.resolve_layer_share_token(ctx, sreq)
1160 .await?
1161 .encode::<
1162 crate::proto::polychart::v1::ResolveLayerShareTokenResponse,
1163 >(format)
1164 }
1165 })
1166 },
1167 )
1168 .with_spec(POLYCHART_SERVICE_RESOLVE_LAYER_SHARE_TOKEN_SPEC)
1169 .route_view(
1170 POLYCHART_SERVICE_SERVICE_NAME,
1171 "CreateLayerShareLink",
1172 {
1173 let svc = ::std::sync::Arc::clone(&self);
1174 ::connectrpc::view_handler_fn(move |
1175 ctx,
1176 req: ::buffa::view::OwnedView<
1177 crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkRequestView<
1178 'static,
1179 >,
1180 >,
1181 format|
1182 {
1183 let svc = ::std::sync::Arc::clone(&svc);
1184 async move {
1185 let sreq = ::connectrpc::ServiceRequest::<
1186 crate::proto::polychart::v1::CreateLayerShareLinkRequest,
1187 >::from_parts(req.reborrow(), req.bytes());
1188 svc.create_layer_share_link(ctx, sreq)
1189 .await?
1190 .encode::<
1191 crate::proto::polychart::v1::CreateLayerShareLinkResponse,
1192 >(format)
1193 }
1194 })
1195 },
1196 )
1197 .with_spec(POLYCHART_SERVICE_CREATE_LAYER_SHARE_LINK_SPEC)
1198 .route_view(
1199 POLYCHART_SERVICE_SERVICE_NAME,
1200 "RevokeLayerShareLink",
1201 {
1202 let svc = ::std::sync::Arc::clone(&self);
1203 ::connectrpc::view_handler_fn(move |
1204 ctx,
1205 req: ::buffa::view::OwnedView<
1206 crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkRequestView<
1207 'static,
1208 >,
1209 >,
1210 format|
1211 {
1212 let svc = ::std::sync::Arc::clone(&svc);
1213 async move {
1214 let sreq = ::connectrpc::ServiceRequest::<
1215 crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
1216 >::from_parts(req.reborrow(), req.bytes());
1217 svc.revoke_layer_share_link(ctx, sreq)
1218 .await?
1219 .encode::<
1220 crate::proto::polychart::v1::RevokeLayerShareLinkResponse,
1221 >(format)
1222 }
1223 })
1224 },
1225 )
1226 .with_spec(POLYCHART_SERVICE_REVOKE_LAYER_SHARE_LINK_SPEC)
1227 .route_view(
1228 POLYCHART_SERVICE_SERVICE_NAME,
1229 "ListOwnerPublishedLayers",
1230 {
1231 let svc = ::std::sync::Arc::clone(&self);
1232 ::connectrpc::view_handler_fn(move |
1233 ctx,
1234 req: ::buffa::view::OwnedView<
1235 crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersRequestView<
1236 'static,
1237 >,
1238 >,
1239 format|
1240 {
1241 let svc = ::std::sync::Arc::clone(&svc);
1242 async move {
1243 let sreq = ::connectrpc::ServiceRequest::<
1244 crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
1245 >::from_parts(req.reborrow(), req.bytes());
1246 svc.list_owner_published_layers(ctx, sreq)
1247 .await?
1248 .encode::<
1249 crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
1250 >(format)
1251 }
1252 })
1253 },
1254 )
1255 .with_spec(POLYCHART_SERVICE_LIST_OWNER_PUBLISHED_LAYERS_SPEC)
1256 .route_view(
1257 POLYCHART_SERVICE_SERVICE_NAME,
1258 "PublishLayer",
1259 {
1260 let svc = ::std::sync::Arc::clone(&self);
1261 ::connectrpc::view_handler_fn(move |
1262 ctx,
1263 req: ::buffa::view::OwnedView<
1264 crate::proto::polychart::v1::__buffa::view::PublishLayerRequestView<
1265 'static,
1266 >,
1267 >,
1268 format|
1269 {
1270 let svc = ::std::sync::Arc::clone(&svc);
1271 async move {
1272 let sreq = ::connectrpc::ServiceRequest::<
1273 crate::proto::polychart::v1::PublishLayerRequest,
1274 >::from_parts(req.reborrow(), req.bytes());
1275 svc.publish_layer(ctx, sreq)
1276 .await?
1277 .encode::<
1278 crate::proto::polychart::v1::PublishLayerResponse,
1279 >(format)
1280 }
1281 })
1282 },
1283 )
1284 .with_spec(POLYCHART_SERVICE_PUBLISH_LAYER_SPEC)
1285 .route_view(
1286 POLYCHART_SERVICE_SERVICE_NAME,
1287 "UnpublishLayer",
1288 {
1289 let svc = ::std::sync::Arc::clone(&self);
1290 ::connectrpc::view_handler_fn(move |
1291 ctx,
1292 req: ::buffa::view::OwnedView<
1293 crate::proto::polychart::v1::__buffa::view::UnpublishLayerRequestView<
1294 'static,
1295 >,
1296 >,
1297 format|
1298 {
1299 let svc = ::std::sync::Arc::clone(&svc);
1300 async move {
1301 let sreq = ::connectrpc::ServiceRequest::<
1302 crate::proto::polychart::v1::UnpublishLayerRequest,
1303 >::from_parts(req.reborrow(), req.bytes());
1304 svc.unpublish_layer(ctx, sreq)
1305 .await?
1306 .encode::<
1307 crate::proto::polychart::v1::UnpublishLayerResponse,
1308 >(format)
1309 }
1310 })
1311 },
1312 )
1313 .with_spec(POLYCHART_SERVICE_UNPUBLISH_LAYER_SPEC)
1314 .route_view(
1315 POLYCHART_SERVICE_SERVICE_NAME,
1316 "UpsertLayer",
1317 {
1318 let svc = ::std::sync::Arc::clone(&self);
1319 ::connectrpc::view_handler_fn(move |
1320 ctx,
1321 req: ::buffa::view::OwnedView<
1322 crate::proto::polychart::v1::__buffa::view::UpsertLayerRequestView<
1323 'static,
1324 >,
1325 >,
1326 format|
1327 {
1328 let svc = ::std::sync::Arc::clone(&svc);
1329 async move {
1330 let sreq = ::connectrpc::ServiceRequest::<
1331 crate::proto::polychart::v1::UpsertLayerRequest,
1332 >::from_parts(req.reborrow(), req.bytes());
1333 svc.upsert_layer(ctx, sreq)
1334 .await?
1335 .encode::<
1336 crate::proto::polychart::v1::UpsertLayerResponse,
1337 >(format)
1338 }
1339 })
1340 },
1341 )
1342 .with_spec(POLYCHART_SERVICE_UPSERT_LAYER_SPEC)
1343 .route_view(
1344 POLYCHART_SERVICE_SERVICE_NAME,
1345 "DeleteLayer",
1346 {
1347 let svc = ::std::sync::Arc::clone(&self);
1348 ::connectrpc::view_handler_fn(move |
1349 ctx,
1350 req: ::buffa::view::OwnedView<
1351 crate::proto::polychart::v1::__buffa::view::DeleteLayerRequestView<
1352 'static,
1353 >,
1354 >,
1355 format|
1356 {
1357 let svc = ::std::sync::Arc::clone(&svc);
1358 async move {
1359 let sreq = ::connectrpc::ServiceRequest::<
1360 crate::proto::polychart::v1::DeleteLayerRequest,
1361 >::from_parts(req.reborrow(), req.bytes());
1362 svc.delete_layer(ctx, sreq)
1363 .await?
1364 .encode::<
1365 crate::proto::polychart::v1::DeleteLayerResponse,
1366 >(format)
1367 }
1368 })
1369 },
1370 )
1371 .with_spec(POLYCHART_SERVICE_DELETE_LAYER_SPEC)
1372 .route_view(
1373 POLYCHART_SERVICE_SERVICE_NAME,
1374 "UpsertDrawing",
1375 {
1376 let svc = ::std::sync::Arc::clone(&self);
1377 ::connectrpc::view_handler_fn(move |
1378 ctx,
1379 req: ::buffa::view::OwnedView<
1380 crate::proto::polychart::v1::__buffa::view::UpsertDrawingRequestView<
1381 'static,
1382 >,
1383 >,
1384 format|
1385 {
1386 let svc = ::std::sync::Arc::clone(&svc);
1387 async move {
1388 let sreq = ::connectrpc::ServiceRequest::<
1389 crate::proto::polychart::v1::UpsertDrawingRequest,
1390 >::from_parts(req.reborrow(), req.bytes());
1391 svc.upsert_drawing(ctx, sreq)
1392 .await?
1393 .encode::<
1394 crate::proto::polychart::v1::UpsertDrawingResponse,
1395 >(format)
1396 }
1397 })
1398 },
1399 )
1400 .with_spec(POLYCHART_SERVICE_UPSERT_DRAWING_SPEC)
1401 .route_view(
1402 POLYCHART_SERVICE_SERVICE_NAME,
1403 "DeleteDrawing",
1404 {
1405 let svc = ::std::sync::Arc::clone(&self);
1406 ::connectrpc::view_handler_fn(move |
1407 ctx,
1408 req: ::buffa::view::OwnedView<
1409 crate::proto::polychart::v1::__buffa::view::DeleteDrawingRequestView<
1410 'static,
1411 >,
1412 >,
1413 format|
1414 {
1415 let svc = ::std::sync::Arc::clone(&svc);
1416 async move {
1417 let sreq = ::connectrpc::ServiceRequest::<
1418 crate::proto::polychart::v1::DeleteDrawingRequest,
1419 >::from_parts(req.reborrow(), req.bytes());
1420 svc.delete_drawing(ctx, sreq)
1421 .await?
1422 .encode::<
1423 crate::proto::polychart::v1::DeleteDrawingResponse,
1424 >(format)
1425 }
1426 })
1427 },
1428 )
1429 .with_spec(POLYCHART_SERVICE_DELETE_DRAWING_SPEC)
1430 .route_view(
1431 POLYCHART_SERVICE_SERVICE_NAME,
1432 "SetLayerSubscriptions",
1433 {
1434 let svc = ::std::sync::Arc::clone(&self);
1435 ::connectrpc::view_handler_fn(move |
1436 ctx,
1437 req: ::buffa::view::OwnedView<
1438 crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsRequestView<
1439 'static,
1440 >,
1441 >,
1442 format|
1443 {
1444 let svc = ::std::sync::Arc::clone(&svc);
1445 async move {
1446 let sreq = ::connectrpc::ServiceRequest::<
1447 crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
1448 >::from_parts(req.reborrow(), req.bytes());
1449 svc.set_layer_subscriptions(ctx, sreq)
1450 .await?
1451 .encode::<
1452 crate::proto::polychart::v1::SetLayerSubscriptionsResponse,
1453 >(format)
1454 }
1455 })
1456 },
1457 )
1458 .with_spec(POLYCHART_SERVICE_SET_LAYER_SUBSCRIPTIONS_SPEC)
1459 }
1460}
1461#[doc(hidden)]
1463pub struct PolychartServiceRegisterMarker;
1464impl<S: PolychartService> ::connectrpc::ServiceRegister<PolychartServiceRegisterMarker>
1465for ::std::sync::Arc<S> {
1466 fn register_service(self, router: ::connectrpc::Router) -> ::connectrpc::Router {
1467 <S as PolychartServiceExt>::register(self, router)
1468 }
1469}
1470pub struct PolychartServiceServer<T> {
1484 inner: ::std::sync::Arc<T>,
1485}
1486impl<T: PolychartService> PolychartServiceServer<T> {
1487 pub fn new(service: T) -> Self {
1489 Self {
1490 inner: ::std::sync::Arc::new(service),
1491 }
1492 }
1493 pub fn from_arc(inner: ::std::sync::Arc<T>) -> Self {
1495 Self { inner }
1496 }
1497}
1498impl<T> Clone for PolychartServiceServer<T> {
1499 fn clone(&self) -> Self {
1500 Self {
1501 inner: ::std::sync::Arc::clone(&self.inner),
1502 }
1503 }
1504}
1505impl<T: PolychartService> ::connectrpc::Dispatcher for PolychartServiceServer<T> {
1506 #[inline]
1507 fn lookup(
1508 &self,
1509 path: &str,
1510 ) -> Option<::connectrpc::dispatcher::codegen::MethodDescriptor> {
1511 let method = path.strip_prefix("polychart.v1.PolychartService/")?;
1512 match method {
1513 "GetMarketLayers" => {
1514 Some(
1515 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1516 .with_spec(POLYCHART_SERVICE_GET_MARKET_LAYERS_SPEC),
1517 )
1518 }
1519 "ListInboxMarketLayers" => {
1520 Some(
1521 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1522 .with_spec(POLYCHART_SERVICE_LIST_INBOX_MARKET_LAYERS_SPEC),
1523 )
1524 }
1525 "GetLayerSnapshot" => {
1526 Some(
1527 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1528 .with_spec(POLYCHART_SERVICE_GET_LAYER_SNAPSHOT_SPEC),
1529 )
1530 }
1531 "GetLayerSubscribeTokens" => {
1532 Some(
1533 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1534 .with_spec(POLYCHART_SERVICE_GET_LAYER_SUBSCRIBE_TOKENS_SPEC),
1535 )
1536 }
1537 "ResolveLayerShareToken" => {
1538 Some(
1539 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1540 .with_spec(POLYCHART_SERVICE_RESOLVE_LAYER_SHARE_TOKEN_SPEC),
1541 )
1542 }
1543 "CreateLayerShareLink" => {
1544 Some(
1545 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1546 .with_spec(POLYCHART_SERVICE_CREATE_LAYER_SHARE_LINK_SPEC),
1547 )
1548 }
1549 "RevokeLayerShareLink" => {
1550 Some(
1551 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1552 .with_spec(POLYCHART_SERVICE_REVOKE_LAYER_SHARE_LINK_SPEC),
1553 )
1554 }
1555 "ListOwnerPublishedLayers" => {
1556 Some(
1557 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1558 .with_spec(POLYCHART_SERVICE_LIST_OWNER_PUBLISHED_LAYERS_SPEC),
1559 )
1560 }
1561 "PublishLayer" => {
1562 Some(
1563 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1564 .with_spec(POLYCHART_SERVICE_PUBLISH_LAYER_SPEC),
1565 )
1566 }
1567 "UnpublishLayer" => {
1568 Some(
1569 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1570 .with_spec(POLYCHART_SERVICE_UNPUBLISH_LAYER_SPEC),
1571 )
1572 }
1573 "UpsertLayer" => {
1574 Some(
1575 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1576 .with_spec(POLYCHART_SERVICE_UPSERT_LAYER_SPEC),
1577 )
1578 }
1579 "DeleteLayer" => {
1580 Some(
1581 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1582 .with_spec(POLYCHART_SERVICE_DELETE_LAYER_SPEC),
1583 )
1584 }
1585 "UpsertDrawing" => {
1586 Some(
1587 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1588 .with_spec(POLYCHART_SERVICE_UPSERT_DRAWING_SPEC),
1589 )
1590 }
1591 "DeleteDrawing" => {
1592 Some(
1593 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1594 .with_spec(POLYCHART_SERVICE_DELETE_DRAWING_SPEC),
1595 )
1596 }
1597 "SetLayerSubscriptions" => {
1598 Some(
1599 ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
1600 .with_spec(POLYCHART_SERVICE_SET_LAYER_SUBSCRIPTIONS_SPEC),
1601 )
1602 }
1603 _ => None,
1604 }
1605 }
1606 fn call_unary(
1607 &self,
1608 path: &str,
1609 ctx: ::connectrpc::RequestContext,
1610 request: ::connectrpc::Payload,
1611 format: ::connectrpc::CodecFormat,
1612 ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
1613 let Some(method) = path.strip_prefix("polychart.v1.PolychartService/") else {
1614 return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
1615 };
1616 let _ = (&ctx, &request, &format);
1617 match method {
1618 "GetMarketLayers" => {
1619 let svc = ::std::sync::Arc::clone(&self.inner);
1620 Box::pin(async move {
1621 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1622 crate::proto::polychart::v1::GetMarketLayersRequest,
1623 >(request.encoded()?, format)?;
1624 let req: crate::proto::polychart::v1::__buffa::view::GetMarketLayersRequestView<
1625 '_,
1626 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1627 &body,
1628 )?;
1629 let req = ::connectrpc::ServiceRequest::<
1630 crate::proto::polychart::v1::GetMarketLayersRequest,
1631 >::from_parts(&req, &body);
1632 svc.get_market_layers(ctx, req)
1633 .await?
1634 .encode::<
1635 crate::proto::polychart::v1::GetMarketLayersResponse,
1636 >(format)
1637 })
1638 }
1639 "ListInboxMarketLayers" => {
1640 let svc = ::std::sync::Arc::clone(&self.inner);
1641 Box::pin(async move {
1642 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1643 crate::proto::polychart::v1::ListInboxMarketLayersRequest,
1644 >(request.encoded()?, format)?;
1645 let req: crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersRequestView<
1646 '_,
1647 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1648 &body,
1649 )?;
1650 let req = ::connectrpc::ServiceRequest::<
1651 crate::proto::polychart::v1::ListInboxMarketLayersRequest,
1652 >::from_parts(&req, &body);
1653 svc.list_inbox_market_layers(ctx, req)
1654 .await?
1655 .encode::<
1656 crate::proto::polychart::v1::ListInboxMarketLayersResponse,
1657 >(format)
1658 })
1659 }
1660 "GetLayerSnapshot" => {
1661 let svc = ::std::sync::Arc::clone(&self.inner);
1662 Box::pin(async move {
1663 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1664 crate::proto::polychart::v1::GetLayerSnapshotRequest,
1665 >(request.encoded()?, format)?;
1666 let req: crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotRequestView<
1667 '_,
1668 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1669 &body,
1670 )?;
1671 let req = ::connectrpc::ServiceRequest::<
1672 crate::proto::polychart::v1::GetLayerSnapshotRequest,
1673 >::from_parts(&req, &body);
1674 svc.get_layer_snapshot(ctx, req)
1675 .await?
1676 .encode::<
1677 crate::proto::polychart::v1::GetLayerSnapshotResponse,
1678 >(format)
1679 })
1680 }
1681 "GetLayerSubscribeTokens" => {
1682 let svc = ::std::sync::Arc::clone(&self.inner);
1683 Box::pin(async move {
1684 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1685 crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
1686 >(request.encoded()?, format)?;
1687 let req: crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensRequestView<
1688 '_,
1689 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1690 &body,
1691 )?;
1692 let req = ::connectrpc::ServiceRequest::<
1693 crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
1694 >::from_parts(&req, &body);
1695 svc.get_layer_subscribe_tokens(ctx, req)
1696 .await?
1697 .encode::<
1698 crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
1699 >(format)
1700 })
1701 }
1702 "ResolveLayerShareToken" => {
1703 let svc = ::std::sync::Arc::clone(&self.inner);
1704 Box::pin(async move {
1705 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1706 crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
1707 >(request.encoded()?, format)?;
1708 let req: crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenRequestView<
1709 '_,
1710 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1711 &body,
1712 )?;
1713 let req = ::connectrpc::ServiceRequest::<
1714 crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
1715 >::from_parts(&req, &body);
1716 svc.resolve_layer_share_token(ctx, req)
1717 .await?
1718 .encode::<
1719 crate::proto::polychart::v1::ResolveLayerShareTokenResponse,
1720 >(format)
1721 })
1722 }
1723 "CreateLayerShareLink" => {
1724 let svc = ::std::sync::Arc::clone(&self.inner);
1725 Box::pin(async move {
1726 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1727 crate::proto::polychart::v1::CreateLayerShareLinkRequest,
1728 >(request.encoded()?, format)?;
1729 let req: crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkRequestView<
1730 '_,
1731 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1732 &body,
1733 )?;
1734 let req = ::connectrpc::ServiceRequest::<
1735 crate::proto::polychart::v1::CreateLayerShareLinkRequest,
1736 >::from_parts(&req, &body);
1737 svc.create_layer_share_link(ctx, req)
1738 .await?
1739 .encode::<
1740 crate::proto::polychart::v1::CreateLayerShareLinkResponse,
1741 >(format)
1742 })
1743 }
1744 "RevokeLayerShareLink" => {
1745 let svc = ::std::sync::Arc::clone(&self.inner);
1746 Box::pin(async move {
1747 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1748 crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
1749 >(request.encoded()?, format)?;
1750 let req: crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkRequestView<
1751 '_,
1752 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1753 &body,
1754 )?;
1755 let req = ::connectrpc::ServiceRequest::<
1756 crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
1757 >::from_parts(&req, &body);
1758 svc.revoke_layer_share_link(ctx, req)
1759 .await?
1760 .encode::<
1761 crate::proto::polychart::v1::RevokeLayerShareLinkResponse,
1762 >(format)
1763 })
1764 }
1765 "ListOwnerPublishedLayers" => {
1766 let svc = ::std::sync::Arc::clone(&self.inner);
1767 Box::pin(async move {
1768 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1769 crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
1770 >(request.encoded()?, format)?;
1771 let req: crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersRequestView<
1772 '_,
1773 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1774 &body,
1775 )?;
1776 let req = ::connectrpc::ServiceRequest::<
1777 crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
1778 >::from_parts(&req, &body);
1779 svc.list_owner_published_layers(ctx, req)
1780 .await?
1781 .encode::<
1782 crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
1783 >(format)
1784 })
1785 }
1786 "PublishLayer" => {
1787 let svc = ::std::sync::Arc::clone(&self.inner);
1788 Box::pin(async move {
1789 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1790 crate::proto::polychart::v1::PublishLayerRequest,
1791 >(request.encoded()?, format)?;
1792 let req: crate::proto::polychart::v1::__buffa::view::PublishLayerRequestView<
1793 '_,
1794 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1795 &body,
1796 )?;
1797 let req = ::connectrpc::ServiceRequest::<
1798 crate::proto::polychart::v1::PublishLayerRequest,
1799 >::from_parts(&req, &body);
1800 svc.publish_layer(ctx, req)
1801 .await?
1802 .encode::<
1803 crate::proto::polychart::v1::PublishLayerResponse,
1804 >(format)
1805 })
1806 }
1807 "UnpublishLayer" => {
1808 let svc = ::std::sync::Arc::clone(&self.inner);
1809 Box::pin(async move {
1810 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1811 crate::proto::polychart::v1::UnpublishLayerRequest,
1812 >(request.encoded()?, format)?;
1813 let req: crate::proto::polychart::v1::__buffa::view::UnpublishLayerRequestView<
1814 '_,
1815 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1816 &body,
1817 )?;
1818 let req = ::connectrpc::ServiceRequest::<
1819 crate::proto::polychart::v1::UnpublishLayerRequest,
1820 >::from_parts(&req, &body);
1821 svc.unpublish_layer(ctx, req)
1822 .await?
1823 .encode::<
1824 crate::proto::polychart::v1::UnpublishLayerResponse,
1825 >(format)
1826 })
1827 }
1828 "UpsertLayer" => {
1829 let svc = ::std::sync::Arc::clone(&self.inner);
1830 Box::pin(async move {
1831 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1832 crate::proto::polychart::v1::UpsertLayerRequest,
1833 >(request.encoded()?, format)?;
1834 let req: crate::proto::polychart::v1::__buffa::view::UpsertLayerRequestView<
1835 '_,
1836 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1837 &body,
1838 )?;
1839 let req = ::connectrpc::ServiceRequest::<
1840 crate::proto::polychart::v1::UpsertLayerRequest,
1841 >::from_parts(&req, &body);
1842 svc.upsert_layer(ctx, req)
1843 .await?
1844 .encode::<
1845 crate::proto::polychart::v1::UpsertLayerResponse,
1846 >(format)
1847 })
1848 }
1849 "DeleteLayer" => {
1850 let svc = ::std::sync::Arc::clone(&self.inner);
1851 Box::pin(async move {
1852 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1853 crate::proto::polychart::v1::DeleteLayerRequest,
1854 >(request.encoded()?, format)?;
1855 let req: crate::proto::polychart::v1::__buffa::view::DeleteLayerRequestView<
1856 '_,
1857 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1858 &body,
1859 )?;
1860 let req = ::connectrpc::ServiceRequest::<
1861 crate::proto::polychart::v1::DeleteLayerRequest,
1862 >::from_parts(&req, &body);
1863 svc.delete_layer(ctx, req)
1864 .await?
1865 .encode::<
1866 crate::proto::polychart::v1::DeleteLayerResponse,
1867 >(format)
1868 })
1869 }
1870 "UpsertDrawing" => {
1871 let svc = ::std::sync::Arc::clone(&self.inner);
1872 Box::pin(async move {
1873 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1874 crate::proto::polychart::v1::UpsertDrawingRequest,
1875 >(request.encoded()?, format)?;
1876 let req: crate::proto::polychart::v1::__buffa::view::UpsertDrawingRequestView<
1877 '_,
1878 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1879 &body,
1880 )?;
1881 let req = ::connectrpc::ServiceRequest::<
1882 crate::proto::polychart::v1::UpsertDrawingRequest,
1883 >::from_parts(&req, &body);
1884 svc.upsert_drawing(ctx, req)
1885 .await?
1886 .encode::<
1887 crate::proto::polychart::v1::UpsertDrawingResponse,
1888 >(format)
1889 })
1890 }
1891 "DeleteDrawing" => {
1892 let svc = ::std::sync::Arc::clone(&self.inner);
1893 Box::pin(async move {
1894 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1895 crate::proto::polychart::v1::DeleteDrawingRequest,
1896 >(request.encoded()?, format)?;
1897 let req: crate::proto::polychart::v1::__buffa::view::DeleteDrawingRequestView<
1898 '_,
1899 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1900 &body,
1901 )?;
1902 let req = ::connectrpc::ServiceRequest::<
1903 crate::proto::polychart::v1::DeleteDrawingRequest,
1904 >::from_parts(&req, &body);
1905 svc.delete_drawing(ctx, req)
1906 .await?
1907 .encode::<
1908 crate::proto::polychart::v1::DeleteDrawingResponse,
1909 >(format)
1910 })
1911 }
1912 "SetLayerSubscriptions" => {
1913 let svc = ::std::sync::Arc::clone(&self.inner);
1914 Box::pin(async move {
1915 let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
1916 crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
1917 >(request.encoded()?, format)?;
1918 let req: crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsRequestView<
1919 '_,
1920 > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
1921 &body,
1922 )?;
1923 let req = ::connectrpc::ServiceRequest::<
1924 crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
1925 >::from_parts(&req, &body);
1926 svc.set_layer_subscriptions(ctx, req)
1927 .await?
1928 .encode::<
1929 crate::proto::polychart::v1::SetLayerSubscriptionsResponse,
1930 >(format)
1931 })
1932 }
1933 _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
1934 }
1935 }
1936 fn call_server_streaming(
1937 &self,
1938 path: &str,
1939 ctx: ::connectrpc::RequestContext,
1940 request: ::buffa::bytes::Bytes,
1941 format: ::connectrpc::CodecFormat,
1942 ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
1943 let Some(method) = path.strip_prefix("polychart.v1.PolychartService/") else {
1944 return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
1945 };
1946 let _ = (&ctx, &request, &format);
1947 match method {
1948 _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
1949 }
1950 }
1951 fn call_client_streaming(
1952 &self,
1953 path: &str,
1954 ctx: ::connectrpc::RequestContext,
1955 requests: ::connectrpc::dispatcher::codegen::RequestStream,
1956 format: ::connectrpc::CodecFormat,
1957 ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
1958 let Some(method) = path.strip_prefix("polychart.v1.PolychartService/") else {
1959 return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
1960 };
1961 let _ = (&ctx, &requests, &format);
1962 match method {
1963 _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
1964 }
1965 }
1966 fn call_bidi_streaming(
1967 &self,
1968 path: &str,
1969 ctx: ::connectrpc::RequestContext,
1970 requests: ::connectrpc::dispatcher::codegen::RequestStream,
1971 format: ::connectrpc::CodecFormat,
1972 ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
1973 let Some(method) = path.strip_prefix("polychart.v1.PolychartService/") else {
1974 return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
1975 };
1976 let _ = (&ctx, &requests, &format);
1977 match method {
1978 _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
1979 }
1980 }
1981}
1982#[derive(Clone)]
2014pub struct PolychartServiceClient<T> {
2015 transport: T,
2016 config: ::connectrpc::client::ClientConfig,
2017}
2018impl<T> PolychartServiceClient<T>
2019where
2020 T: ::connectrpc::client::ClientTransport,
2021 <T::ResponseBody as ::connectrpc::http_body::Body>::Error: ::std::fmt::Display,
2022{
2023 pub fn new(transport: T, config: ::connectrpc::client::ClientConfig) -> Self {
2025 Self { transport, config }
2026 }
2027 pub fn config(&self) -> &::connectrpc::client::ClientConfig {
2029 &self.config
2030 }
2031 pub fn config_mut(&mut self) -> &mut ::connectrpc::client::ClientConfig {
2033 &mut self.config
2034 }
2035 pub async fn get_market_layers(
2037 &self,
2038 request: crate::proto::polychart::v1::GetMarketLayersRequest,
2039 ) -> Result<
2040 ::connectrpc::client::UnaryResponse<
2041 ::buffa::view::OwnedView<
2042 crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<
2043 'static,
2044 >,
2045 >,
2046 >,
2047 ::connectrpc::ConnectError,
2048 > {
2049 self.get_market_layers_with_options(
2050 request,
2051 ::connectrpc::client::CallOptions::default(),
2052 )
2053 .await
2054 }
2055 pub async fn get_market_layers_with_options(
2057 &self,
2058 request: crate::proto::polychart::v1::GetMarketLayersRequest,
2059 options: ::connectrpc::client::CallOptions,
2060 ) -> Result<
2061 ::connectrpc::client::UnaryResponse<
2062 ::buffa::view::OwnedView<
2063 crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<
2064 'static,
2065 >,
2066 >,
2067 >,
2068 ::connectrpc::ConnectError,
2069 > {
2070 ::connectrpc::client::call_unary(
2071 &self.transport,
2072 &self.config,
2073 POLYCHART_SERVICE_SERVICE_NAME,
2074 "GetMarketLayers",
2075 request,
2076 options,
2077 )
2078 .await
2079 }
2080 pub async fn list_inbox_market_layers(
2082 &self,
2083 request: crate::proto::polychart::v1::ListInboxMarketLayersRequest,
2084 ) -> Result<
2085 ::connectrpc::client::UnaryResponse<
2086 ::buffa::view::OwnedView<
2087 crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<
2088 'static,
2089 >,
2090 >,
2091 >,
2092 ::connectrpc::ConnectError,
2093 > {
2094 self.list_inbox_market_layers_with_options(
2095 request,
2096 ::connectrpc::client::CallOptions::default(),
2097 )
2098 .await
2099 }
2100 pub async fn list_inbox_market_layers_with_options(
2102 &self,
2103 request: crate::proto::polychart::v1::ListInboxMarketLayersRequest,
2104 options: ::connectrpc::client::CallOptions,
2105 ) -> Result<
2106 ::connectrpc::client::UnaryResponse<
2107 ::buffa::view::OwnedView<
2108 crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<
2109 'static,
2110 >,
2111 >,
2112 >,
2113 ::connectrpc::ConnectError,
2114 > {
2115 ::connectrpc::client::call_unary(
2116 &self.transport,
2117 &self.config,
2118 POLYCHART_SERVICE_SERVICE_NAME,
2119 "ListInboxMarketLayers",
2120 request,
2121 options,
2122 )
2123 .await
2124 }
2125 pub async fn get_layer_snapshot(
2127 &self,
2128 request: crate::proto::polychart::v1::GetLayerSnapshotRequest,
2129 ) -> Result<
2130 ::connectrpc::client::UnaryResponse<
2131 ::buffa::view::OwnedView<
2132 crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<
2133 'static,
2134 >,
2135 >,
2136 >,
2137 ::connectrpc::ConnectError,
2138 > {
2139 self.get_layer_snapshot_with_options(
2140 request,
2141 ::connectrpc::client::CallOptions::default(),
2142 )
2143 .await
2144 }
2145 pub async fn get_layer_snapshot_with_options(
2147 &self,
2148 request: crate::proto::polychart::v1::GetLayerSnapshotRequest,
2149 options: ::connectrpc::client::CallOptions,
2150 ) -> Result<
2151 ::connectrpc::client::UnaryResponse<
2152 ::buffa::view::OwnedView<
2153 crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<
2154 'static,
2155 >,
2156 >,
2157 >,
2158 ::connectrpc::ConnectError,
2159 > {
2160 ::connectrpc::client::call_unary(
2161 &self.transport,
2162 &self.config,
2163 POLYCHART_SERVICE_SERVICE_NAME,
2164 "GetLayerSnapshot",
2165 request,
2166 options,
2167 )
2168 .await
2169 }
2170 pub async fn get_layer_subscribe_tokens(
2172 &self,
2173 request: crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
2174 ) -> Result<
2175 ::connectrpc::client::UnaryResponse<
2176 ::buffa::view::OwnedView<
2177 crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<
2178 'static,
2179 >,
2180 >,
2181 >,
2182 ::connectrpc::ConnectError,
2183 > {
2184 self.get_layer_subscribe_tokens_with_options(
2185 request,
2186 ::connectrpc::client::CallOptions::default(),
2187 )
2188 .await
2189 }
2190 pub async fn get_layer_subscribe_tokens_with_options(
2192 &self,
2193 request: crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
2194 options: ::connectrpc::client::CallOptions,
2195 ) -> Result<
2196 ::connectrpc::client::UnaryResponse<
2197 ::buffa::view::OwnedView<
2198 crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<
2199 'static,
2200 >,
2201 >,
2202 >,
2203 ::connectrpc::ConnectError,
2204 > {
2205 ::connectrpc::client::call_unary(
2206 &self.transport,
2207 &self.config,
2208 POLYCHART_SERVICE_SERVICE_NAME,
2209 "GetLayerSubscribeTokens",
2210 request,
2211 options,
2212 )
2213 .await
2214 }
2215 pub async fn resolve_layer_share_token(
2217 &self,
2218 request: crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
2219 ) -> Result<
2220 ::connectrpc::client::UnaryResponse<
2221 ::buffa::view::OwnedView<
2222 crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<
2223 'static,
2224 >,
2225 >,
2226 >,
2227 ::connectrpc::ConnectError,
2228 > {
2229 self.resolve_layer_share_token_with_options(
2230 request,
2231 ::connectrpc::client::CallOptions::default(),
2232 )
2233 .await
2234 }
2235 pub async fn resolve_layer_share_token_with_options(
2237 &self,
2238 request: crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
2239 options: ::connectrpc::client::CallOptions,
2240 ) -> Result<
2241 ::connectrpc::client::UnaryResponse<
2242 ::buffa::view::OwnedView<
2243 crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<
2244 'static,
2245 >,
2246 >,
2247 >,
2248 ::connectrpc::ConnectError,
2249 > {
2250 ::connectrpc::client::call_unary(
2251 &self.transport,
2252 &self.config,
2253 POLYCHART_SERVICE_SERVICE_NAME,
2254 "ResolveLayerShareToken",
2255 request,
2256 options,
2257 )
2258 .await
2259 }
2260 pub async fn create_layer_share_link(
2262 &self,
2263 request: crate::proto::polychart::v1::CreateLayerShareLinkRequest,
2264 ) -> Result<
2265 ::connectrpc::client::UnaryResponse<
2266 ::buffa::view::OwnedView<
2267 crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<
2268 'static,
2269 >,
2270 >,
2271 >,
2272 ::connectrpc::ConnectError,
2273 > {
2274 self.create_layer_share_link_with_options(
2275 request,
2276 ::connectrpc::client::CallOptions::default(),
2277 )
2278 .await
2279 }
2280 pub async fn create_layer_share_link_with_options(
2282 &self,
2283 request: crate::proto::polychart::v1::CreateLayerShareLinkRequest,
2284 options: ::connectrpc::client::CallOptions,
2285 ) -> Result<
2286 ::connectrpc::client::UnaryResponse<
2287 ::buffa::view::OwnedView<
2288 crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<
2289 'static,
2290 >,
2291 >,
2292 >,
2293 ::connectrpc::ConnectError,
2294 > {
2295 ::connectrpc::client::call_unary(
2296 &self.transport,
2297 &self.config,
2298 POLYCHART_SERVICE_SERVICE_NAME,
2299 "CreateLayerShareLink",
2300 request,
2301 options,
2302 )
2303 .await
2304 }
2305 pub async fn revoke_layer_share_link(
2307 &self,
2308 request: crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
2309 ) -> Result<
2310 ::connectrpc::client::UnaryResponse<
2311 ::buffa::view::OwnedView<
2312 crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<
2313 'static,
2314 >,
2315 >,
2316 >,
2317 ::connectrpc::ConnectError,
2318 > {
2319 self.revoke_layer_share_link_with_options(
2320 request,
2321 ::connectrpc::client::CallOptions::default(),
2322 )
2323 .await
2324 }
2325 pub async fn revoke_layer_share_link_with_options(
2327 &self,
2328 request: crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
2329 options: ::connectrpc::client::CallOptions,
2330 ) -> Result<
2331 ::connectrpc::client::UnaryResponse<
2332 ::buffa::view::OwnedView<
2333 crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<
2334 'static,
2335 >,
2336 >,
2337 >,
2338 ::connectrpc::ConnectError,
2339 > {
2340 ::connectrpc::client::call_unary(
2341 &self.transport,
2342 &self.config,
2343 POLYCHART_SERVICE_SERVICE_NAME,
2344 "RevokeLayerShareLink",
2345 request,
2346 options,
2347 )
2348 .await
2349 }
2350 pub async fn list_owner_published_layers(
2352 &self,
2353 request: crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
2354 ) -> Result<
2355 ::connectrpc::client::UnaryResponse<
2356 ::buffa::view::OwnedView<
2357 crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
2358 'static,
2359 >,
2360 >,
2361 >,
2362 ::connectrpc::ConnectError,
2363 > {
2364 self.list_owner_published_layers_with_options(
2365 request,
2366 ::connectrpc::client::CallOptions::default(),
2367 )
2368 .await
2369 }
2370 pub async fn list_owner_published_layers_with_options(
2372 &self,
2373 request: crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
2374 options: ::connectrpc::client::CallOptions,
2375 ) -> Result<
2376 ::connectrpc::client::UnaryResponse<
2377 ::buffa::view::OwnedView<
2378 crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
2379 'static,
2380 >,
2381 >,
2382 >,
2383 ::connectrpc::ConnectError,
2384 > {
2385 ::connectrpc::client::call_unary(
2386 &self.transport,
2387 &self.config,
2388 POLYCHART_SERVICE_SERVICE_NAME,
2389 "ListOwnerPublishedLayers",
2390 request,
2391 options,
2392 )
2393 .await
2394 }
2395 pub async fn publish_layer(
2397 &self,
2398 request: crate::proto::polychart::v1::PublishLayerRequest,
2399 ) -> Result<
2400 ::connectrpc::client::UnaryResponse<
2401 ::buffa::view::OwnedView<
2402 crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<
2403 'static,
2404 >,
2405 >,
2406 >,
2407 ::connectrpc::ConnectError,
2408 > {
2409 self.publish_layer_with_options(
2410 request,
2411 ::connectrpc::client::CallOptions::default(),
2412 )
2413 .await
2414 }
2415 pub async fn publish_layer_with_options(
2417 &self,
2418 request: crate::proto::polychart::v1::PublishLayerRequest,
2419 options: ::connectrpc::client::CallOptions,
2420 ) -> Result<
2421 ::connectrpc::client::UnaryResponse<
2422 ::buffa::view::OwnedView<
2423 crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<
2424 'static,
2425 >,
2426 >,
2427 >,
2428 ::connectrpc::ConnectError,
2429 > {
2430 ::connectrpc::client::call_unary(
2431 &self.transport,
2432 &self.config,
2433 POLYCHART_SERVICE_SERVICE_NAME,
2434 "PublishLayer",
2435 request,
2436 options,
2437 )
2438 .await
2439 }
2440 pub async fn unpublish_layer(
2442 &self,
2443 request: crate::proto::polychart::v1::UnpublishLayerRequest,
2444 ) -> Result<
2445 ::connectrpc::client::UnaryResponse<
2446 ::buffa::view::OwnedView<
2447 crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<
2448 'static,
2449 >,
2450 >,
2451 >,
2452 ::connectrpc::ConnectError,
2453 > {
2454 self.unpublish_layer_with_options(
2455 request,
2456 ::connectrpc::client::CallOptions::default(),
2457 )
2458 .await
2459 }
2460 pub async fn unpublish_layer_with_options(
2462 &self,
2463 request: crate::proto::polychart::v1::UnpublishLayerRequest,
2464 options: ::connectrpc::client::CallOptions,
2465 ) -> Result<
2466 ::connectrpc::client::UnaryResponse<
2467 ::buffa::view::OwnedView<
2468 crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<
2469 'static,
2470 >,
2471 >,
2472 >,
2473 ::connectrpc::ConnectError,
2474 > {
2475 ::connectrpc::client::call_unary(
2476 &self.transport,
2477 &self.config,
2478 POLYCHART_SERVICE_SERVICE_NAME,
2479 "UnpublishLayer",
2480 request,
2481 options,
2482 )
2483 .await
2484 }
2485 pub async fn upsert_layer(
2487 &self,
2488 request: crate::proto::polychart::v1::UpsertLayerRequest,
2489 ) -> Result<
2490 ::connectrpc::client::UnaryResponse<
2491 ::buffa::view::OwnedView<
2492 crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<
2493 'static,
2494 >,
2495 >,
2496 >,
2497 ::connectrpc::ConnectError,
2498 > {
2499 self.upsert_layer_with_options(
2500 request,
2501 ::connectrpc::client::CallOptions::default(),
2502 )
2503 .await
2504 }
2505 pub async fn upsert_layer_with_options(
2507 &self,
2508 request: crate::proto::polychart::v1::UpsertLayerRequest,
2509 options: ::connectrpc::client::CallOptions,
2510 ) -> Result<
2511 ::connectrpc::client::UnaryResponse<
2512 ::buffa::view::OwnedView<
2513 crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<
2514 'static,
2515 >,
2516 >,
2517 >,
2518 ::connectrpc::ConnectError,
2519 > {
2520 ::connectrpc::client::call_unary(
2521 &self.transport,
2522 &self.config,
2523 POLYCHART_SERVICE_SERVICE_NAME,
2524 "UpsertLayer",
2525 request,
2526 options,
2527 )
2528 .await
2529 }
2530 pub async fn delete_layer(
2532 &self,
2533 request: crate::proto::polychart::v1::DeleteLayerRequest,
2534 ) -> Result<
2535 ::connectrpc::client::UnaryResponse<
2536 ::buffa::view::OwnedView<
2537 crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<
2538 'static,
2539 >,
2540 >,
2541 >,
2542 ::connectrpc::ConnectError,
2543 > {
2544 self.delete_layer_with_options(
2545 request,
2546 ::connectrpc::client::CallOptions::default(),
2547 )
2548 .await
2549 }
2550 pub async fn delete_layer_with_options(
2552 &self,
2553 request: crate::proto::polychart::v1::DeleteLayerRequest,
2554 options: ::connectrpc::client::CallOptions,
2555 ) -> Result<
2556 ::connectrpc::client::UnaryResponse<
2557 ::buffa::view::OwnedView<
2558 crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<
2559 'static,
2560 >,
2561 >,
2562 >,
2563 ::connectrpc::ConnectError,
2564 > {
2565 ::connectrpc::client::call_unary(
2566 &self.transport,
2567 &self.config,
2568 POLYCHART_SERVICE_SERVICE_NAME,
2569 "DeleteLayer",
2570 request,
2571 options,
2572 )
2573 .await
2574 }
2575 pub async fn upsert_drawing(
2577 &self,
2578 request: crate::proto::polychart::v1::UpsertDrawingRequest,
2579 ) -> Result<
2580 ::connectrpc::client::UnaryResponse<
2581 ::buffa::view::OwnedView<
2582 crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<
2583 'static,
2584 >,
2585 >,
2586 >,
2587 ::connectrpc::ConnectError,
2588 > {
2589 self.upsert_drawing_with_options(
2590 request,
2591 ::connectrpc::client::CallOptions::default(),
2592 )
2593 .await
2594 }
2595 pub async fn upsert_drawing_with_options(
2597 &self,
2598 request: crate::proto::polychart::v1::UpsertDrawingRequest,
2599 options: ::connectrpc::client::CallOptions,
2600 ) -> Result<
2601 ::connectrpc::client::UnaryResponse<
2602 ::buffa::view::OwnedView<
2603 crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<
2604 'static,
2605 >,
2606 >,
2607 >,
2608 ::connectrpc::ConnectError,
2609 > {
2610 ::connectrpc::client::call_unary(
2611 &self.transport,
2612 &self.config,
2613 POLYCHART_SERVICE_SERVICE_NAME,
2614 "UpsertDrawing",
2615 request,
2616 options,
2617 )
2618 .await
2619 }
2620 pub async fn delete_drawing(
2622 &self,
2623 request: crate::proto::polychart::v1::DeleteDrawingRequest,
2624 ) -> Result<
2625 ::connectrpc::client::UnaryResponse<
2626 ::buffa::view::OwnedView<
2627 crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<
2628 'static,
2629 >,
2630 >,
2631 >,
2632 ::connectrpc::ConnectError,
2633 > {
2634 self.delete_drawing_with_options(
2635 request,
2636 ::connectrpc::client::CallOptions::default(),
2637 )
2638 .await
2639 }
2640 pub async fn delete_drawing_with_options(
2642 &self,
2643 request: crate::proto::polychart::v1::DeleteDrawingRequest,
2644 options: ::connectrpc::client::CallOptions,
2645 ) -> Result<
2646 ::connectrpc::client::UnaryResponse<
2647 ::buffa::view::OwnedView<
2648 crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<
2649 'static,
2650 >,
2651 >,
2652 >,
2653 ::connectrpc::ConnectError,
2654 > {
2655 ::connectrpc::client::call_unary(
2656 &self.transport,
2657 &self.config,
2658 POLYCHART_SERVICE_SERVICE_NAME,
2659 "DeleteDrawing",
2660 request,
2661 options,
2662 )
2663 .await
2664 }
2665 pub async fn set_layer_subscriptions(
2667 &self,
2668 request: crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
2669 ) -> Result<
2670 ::connectrpc::client::UnaryResponse<
2671 ::buffa::view::OwnedView<
2672 crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<
2673 'static,
2674 >,
2675 >,
2676 >,
2677 ::connectrpc::ConnectError,
2678 > {
2679 self.set_layer_subscriptions_with_options(
2680 request,
2681 ::connectrpc::client::CallOptions::default(),
2682 )
2683 .await
2684 }
2685 pub async fn set_layer_subscriptions_with_options(
2687 &self,
2688 request: crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
2689 options: ::connectrpc::client::CallOptions,
2690 ) -> Result<
2691 ::connectrpc::client::UnaryResponse<
2692 ::buffa::view::OwnedView<
2693 crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<
2694 'static,
2695 >,
2696 >,
2697 >,
2698 ::connectrpc::ConnectError,
2699 > {
2700 ::connectrpc::client::call_unary(
2701 &self.transport,
2702 &self.config,
2703 POLYCHART_SERVICE_SERVICE_NAME,
2704 "SetLayerSubscriptions",
2705 request,
2706 options,
2707 )
2708 .await
2709 }
2710}