nominal_api_proto/proto/
nominal.mesh.v1.rs

1// This file is @generated by prost-build.
2#[derive(Clone, PartialEq, ::prost::Message)]
3pub struct RemoteConnection {
4    #[prost(string, tag = "1")]
5    pub rid: ::prost::alloc::string::String,
6    #[prost(string, tag = "2")]
7    pub name: ::prost::alloc::string::String,
8    #[prost(string, tag = "3")]
9    pub base_url: ::prost::alloc::string::String,
10    #[prost(string, tag = "4")]
11    pub secret_rid: ::prost::alloc::string::String,
12    #[prost(enumeration = "RemoteConnectionStatus", tag = "5")]
13    pub status: i32,
14    #[prost(message, optional, tag = "6")]
15    pub status_updated_at: ::core::option::Option<
16        super::super::super::google::protobuf::Timestamp,
17    >,
18}
19#[derive(Clone, PartialEq, ::prost::Message)]
20pub struct CreateRemoteConnectionRequest {
21    #[prost(string, tag = "1")]
22    pub name: ::prost::alloc::string::String,
23    #[prost(string, tag = "2")]
24    pub base_url: ::prost::alloc::string::String,
25    #[prost(string, tag = "3")]
26    pub secret_rid: ::prost::alloc::string::String,
27    #[prost(string, tag = "4")]
28    pub workspace_rid: ::prost::alloc::string::String,
29}
30#[derive(Clone, PartialEq, ::prost::Message)]
31pub struct CreateRemoteConnectionResponse {
32    #[prost(message, optional, tag = "1")]
33    pub remote_connection: ::core::option::Option<RemoteConnection>,
34}
35#[derive(Clone, PartialEq, ::prost::Message)]
36pub struct GetRemoteConnectionRequest {
37    #[prost(string, tag = "1")]
38    pub remote_connection_rid: ::prost::alloc::string::String,
39}
40#[derive(Clone, PartialEq, ::prost::Message)]
41pub struct GetRemoteConnectionResponse {
42    #[prost(message, optional, tag = "1")]
43    pub remote_connection: ::core::option::Option<RemoteConnection>,
44}
45#[derive(Clone, PartialEq, ::prost::Message)]
46pub struct UpdateRemoteConnectionRequest {
47    #[prost(string, tag = "1")]
48    pub remote_connection_rid: ::prost::alloc::string::String,
49    #[prost(string, optional, tag = "2")]
50    pub name: ::core::option::Option<::prost::alloc::string::String>,
51    #[prost(string, optional, tag = "3")]
52    pub base_url: ::core::option::Option<::prost::alloc::string::String>,
53    #[prost(string, optional, tag = "4")]
54    pub secret_rid: ::core::option::Option<::prost::alloc::string::String>,
55}
56#[derive(Clone, PartialEq, ::prost::Message)]
57pub struct UpdateRemoteConnectionResponse {
58    #[prost(message, optional, tag = "1")]
59    pub remote_connection: ::core::option::Option<RemoteConnection>,
60}
61#[derive(Clone, PartialEq, ::prost::Message)]
62pub struct DeleteRemoteConnectionRequest {
63    #[prost(string, tag = "1")]
64    pub remote_connection_rid: ::prost::alloc::string::String,
65}
66#[derive(Clone, Copy, PartialEq, ::prost::Message)]
67pub struct DeleteRemoteConnectionResponse {}
68#[derive(Clone, PartialEq, ::prost::Message)]
69pub struct ListRemoteConnectionsRequest {
70    #[prost(string, tag = "1")]
71    pub workspace_rid: ::prost::alloc::string::String,
72    #[prost(int32, tag = "2")]
73    pub page_size: i32,
74    #[prost(string, optional, tag = "3")]
75    pub page_token: ::core::option::Option<::prost::alloc::string::String>,
76}
77#[derive(Clone, PartialEq, ::prost::Message)]
78pub struct ListRemoteConnectionsResponse {
79    #[prost(message, repeated, tag = "1")]
80    pub remote_connections: ::prost::alloc::vec::Vec<RemoteConnection>,
81    #[prost(string, optional, tag = "2")]
82    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
83}
84#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
85#[repr(i32)]
86pub enum RemoteConnectionStatus {
87    Unspecified = 0,
88    Online = 1,
89    Offline = 2,
90}
91impl RemoteConnectionStatus {
92    /// String value of the enum field names used in the ProtoBuf definition.
93    ///
94    /// The values are not transformed in any way and thus are considered stable
95    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
96    pub fn as_str_name(&self) -> &'static str {
97        match self {
98            Self::Unspecified => "REMOTE_CONNECTION_STATUS_UNSPECIFIED",
99            Self::Online => "REMOTE_CONNECTION_STATUS_ONLINE",
100            Self::Offline => "REMOTE_CONNECTION_STATUS_OFFLINE",
101        }
102    }
103    /// Creates an enum from field names used in the ProtoBuf definition.
104    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
105        match value {
106            "REMOTE_CONNECTION_STATUS_UNSPECIFIED" => Some(Self::Unspecified),
107            "REMOTE_CONNECTION_STATUS_ONLINE" => Some(Self::Online),
108            "REMOTE_CONNECTION_STATUS_OFFLINE" => Some(Self::Offline),
109            _ => None,
110        }
111    }
112}
113#[derive(Clone, PartialEq, ::prost::Message)]
114pub struct Link {
115    #[prost(string, tag = "1")]
116    pub rid: ::prost::alloc::string::String,
117    #[prost(string, tag = "2")]
118    pub local_resource_rid: ::prost::alloc::string::String,
119    #[prost(string, tag = "3")]
120    pub remote_resource_rid: ::prost::alloc::string::String,
121    #[prost(string, tag = "4")]
122    pub remote_connection_rid: ::prost::alloc::string::String,
123    #[prost(bool, tag = "5")]
124    pub enabled: bool,
125    #[prost(enumeration = "ResourceType", tag = "6")]
126    pub resource_type: i32,
127}
128#[derive(Clone, PartialEq, ::prost::Message)]
129pub struct CreateLinkRequest {
130    #[prost(string, tag = "1")]
131    pub local_resource_rid: ::prost::alloc::string::String,
132    #[prost(string, tag = "2")]
133    pub remote_resource_rid: ::prost::alloc::string::String,
134    #[prost(string, tag = "3")]
135    pub remote_connection_rid: ::prost::alloc::string::String,
136    #[prost(bool, tag = "4")]
137    pub enabled: bool,
138    #[prost(enumeration = "ResourceType", tag = "5")]
139    pub resource_type: i32,
140    #[prost(string, tag = "6")]
141    pub workspace_rid: ::prost::alloc::string::String,
142}
143#[derive(Clone, Copy, PartialEq, ::prost::Message)]
144pub struct CreateLinkResponse {}
145#[derive(Clone, PartialEq, ::prost::Message)]
146pub struct GetLinkRequest {
147    #[prost(string, tag = "1")]
148    pub link_rid: ::prost::alloc::string::String,
149}
150#[derive(Clone, PartialEq, ::prost::Message)]
151pub struct GetLinkResponse {
152    #[prost(message, optional, tag = "1")]
153    pub link: ::core::option::Option<Link>,
154}
155#[derive(Clone, PartialEq, ::prost::Message)]
156pub struct UpdateLinkRequest {
157    #[prost(string, tag = "1")]
158    pub link_rid: ::prost::alloc::string::String,
159    #[prost(string, optional, tag = "2")]
160    pub remote_connection_rid: ::core::option::Option<::prost::alloc::string::String>,
161    #[prost(bool, optional, tag = "3")]
162    pub enabled: ::core::option::Option<bool>,
163    #[prost(string, optional, tag = "4")]
164    pub remote_resource_rid: ::core::option::Option<::prost::alloc::string::String>,
165}
166#[derive(Clone, PartialEq, ::prost::Message)]
167pub struct UpdateLinkResponse {
168    #[prost(message, optional, tag = "1")]
169    pub link: ::core::option::Option<Link>,
170}
171#[derive(Clone, PartialEq, ::prost::Message)]
172pub struct DeleteLinkRequest {
173    #[prost(string, tag = "1")]
174    pub link_rid: ::prost::alloc::string::String,
175}
176#[derive(Clone, Copy, PartialEq, ::prost::Message)]
177pub struct DeleteLinkResponse {}
178#[derive(Clone, PartialEq, ::prost::Message)]
179pub struct SearchLinksRequest {
180    #[prost(string, tag = "1")]
181    pub workspace_rid: ::prost::alloc::string::String,
182    #[prost(int32, tag = "2")]
183    pub page_size: i32,
184    #[prost(bool, optional, tag = "3")]
185    pub enabled: ::core::option::Option<bool>,
186    #[prost(enumeration = "ResourceType", optional, tag = "4")]
187    pub resource_type: ::core::option::Option<i32>,
188    #[prost(string, optional, tag = "5")]
189    pub local_resource_rid: ::core::option::Option<::prost::alloc::string::String>,
190    #[prost(string, optional, tag = "6")]
191    pub remote_connection_rid: ::core::option::Option<::prost::alloc::string::String>,
192    #[prost(string, optional, tag = "7")]
193    pub page_token: ::core::option::Option<::prost::alloc::string::String>,
194}
195#[derive(Clone, PartialEq, ::prost::Message)]
196pub struct SearchLinksResponse {
197    #[prost(message, repeated, tag = "1")]
198    pub links: ::prost::alloc::vec::Vec<Link>,
199    #[prost(string, optional, tag = "2")]
200    pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
201}
202#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
203#[repr(i32)]
204pub enum ResourceType {
205    Unspecified = 0,
206    Dataset = 1,
207}
208impl ResourceType {
209    /// String value of the enum field names used in the ProtoBuf definition.
210    ///
211    /// The values are not transformed in any way and thus are considered stable
212    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
213    pub fn as_str_name(&self) -> &'static str {
214        match self {
215            Self::Unspecified => "RESOURCE_TYPE_UNSPECIFIED",
216            Self::Dataset => "RESOURCE_TYPE_DATASET",
217        }
218    }
219    /// Creates an enum from field names used in the ProtoBuf definition.
220    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
221        match value {
222            "RESOURCE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
223            "RESOURCE_TYPE_DATASET" => Some(Self::Dataset),
224            _ => None,
225        }
226    }
227}
228#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
229#[repr(i32)]
230pub enum MeshServiceError {
231    LinkNotFound = 0,
232    LinkAlreadyExists = 1,
233    RemoteConnectionNotFound = 2,
234    RemoteConnectionAlreadyExists = 3,
235    RemoteConnectionHasDependentLinks = 4,
236    InvalidApiToken = 5,
237}
238impl MeshServiceError {
239    /// String value of the enum field names used in the ProtoBuf definition.
240    ///
241    /// The values are not transformed in any way and thus are considered stable
242    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
243    pub fn as_str_name(&self) -> &'static str {
244        match self {
245            Self::LinkNotFound => "MESH_SERVICE_ERROR_LINK_NOT_FOUND",
246            Self::LinkAlreadyExists => "MESH_SERVICE_ERROR_LINK_ALREADY_EXISTS",
247            Self::RemoteConnectionNotFound => {
248                "MESH_SERVICE_ERROR_REMOTE_CONNECTION_NOT_FOUND"
249            }
250            Self::RemoteConnectionAlreadyExists => {
251                "MESH_SERVICE_ERROR_REMOTE_CONNECTION_ALREADY_EXISTS"
252            }
253            Self::RemoteConnectionHasDependentLinks => {
254                "MESH_SERVICE_ERROR_REMOTE_CONNECTION_HAS_DEPENDENT_LINKS"
255            }
256            Self::InvalidApiToken => "MESH_SERVICE_ERROR_INVALID_API_TOKEN",
257        }
258    }
259    /// Creates an enum from field names used in the ProtoBuf definition.
260    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
261        match value {
262            "MESH_SERVICE_ERROR_LINK_NOT_FOUND" => Some(Self::LinkNotFound),
263            "MESH_SERVICE_ERROR_LINK_ALREADY_EXISTS" => Some(Self::LinkAlreadyExists),
264            "MESH_SERVICE_ERROR_REMOTE_CONNECTION_NOT_FOUND" => {
265                Some(Self::RemoteConnectionNotFound)
266            }
267            "MESH_SERVICE_ERROR_REMOTE_CONNECTION_ALREADY_EXISTS" => {
268                Some(Self::RemoteConnectionAlreadyExists)
269            }
270            "MESH_SERVICE_ERROR_REMOTE_CONNECTION_HAS_DEPENDENT_LINKS" => {
271                Some(Self::RemoteConnectionHasDependentLinks)
272            }
273            "MESH_SERVICE_ERROR_INVALID_API_TOKEN" => Some(Self::InvalidApiToken),
274            _ => None,
275        }
276    }
277}
278#[derive(Clone, PartialEq, ::prost::Message)]
279pub struct MeshRequest {
280    #[prost(oneof = "mesh_request::Request", tags = "1, 2")]
281    pub request: ::core::option::Option<mesh_request::Request>,
282}
283/// Nested message and enum types in `MeshRequest`.
284pub mod mesh_request {
285    #[derive(Clone, PartialEq, ::prost::Oneof)]
286    pub enum Request {
287        #[prost(message, tag = "1")]
288        DataStream(super::DataStreamRequest),
289        #[prost(message, tag = "2")]
290        FileIngest(super::FileIngestRequest),
291    }
292}
293#[derive(Clone, Copy, PartialEq, ::prost::Message)]
294pub struct MeshResponse {}
295#[derive(Clone, PartialEq, ::prost::Message)]
296pub struct DataStreamRequest {
297    #[prost(message, repeated, tag = "1")]
298    pub write_batches_request: ::prost::alloc::vec::Vec<
299        super::super::direct_channel_writer::v2::InternalWriteBatchesRequest,
300    >,
301}
302#[derive(Clone, PartialEq, ::prost::Message)]
303pub struct FileIngestRequest {
304    #[prost(bytes = "vec", tag = "1")]
305    pub ingest_request: ::prost::alloc::vec::Vec<u8>,
306}
307#[derive(Clone, Copy, PartialEq, ::prost::Message)]
308pub struct HealthCheckRequest {}
309#[derive(Clone, Copy, PartialEq, ::prost::Message)]
310pub struct HealthCheckResponse {}
311/// Generated client implementations.
312pub mod mesh_service_client {
313    #![allow(
314        unused_variables,
315        dead_code,
316        missing_docs,
317        clippy::wildcard_imports,
318        clippy::let_unit_value,
319    )]
320    use tonic::codegen::*;
321    use tonic::codegen::http::Uri;
322    #[derive(Debug, Clone)]
323    pub struct MeshServiceClient<T> {
324        inner: tonic::client::Grpc<T>,
325    }
326    impl MeshServiceClient<tonic::transport::Channel> {
327        /// Attempt to create a new client by connecting to a given endpoint.
328        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
329        where
330            D: TryInto<tonic::transport::Endpoint>,
331            D::Error: Into<StdError>,
332        {
333            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
334            Ok(Self::new(conn))
335        }
336    }
337    impl<T> MeshServiceClient<T>
338    where
339        T: tonic::client::GrpcService<tonic::body::Body>,
340        T::Error: Into<StdError>,
341        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
342        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
343    {
344        pub fn new(inner: T) -> Self {
345            let inner = tonic::client::Grpc::new(inner);
346            Self { inner }
347        }
348        pub fn with_origin(inner: T, origin: Uri) -> Self {
349            let inner = tonic::client::Grpc::with_origin(inner, origin);
350            Self { inner }
351        }
352        pub fn with_interceptor<F>(
353            inner: T,
354            interceptor: F,
355        ) -> MeshServiceClient<InterceptedService<T, F>>
356        where
357            F: tonic::service::Interceptor,
358            T::ResponseBody: Default,
359            T: tonic::codegen::Service<
360                http::Request<tonic::body::Body>,
361                Response = http::Response<
362                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
363                >,
364            >,
365            <T as tonic::codegen::Service<
366                http::Request<tonic::body::Body>,
367            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
368        {
369            MeshServiceClient::new(InterceptedService::new(inner, interceptor))
370        }
371        /// Compress requests with the given encoding.
372        ///
373        /// This requires the server to support it otherwise it might respond with an
374        /// error.
375        #[must_use]
376        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
377            self.inner = self.inner.send_compressed(encoding);
378            self
379        }
380        /// Enable decompressing responses.
381        #[must_use]
382        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
383            self.inner = self.inner.accept_compressed(encoding);
384            self
385        }
386        /// Limits the maximum size of a decoded message.
387        ///
388        /// Default: `4MB`
389        #[must_use]
390        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
391            self.inner = self.inner.max_decoding_message_size(limit);
392            self
393        }
394        /// Limits the maximum size of an encoded message.
395        ///
396        /// Default: `usize::MAX`
397        #[must_use]
398        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
399            self.inner = self.inner.max_encoding_message_size(limit);
400            self
401        }
402        pub async fn mesh(
403            &mut self,
404            request: impl tonic::IntoRequest<super::MeshRequest>,
405        ) -> std::result::Result<tonic::Response<super::MeshResponse>, tonic::Status> {
406            self.inner
407                .ready()
408                .await
409                .map_err(|e| {
410                    tonic::Status::unknown(
411                        format!("Service was not ready: {}", e.into()),
412                    )
413                })?;
414            let codec = tonic::codec::ProstCodec::default();
415            let path = http::uri::PathAndQuery::from_static(
416                "/nominal.mesh.v1.MeshService/Mesh",
417            );
418            let mut req = request.into_request();
419            req.extensions_mut()
420                .insert(GrpcMethod::new("nominal.mesh.v1.MeshService", "Mesh"));
421            self.inner.unary(req, path, codec).await
422        }
423        pub async fn health_check(
424            &mut self,
425            request: impl tonic::IntoRequest<super::HealthCheckRequest>,
426        ) -> std::result::Result<
427            tonic::Response<super::HealthCheckResponse>,
428            tonic::Status,
429        > {
430            self.inner
431                .ready()
432                .await
433                .map_err(|e| {
434                    tonic::Status::unknown(
435                        format!("Service was not ready: {}", e.into()),
436                    )
437                })?;
438            let codec = tonic::codec::ProstCodec::default();
439            let path = http::uri::PathAndQuery::from_static(
440                "/nominal.mesh.v1.MeshService/HealthCheck",
441            );
442            let mut req = request.into_request();
443            req.extensions_mut()
444                .insert(GrpcMethod::new("nominal.mesh.v1.MeshService", "HealthCheck"));
445            self.inner.unary(req, path, codec).await
446        }
447        pub async fn create_link(
448            &mut self,
449            request: impl tonic::IntoRequest<super::CreateLinkRequest>,
450        ) -> std::result::Result<
451            tonic::Response<super::CreateLinkResponse>,
452            tonic::Status,
453        > {
454            self.inner
455                .ready()
456                .await
457                .map_err(|e| {
458                    tonic::Status::unknown(
459                        format!("Service was not ready: {}", e.into()),
460                    )
461                })?;
462            let codec = tonic::codec::ProstCodec::default();
463            let path = http::uri::PathAndQuery::from_static(
464                "/nominal.mesh.v1.MeshService/CreateLink",
465            );
466            let mut req = request.into_request();
467            req.extensions_mut()
468                .insert(GrpcMethod::new("nominal.mesh.v1.MeshService", "CreateLink"));
469            self.inner.unary(req, path, codec).await
470        }
471        pub async fn get_link(
472            &mut self,
473            request: impl tonic::IntoRequest<super::GetLinkRequest>,
474        ) -> std::result::Result<
475            tonic::Response<super::GetLinkResponse>,
476            tonic::Status,
477        > {
478            self.inner
479                .ready()
480                .await
481                .map_err(|e| {
482                    tonic::Status::unknown(
483                        format!("Service was not ready: {}", e.into()),
484                    )
485                })?;
486            let codec = tonic::codec::ProstCodec::default();
487            let path = http::uri::PathAndQuery::from_static(
488                "/nominal.mesh.v1.MeshService/GetLink",
489            );
490            let mut req = request.into_request();
491            req.extensions_mut()
492                .insert(GrpcMethod::new("nominal.mesh.v1.MeshService", "GetLink"));
493            self.inner.unary(req, path, codec).await
494        }
495        pub async fn update_link(
496            &mut self,
497            request: impl tonic::IntoRequest<super::UpdateLinkRequest>,
498        ) -> std::result::Result<
499            tonic::Response<super::UpdateLinkResponse>,
500            tonic::Status,
501        > {
502            self.inner
503                .ready()
504                .await
505                .map_err(|e| {
506                    tonic::Status::unknown(
507                        format!("Service was not ready: {}", e.into()),
508                    )
509                })?;
510            let codec = tonic::codec::ProstCodec::default();
511            let path = http::uri::PathAndQuery::from_static(
512                "/nominal.mesh.v1.MeshService/UpdateLink",
513            );
514            let mut req = request.into_request();
515            req.extensions_mut()
516                .insert(GrpcMethod::new("nominal.mesh.v1.MeshService", "UpdateLink"));
517            self.inner.unary(req, path, codec).await
518        }
519        pub async fn delete_link(
520            &mut self,
521            request: impl tonic::IntoRequest<super::DeleteLinkRequest>,
522        ) -> std::result::Result<
523            tonic::Response<super::DeleteLinkResponse>,
524            tonic::Status,
525        > {
526            self.inner
527                .ready()
528                .await
529                .map_err(|e| {
530                    tonic::Status::unknown(
531                        format!("Service was not ready: {}", e.into()),
532                    )
533                })?;
534            let codec = tonic::codec::ProstCodec::default();
535            let path = http::uri::PathAndQuery::from_static(
536                "/nominal.mesh.v1.MeshService/DeleteLink",
537            );
538            let mut req = request.into_request();
539            req.extensions_mut()
540                .insert(GrpcMethod::new("nominal.mesh.v1.MeshService", "DeleteLink"));
541            self.inner.unary(req, path, codec).await
542        }
543        pub async fn search_links(
544            &mut self,
545            request: impl tonic::IntoRequest<super::SearchLinksRequest>,
546        ) -> std::result::Result<
547            tonic::Response<super::SearchLinksResponse>,
548            tonic::Status,
549        > {
550            self.inner
551                .ready()
552                .await
553                .map_err(|e| {
554                    tonic::Status::unknown(
555                        format!("Service was not ready: {}", e.into()),
556                    )
557                })?;
558            let codec = tonic::codec::ProstCodec::default();
559            let path = http::uri::PathAndQuery::from_static(
560                "/nominal.mesh.v1.MeshService/SearchLinks",
561            );
562            let mut req = request.into_request();
563            req.extensions_mut()
564                .insert(GrpcMethod::new("nominal.mesh.v1.MeshService", "SearchLinks"));
565            self.inner.unary(req, path, codec).await
566        }
567        pub async fn create_remote_connection(
568            &mut self,
569            request: impl tonic::IntoRequest<super::CreateRemoteConnectionRequest>,
570        ) -> std::result::Result<
571            tonic::Response<super::CreateRemoteConnectionResponse>,
572            tonic::Status,
573        > {
574            self.inner
575                .ready()
576                .await
577                .map_err(|e| {
578                    tonic::Status::unknown(
579                        format!("Service was not ready: {}", e.into()),
580                    )
581                })?;
582            let codec = tonic::codec::ProstCodec::default();
583            let path = http::uri::PathAndQuery::from_static(
584                "/nominal.mesh.v1.MeshService/CreateRemoteConnection",
585            );
586            let mut req = request.into_request();
587            req.extensions_mut()
588                .insert(
589                    GrpcMethod::new(
590                        "nominal.mesh.v1.MeshService",
591                        "CreateRemoteConnection",
592                    ),
593                );
594            self.inner.unary(req, path, codec).await
595        }
596        pub async fn get_remote_connection(
597            &mut self,
598            request: impl tonic::IntoRequest<super::GetRemoteConnectionRequest>,
599        ) -> std::result::Result<
600            tonic::Response<super::GetRemoteConnectionResponse>,
601            tonic::Status,
602        > {
603            self.inner
604                .ready()
605                .await
606                .map_err(|e| {
607                    tonic::Status::unknown(
608                        format!("Service was not ready: {}", e.into()),
609                    )
610                })?;
611            let codec = tonic::codec::ProstCodec::default();
612            let path = http::uri::PathAndQuery::from_static(
613                "/nominal.mesh.v1.MeshService/GetRemoteConnection",
614            );
615            let mut req = request.into_request();
616            req.extensions_mut()
617                .insert(
618                    GrpcMethod::new("nominal.mesh.v1.MeshService", "GetRemoteConnection"),
619                );
620            self.inner.unary(req, path, codec).await
621        }
622        pub async fn update_remote_connection(
623            &mut self,
624            request: impl tonic::IntoRequest<super::UpdateRemoteConnectionRequest>,
625        ) -> std::result::Result<
626            tonic::Response<super::UpdateRemoteConnectionResponse>,
627            tonic::Status,
628        > {
629            self.inner
630                .ready()
631                .await
632                .map_err(|e| {
633                    tonic::Status::unknown(
634                        format!("Service was not ready: {}", e.into()),
635                    )
636                })?;
637            let codec = tonic::codec::ProstCodec::default();
638            let path = http::uri::PathAndQuery::from_static(
639                "/nominal.mesh.v1.MeshService/UpdateRemoteConnection",
640            );
641            let mut req = request.into_request();
642            req.extensions_mut()
643                .insert(
644                    GrpcMethod::new(
645                        "nominal.mesh.v1.MeshService",
646                        "UpdateRemoteConnection",
647                    ),
648                );
649            self.inner.unary(req, path, codec).await
650        }
651        pub async fn delete_remote_connection(
652            &mut self,
653            request: impl tonic::IntoRequest<super::DeleteRemoteConnectionRequest>,
654        ) -> std::result::Result<
655            tonic::Response<super::DeleteRemoteConnectionResponse>,
656            tonic::Status,
657        > {
658            self.inner
659                .ready()
660                .await
661                .map_err(|e| {
662                    tonic::Status::unknown(
663                        format!("Service was not ready: {}", e.into()),
664                    )
665                })?;
666            let codec = tonic::codec::ProstCodec::default();
667            let path = http::uri::PathAndQuery::from_static(
668                "/nominal.mesh.v1.MeshService/DeleteRemoteConnection",
669            );
670            let mut req = request.into_request();
671            req.extensions_mut()
672                .insert(
673                    GrpcMethod::new(
674                        "nominal.mesh.v1.MeshService",
675                        "DeleteRemoteConnection",
676                    ),
677                );
678            self.inner.unary(req, path, codec).await
679        }
680        pub async fn list_remote_connections(
681            &mut self,
682            request: impl tonic::IntoRequest<super::ListRemoteConnectionsRequest>,
683        ) -> std::result::Result<
684            tonic::Response<super::ListRemoteConnectionsResponse>,
685            tonic::Status,
686        > {
687            self.inner
688                .ready()
689                .await
690                .map_err(|e| {
691                    tonic::Status::unknown(
692                        format!("Service was not ready: {}", e.into()),
693                    )
694                })?;
695            let codec = tonic::codec::ProstCodec::default();
696            let path = http::uri::PathAndQuery::from_static(
697                "/nominal.mesh.v1.MeshService/ListRemoteConnections",
698            );
699            let mut req = request.into_request();
700            req.extensions_mut()
701                .insert(
702                    GrpcMethod::new(
703                        "nominal.mesh.v1.MeshService",
704                        "ListRemoteConnections",
705                    ),
706                );
707            self.inner.unary(req, path, codec).await
708        }
709    }
710}
nominal_api_proto/proto/nominal.mesh.v1.rs

nominal_api_proto/proto/
nominal.mesh.v1.rs
