pub type OwnedGetMarketLayersRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetMarketLayersRequestView<'static>,
>;
pub type OwnedGetMarketLayersResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<'static>,
>;
pub type OwnedListInboxMarketLayersRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersRequestView<'static>,
>;
pub type OwnedListInboxMarketLayersResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<
'static,
>,
>;
pub type OwnedGetLayerSnapshotRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotRequestView<'static>,
>;
pub type OwnedGetLayerSnapshotResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<'static>,
>;
pub type OwnedGetLayerSubscribeTokensRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensRequestView<
'static,
>,
>;
pub type OwnedGetLayerSubscribeTokensResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<
'static,
>,
>;
pub type OwnedResolveLayerShareTokenRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenRequestView<
'static,
>,
>;
pub type OwnedResolveLayerShareTokenResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<
'static,
>,
>;
pub type OwnedCreateLayerShareLinkRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkRequestView<'static>,
>;
pub type OwnedCreateLayerShareLinkResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<'static>,
>;
pub type OwnedRevokeLayerShareLinkRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkRequestView<'static>,
>;
pub type OwnedRevokeLayerShareLinkResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<'static>,
>;
pub type OwnedListOwnerPublishedLayersRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersRequestView<
'static,
>,
>;
pub type OwnedListOwnerPublishedLayersResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
'static,
>,
>;
pub type OwnedPublishLayerRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::PublishLayerRequestView<'static>,
>;
pub type OwnedPublishLayerResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<'static>,
>;
pub type OwnedUnpublishLayerRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UnpublishLayerRequestView<'static>,
>;
pub type OwnedUnpublishLayerResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<'static>,
>;
pub type OwnedUpsertLayerRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertLayerRequestView<'static>,
>;
pub type OwnedUpsertLayerResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<'static>,
>;
pub type OwnedDeleteLayerRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteLayerRequestView<'static>,
>;
pub type OwnedDeleteLayerResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<'static>,
>;
pub type OwnedUpsertDrawingRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertDrawingRequestView<'static>,
>;
pub type OwnedUpsertDrawingResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<'static>,
>;
pub type OwnedDeleteDrawingRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteDrawingRequestView<'static>,
>;
pub type OwnedDeleteDrawingResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<'static>,
>;
pub type OwnedSetLayerSubscriptionsRequestView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsRequestView<'static>,
>;
pub type OwnedSetLayerSubscriptionsResponseView = ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<
'static,
>,
>;
impl ::connectrpc::Encodable<crate::proto::polychart::v1::GetMarketLayersResponse>
for crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::GetMarketLayersResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::ListInboxMarketLayersResponse>
for crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::ListInboxMarketLayersResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<
'static,
>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::GetLayerSnapshotResponse>
for crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::GetLayerSnapshotResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
>
for crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<
'static,
>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::ResolveLayerShareTokenResponse>
for crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::ResolveLayerShareTokenResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<
'static,
>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::CreateLayerShareLinkResponse>
for crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::CreateLayerShareLinkResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::RevokeLayerShareLinkResponse>
for crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::RevokeLayerShareLinkResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
>
for crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
'_,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
'static,
>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::PublishLayerResponse>
for crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::PublishLayerResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::UnpublishLayerResponse>
for crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::UnpublishLayerResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::UpsertLayerResponse>
for crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::UpsertLayerResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::DeleteLayerResponse>
for crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::DeleteLayerResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::UpsertDrawingResponse>
for crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::UpsertDrawingResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::DeleteDrawingResponse>
for crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::DeleteDrawingResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<'static>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::SetLayerSubscriptionsResponse>
for crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<'_> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self, codec)
}
}
impl ::connectrpc::Encodable<crate::proto::polychart::v1::SetLayerSubscriptionsResponse>
for ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<
'static,
>,
> {
fn encode(
&self,
codec: ::connectrpc::CodecFormat,
) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
}
}
pub const POLYCHART_SERVICE_SERVICE_NAME: &str = "polychart.v1.PolychartService";
pub const POLYCHART_SERVICE_GET_MARKET_LAYERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/GetMarketLayers",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_LIST_INBOX_MARKET_LAYERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/ListInboxMarketLayers",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_GET_LAYER_SNAPSHOT_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/GetLayerSnapshot",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_GET_LAYER_SUBSCRIBE_TOKENS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/GetLayerSubscribeTokens",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_RESOLVE_LAYER_SHARE_TOKEN_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/ResolveLayerShareToken",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_CREATE_LAYER_SHARE_LINK_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/CreateLayerShareLink",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_REVOKE_LAYER_SHARE_LINK_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/RevokeLayerShareLink",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_LIST_OWNER_PUBLISHED_LAYERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/ListOwnerPublishedLayers",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_PUBLISH_LAYER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/PublishLayer",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_UNPUBLISH_LAYER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/UnpublishLayer",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_UPSERT_LAYER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/UpsertLayer",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_DELETE_LAYER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/DeleteLayer",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_UPSERT_DRAWING_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/UpsertDrawing",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_DELETE_DRAWING_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/DeleteDrawing",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
pub const POLYCHART_SERVICE_SET_LAYER_SUBSCRIPTIONS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
"/polychart.v1.PolychartService/SetLayerSubscriptions",
::connectrpc::StreamType::Unary,
)
.with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
#[allow(clippy::type_complexity)]
pub trait PolychartService: Send + Sync + 'static {
fn get_market_layers<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::GetMarketLayersRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::GetMarketLayersResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn list_inbox_market_layers<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::ListInboxMarketLayersRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::ListInboxMarketLayersResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn get_layer_snapshot<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::GetLayerSnapshotRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::GetLayerSnapshotResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn get_layer_subscribe_tokens<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn resolve_layer_share_token<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::ResolveLayerShareTokenResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn create_layer_share_link<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::CreateLayerShareLinkRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::CreateLayerShareLinkResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn revoke_layer_share_link<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::RevokeLayerShareLinkResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn list_owner_published_layers<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn publish_layer<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::PublishLayerRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::PublishLayerResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn unpublish_layer<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::UnpublishLayerRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::UnpublishLayerResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn upsert_layer<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::UpsertLayerRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::UpsertLayerResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn delete_layer<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::DeleteLayerRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::DeleteLayerResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn upsert_drawing<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::UpsertDrawingRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::UpsertDrawingResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn delete_drawing<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::DeleteDrawingRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::DeleteDrawingResponse,
> + Send + use<'a, Self>,
>,
> + Send;
fn set_layer_subscriptions<'a>(
&'a self,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::ServiceRequest<
'_,
crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
>,
) -> impl ::std::future::Future<
Output = ::connectrpc::ServiceResult<
impl ::connectrpc::Encodable<
crate::proto::polychart::v1::SetLayerSubscriptionsResponse,
> + Send + use<'a, Self>,
>,
> + Send;
}
pub trait PolychartServiceExt: PolychartService {
fn register(
self: ::std::sync::Arc<Self>,
router: ::connectrpc::Router,
) -> ::connectrpc::Router;
}
impl<S: PolychartService> PolychartServiceExt for S {
fn register(
self: ::std::sync::Arc<Self>,
router: ::connectrpc::Router,
) -> ::connectrpc::Router {
router
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"GetMarketLayers",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetMarketLayersRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::GetMarketLayersRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.get_market_layers(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::GetMarketLayersResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_GET_MARKET_LAYERS_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"ListInboxMarketLayers",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::ListInboxMarketLayersRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.list_inbox_market_layers(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::ListInboxMarketLayersResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_LIST_INBOX_MARKET_LAYERS_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"GetLayerSnapshot",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::GetLayerSnapshotRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.get_layer_snapshot(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::GetLayerSnapshotResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_GET_LAYER_SNAPSHOT_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"GetLayerSubscribeTokens",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.get_layer_subscribe_tokens(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_GET_LAYER_SUBSCRIBE_TOKENS_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"ResolveLayerShareToken",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.resolve_layer_share_token(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::ResolveLayerShareTokenResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_RESOLVE_LAYER_SHARE_TOKEN_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"CreateLayerShareLink",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::CreateLayerShareLinkRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.create_layer_share_link(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::CreateLayerShareLinkResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_CREATE_LAYER_SHARE_LINK_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"RevokeLayerShareLink",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.revoke_layer_share_link(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::RevokeLayerShareLinkResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_REVOKE_LAYER_SHARE_LINK_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"ListOwnerPublishedLayers",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.list_owner_published_layers(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_LIST_OWNER_PUBLISHED_LAYERS_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"PublishLayer",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::PublishLayerRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::PublishLayerRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.publish_layer(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::PublishLayerResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_PUBLISH_LAYER_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"UnpublishLayer",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UnpublishLayerRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::UnpublishLayerRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.unpublish_layer(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::UnpublishLayerResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_UNPUBLISH_LAYER_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"UpsertLayer",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertLayerRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::UpsertLayerRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.upsert_layer(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::UpsertLayerResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_UPSERT_LAYER_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"DeleteLayer",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteLayerRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::DeleteLayerRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.delete_layer(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::DeleteLayerResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_DELETE_LAYER_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"UpsertDrawing",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertDrawingRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::UpsertDrawingRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.upsert_drawing(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::UpsertDrawingResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_UPSERT_DRAWING_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"DeleteDrawing",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteDrawingRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::DeleteDrawingRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.delete_drawing(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::DeleteDrawingResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_DELETE_DRAWING_SPEC)
.route_view(
POLYCHART_SERVICE_SERVICE_NAME,
"SetLayerSubscriptions",
{
let svc = ::std::sync::Arc::clone(&self);
::connectrpc::view_handler_fn(move |
ctx,
req: ::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsRequestView<
'static,
>,
>,
format|
{
let svc = ::std::sync::Arc::clone(&svc);
async move {
let sreq = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
>::from_parts(req.reborrow(), req.bytes());
svc.set_layer_subscriptions(ctx, sreq)
.await?
.encode::<
crate::proto::polychart::v1::SetLayerSubscriptionsResponse,
>(format)
}
})
},
)
.with_spec(POLYCHART_SERVICE_SET_LAYER_SUBSCRIPTIONS_SPEC)
}
}
#[doc(hidden)]
pub struct PolychartServiceRegisterMarker;
impl<S: PolychartService> ::connectrpc::ServiceRegister<PolychartServiceRegisterMarker>
for ::std::sync::Arc<S> {
fn register_service(self, router: ::connectrpc::Router) -> ::connectrpc::Router {
<S as PolychartServiceExt>::register(self, router)
}
}
pub struct PolychartServiceServer<T> {
inner: ::std::sync::Arc<T>,
}
impl<T: PolychartService> PolychartServiceServer<T> {
pub fn new(service: T) -> Self {
Self {
inner: ::std::sync::Arc::new(service),
}
}
pub fn from_arc(inner: ::std::sync::Arc<T>) -> Self {
Self { inner }
}
}
impl<T> Clone for PolychartServiceServer<T> {
fn clone(&self) -> Self {
Self {
inner: ::std::sync::Arc::clone(&self.inner),
}
}
}
impl<T: PolychartService> ::connectrpc::Dispatcher for PolychartServiceServer<T> {
#[inline]
fn lookup(
&self,
path: &str,
) -> Option<::connectrpc::dispatcher::codegen::MethodDescriptor> {
let method = path.strip_prefix("polychart.v1.PolychartService/")?;
match method {
"GetMarketLayers" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_GET_MARKET_LAYERS_SPEC),
)
}
"ListInboxMarketLayers" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_LIST_INBOX_MARKET_LAYERS_SPEC),
)
}
"GetLayerSnapshot" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_GET_LAYER_SNAPSHOT_SPEC),
)
}
"GetLayerSubscribeTokens" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_GET_LAYER_SUBSCRIBE_TOKENS_SPEC),
)
}
"ResolveLayerShareToken" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_RESOLVE_LAYER_SHARE_TOKEN_SPEC),
)
}
"CreateLayerShareLink" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_CREATE_LAYER_SHARE_LINK_SPEC),
)
}
"RevokeLayerShareLink" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_REVOKE_LAYER_SHARE_LINK_SPEC),
)
}
"ListOwnerPublishedLayers" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_LIST_OWNER_PUBLISHED_LAYERS_SPEC),
)
}
"PublishLayer" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_PUBLISH_LAYER_SPEC),
)
}
"UnpublishLayer" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_UNPUBLISH_LAYER_SPEC),
)
}
"UpsertLayer" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_UPSERT_LAYER_SPEC),
)
}
"DeleteLayer" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_DELETE_LAYER_SPEC),
)
}
"UpsertDrawing" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_UPSERT_DRAWING_SPEC),
)
}
"DeleteDrawing" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_DELETE_DRAWING_SPEC),
)
}
"SetLayerSubscriptions" => {
Some(
::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
.with_spec(POLYCHART_SERVICE_SET_LAYER_SUBSCRIPTIONS_SPEC),
)
}
_ => None,
}
}
fn call_unary(
&self,
path: &str,
ctx: ::connectrpc::RequestContext,
request: ::connectrpc::Payload,
format: ::connectrpc::CodecFormat,
) -> ::connectrpc::dispatcher::codegen::UnaryResult {
let Some(method) = path.strip_prefix("polychart.v1.PolychartService/") else {
return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
};
let _ = (&ctx, &request, &format);
match method {
"GetMarketLayers" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::GetMarketLayersRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::GetMarketLayersRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::GetMarketLayersRequest,
>::from_parts(&req, &body);
svc.get_market_layers(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::GetMarketLayersResponse,
>(format)
})
}
"ListInboxMarketLayers" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::ListInboxMarketLayersRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::ListInboxMarketLayersRequest,
>::from_parts(&req, &body);
svc.list_inbox_market_layers(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::ListInboxMarketLayersResponse,
>(format)
})
}
"GetLayerSnapshot" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::GetLayerSnapshotRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::GetLayerSnapshotRequest,
>::from_parts(&req, &body);
svc.get_layer_snapshot(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::GetLayerSnapshotResponse,
>(format)
})
}
"GetLayerSubscribeTokens" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
>::from_parts(&req, &body);
svc.get_layer_subscribe_tokens(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::GetLayerSubscribeTokensResponse,
>(format)
})
}
"ResolveLayerShareToken" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
>::from_parts(&req, &body);
svc.resolve_layer_share_token(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::ResolveLayerShareTokenResponse,
>(format)
})
}
"CreateLayerShareLink" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::CreateLayerShareLinkRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::CreateLayerShareLinkRequest,
>::from_parts(&req, &body);
svc.create_layer_share_link(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::CreateLayerShareLinkResponse,
>(format)
})
}
"RevokeLayerShareLink" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
>::from_parts(&req, &body);
svc.revoke_layer_share_link(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::RevokeLayerShareLinkResponse,
>(format)
})
}
"ListOwnerPublishedLayers" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
>::from_parts(&req, &body);
svc.list_owner_published_layers(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::ListOwnerPublishedLayersResponse,
>(format)
})
}
"PublishLayer" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::PublishLayerRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::PublishLayerRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::PublishLayerRequest,
>::from_parts(&req, &body);
svc.publish_layer(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::PublishLayerResponse,
>(format)
})
}
"UnpublishLayer" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::UnpublishLayerRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::UnpublishLayerRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::UnpublishLayerRequest,
>::from_parts(&req, &body);
svc.unpublish_layer(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::UnpublishLayerResponse,
>(format)
})
}
"UpsertLayer" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::UpsertLayerRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::UpsertLayerRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::UpsertLayerRequest,
>::from_parts(&req, &body);
svc.upsert_layer(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::UpsertLayerResponse,
>(format)
})
}
"DeleteLayer" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::DeleteLayerRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::DeleteLayerRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::DeleteLayerRequest,
>::from_parts(&req, &body);
svc.delete_layer(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::DeleteLayerResponse,
>(format)
})
}
"UpsertDrawing" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::UpsertDrawingRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::UpsertDrawingRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::UpsertDrawingRequest,
>::from_parts(&req, &body);
svc.upsert_drawing(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::UpsertDrawingResponse,
>(format)
})
}
"DeleteDrawing" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::DeleteDrawingRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::DeleteDrawingRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::DeleteDrawingRequest,
>::from_parts(&req, &body);
svc.delete_drawing(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::DeleteDrawingResponse,
>(format)
})
}
"SetLayerSubscriptions" => {
let svc = ::std::sync::Arc::clone(&self.inner);
Box::pin(async move {
let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
>(request.encoded()?, format)?;
let req: crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsRequestView<
'_,
> = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
&body,
)?;
let req = ::connectrpc::ServiceRequest::<
crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
>::from_parts(&req, &body);
svc.set_layer_subscriptions(ctx, req)
.await?
.encode::<
crate::proto::polychart::v1::SetLayerSubscriptionsResponse,
>(format)
})
}
_ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
}
}
fn call_server_streaming(
&self,
path: &str,
ctx: ::connectrpc::RequestContext,
request: ::buffa::bytes::Bytes,
format: ::connectrpc::CodecFormat,
) -> ::connectrpc::dispatcher::codegen::StreamingResult {
let Some(method) = path.strip_prefix("polychart.v1.PolychartService/") else {
return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
};
let _ = (&ctx, &request, &format);
match method {
_ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
}
}
fn call_client_streaming(
&self,
path: &str,
ctx: ::connectrpc::RequestContext,
requests: ::connectrpc::dispatcher::codegen::RequestStream,
format: ::connectrpc::CodecFormat,
) -> ::connectrpc::dispatcher::codegen::UnaryResult {
let Some(method) = path.strip_prefix("polychart.v1.PolychartService/") else {
return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
};
let _ = (&ctx, &requests, &format);
match method {
_ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
}
}
fn call_bidi_streaming(
&self,
path: &str,
ctx: ::connectrpc::RequestContext,
requests: ::connectrpc::dispatcher::codegen::RequestStream,
format: ::connectrpc::CodecFormat,
) -> ::connectrpc::dispatcher::codegen::StreamingResult {
let Some(method) = path.strip_prefix("polychart.v1.PolychartService/") else {
return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
};
let _ = (&ctx, &requests, &format);
match method {
_ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
}
}
}
#[derive(Clone)]
pub struct PolychartServiceClient<T> {
transport: T,
config: ::connectrpc::client::ClientConfig,
}
impl<T> PolychartServiceClient<T>
where
T: ::connectrpc::client::ClientTransport,
<T::ResponseBody as ::connectrpc::http_body::Body>::Error: ::std::fmt::Display,
{
pub fn new(transport: T, config: ::connectrpc::client::ClientConfig) -> Self {
Self { transport, config }
}
pub fn config(&self) -> &::connectrpc::client::ClientConfig {
&self.config
}
pub fn config_mut(&mut self) -> &mut ::connectrpc::client::ClientConfig {
&mut self.config
}
pub async fn get_market_layers(
&self,
request: crate::proto::polychart::v1::GetMarketLayersRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.get_market_layers_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn get_market_layers_with_options(
&self,
request: crate::proto::polychart::v1::GetMarketLayersRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetMarketLayersResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"GetMarketLayers",
request,
options,
)
.await
}
pub async fn list_inbox_market_layers(
&self,
request: crate::proto::polychart::v1::ListInboxMarketLayersRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.list_inbox_market_layers_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn list_inbox_market_layers_with_options(
&self,
request: crate::proto::polychart::v1::ListInboxMarketLayersRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListInboxMarketLayersResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"ListInboxMarketLayers",
request,
options,
)
.await
}
pub async fn get_layer_snapshot(
&self,
request: crate::proto::polychart::v1::GetLayerSnapshotRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.get_layer_snapshot_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn get_layer_snapshot_with_options(
&self,
request: crate::proto::polychart::v1::GetLayerSnapshotRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSnapshotResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"GetLayerSnapshot",
request,
options,
)
.await
}
pub async fn get_layer_subscribe_tokens(
&self,
request: crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.get_layer_subscribe_tokens_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn get_layer_subscribe_tokens_with_options(
&self,
request: crate::proto::polychart::v1::GetLayerSubscribeTokensRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::GetLayerSubscribeTokensResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"GetLayerSubscribeTokens",
request,
options,
)
.await
}
pub async fn resolve_layer_share_token(
&self,
request: crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.resolve_layer_share_token_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn resolve_layer_share_token_with_options(
&self,
request: crate::proto::polychart::v1::ResolveLayerShareTokenRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ResolveLayerShareTokenResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"ResolveLayerShareToken",
request,
options,
)
.await
}
pub async fn create_layer_share_link(
&self,
request: crate::proto::polychart::v1::CreateLayerShareLinkRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.create_layer_share_link_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn create_layer_share_link_with_options(
&self,
request: crate::proto::polychart::v1::CreateLayerShareLinkRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::CreateLayerShareLinkResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"CreateLayerShareLink",
request,
options,
)
.await
}
pub async fn revoke_layer_share_link(
&self,
request: crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.revoke_layer_share_link_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn revoke_layer_share_link_with_options(
&self,
request: crate::proto::polychart::v1::RevokeLayerShareLinkRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::RevokeLayerShareLinkResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"RevokeLayerShareLink",
request,
options,
)
.await
}
pub async fn list_owner_published_layers(
&self,
request: crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.list_owner_published_layers_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn list_owner_published_layers_with_options(
&self,
request: crate::proto::polychart::v1::ListOwnerPublishedLayersRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::ListOwnerPublishedLayersResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"ListOwnerPublishedLayers",
request,
options,
)
.await
}
pub async fn publish_layer(
&self,
request: crate::proto::polychart::v1::PublishLayerRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.publish_layer_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn publish_layer_with_options(
&self,
request: crate::proto::polychart::v1::PublishLayerRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::PublishLayerResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"PublishLayer",
request,
options,
)
.await
}
pub async fn unpublish_layer(
&self,
request: crate::proto::polychart::v1::UnpublishLayerRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.unpublish_layer_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn unpublish_layer_with_options(
&self,
request: crate::proto::polychart::v1::UnpublishLayerRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UnpublishLayerResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"UnpublishLayer",
request,
options,
)
.await
}
pub async fn upsert_layer(
&self,
request: crate::proto::polychart::v1::UpsertLayerRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.upsert_layer_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn upsert_layer_with_options(
&self,
request: crate::proto::polychart::v1::UpsertLayerRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertLayerResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"UpsertLayer",
request,
options,
)
.await
}
pub async fn delete_layer(
&self,
request: crate::proto::polychart::v1::DeleteLayerRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.delete_layer_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn delete_layer_with_options(
&self,
request: crate::proto::polychart::v1::DeleteLayerRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteLayerResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"DeleteLayer",
request,
options,
)
.await
}
pub async fn upsert_drawing(
&self,
request: crate::proto::polychart::v1::UpsertDrawingRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.upsert_drawing_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn upsert_drawing_with_options(
&self,
request: crate::proto::polychart::v1::UpsertDrawingRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::UpsertDrawingResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"UpsertDrawing",
request,
options,
)
.await
}
pub async fn delete_drawing(
&self,
request: crate::proto::polychart::v1::DeleteDrawingRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.delete_drawing_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn delete_drawing_with_options(
&self,
request: crate::proto::polychart::v1::DeleteDrawingRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::DeleteDrawingResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"DeleteDrawing",
request,
options,
)
.await
}
pub async fn set_layer_subscriptions(
&self,
request: crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
self.set_layer_subscriptions_with_options(
request,
::connectrpc::client::CallOptions::default(),
)
.await
}
pub async fn set_layer_subscriptions_with_options(
&self,
request: crate::proto::polychart::v1::SetLayerSubscriptionsRequest,
options: ::connectrpc::client::CallOptions,
) -> Result<
::connectrpc::client::UnaryResponse<
::buffa::view::OwnedView<
crate::proto::polychart::v1::__buffa::view::SetLayerSubscriptionsResponseView<
'static,
>,
>,
>,
::connectrpc::ConnectError,
> {
::connectrpc::client::call_unary(
&self.transport,
&self.config,
POLYCHART_SERVICE_SERVICE_NAME,
"SetLayerSubscriptions",
request,
options,
)
.await
}
}