nominal_api_proto/proto/
nominal.mesh.v1.rs

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

nominal_api_proto/proto/
nominal.mesh.v1.rs
