cx_api/generated/
com.coralogixapis.notification_center.connectors.v1.rs

Search
1// This file is @generated by prost-build.
2#[derive(serde::Serialize, serde::Deserialize)]
3#[serde(rename_all = "snake_case")]
4#[derive(Clone, PartialEq, ::prost::Message)]
5pub struct Connector {
6    /// A unique identifier - automatically generated unless provided by the user
7    #[prost(string, optional, tag = "1")]
8    pub id: ::core::option::Option<::prost::alloc::string::String>,
9    #[prost(enumeration = "super::super::ConnectorType", tag = "3")]
10    pub r#type: i32,
11    #[prost(uint32, optional, tag = "4")]
12    pub team_id: ::core::option::Option<u32>,
13    #[prost(string, tag = "5")]
14    pub name: ::prost::alloc::string::String,
15    #[prost(string, tag = "6")]
16    pub description: ::prost::alloc::string::String,
17    /// System-generated timestamp for when the connector was last updated
18    #[prost(message, optional, tag = "7")]
19    pub create_time: ::core::option::Option<::prost_wkt_types::Timestamp>,
20    /// System-generated timestamp for when the connector was last updated
21    #[prost(message, optional, tag = "8")]
22    pub update_time: ::core::option::Option<::prost_wkt_types::Timestamp>,
23    /// Configuration override templates for specific entity types, values from connector_configs will be used if not overridden
24    #[prost(message, repeated, tag = "11")]
25    pub config_overrides: ::prost::alloc::vec::Vec<EntityTypeConfigOverrides>,
26    #[prost(message, optional, tag = "12")]
27    pub connector_config: ::core::option::Option<ConnectorConfig>,
28    #[prost(message, optional, tag = "13")]
29    pub diagnostics: ::core::option::Option<Diagnostics>,
30}
31#[derive(serde::Serialize, serde::Deserialize)]
32#[serde(rename_all = "snake_case")]
33#[derive(Clone, PartialEq, ::prost::Message)]
34pub struct ConnectorInternal {
35    /// automatically generated unless provided by the user
36    #[prost(string, tag = "1")]
37    pub id: ::prost::alloc::string::String,
38    /// system generated uuid
39    #[prost(string, tag = "2")]
40    pub internal_id: ::prost::alloc::string::String,
41    #[prost(enumeration = "super::super::ConnectorType", tag = "3")]
42    pub r#type: i32,
43    #[prost(uint32, tag = "4")]
44    pub team_id: u32,
45    #[prost(string, tag = "5")]
46    pub name: ::prost::alloc::string::String,
47    #[prost(string, tag = "6")]
48    pub description: ::prost::alloc::string::String,
49    /// System-generated timestamp for when the connector was last updated
50    #[prost(message, optional, tag = "7")]
51    pub create_time: ::core::option::Option<::prost_wkt_types::Timestamp>,
52    /// System-generated timestamp for when the connector was last updated
53    #[prost(message, optional, tag = "8")]
54    pub update_time: ::core::option::Option<::prost_wkt_types::Timestamp>,
55    /// Configuration override templates for specific entity types, values from connector_configs will be used if not overridden
56    #[prost(message, repeated, tag = "9")]
57    pub config_overrides: ::prost::alloc::vec::Vec<EntityTypeConfigOverrides>,
58    #[prost(message, optional, tag = "10")]
59    pub connector_config: ::core::option::Option<ConnectorConfig>,
60    #[prost(message, optional, tag = "11")]
61    pub diagnostics: ::core::option::Option<Diagnostics>,
62}
63#[derive(serde::Serialize, serde::Deserialize)]
64#[serde(rename_all = "snake_case")]
65#[derive(Clone, PartialEq, ::prost::Message)]
66pub struct EntityTypeConfigOverrides {
67    #[prost(enumeration = "super::super::EntityType", tag = "3")]
68    pub entity_type: i32,
69    #[prost(message, repeated, tag = "4")]
70    pub fields: ::prost::alloc::vec::Vec<super::super::TemplatedConnectorConfigField>,
71}
72#[derive(serde::Serialize, serde::Deserialize)]
73#[serde(rename_all = "snake_case")]
74#[derive(Clone, PartialEq, ::prost::Message)]
75pub struct ConnectorSummary {
76    #[prost(string, optional, tag = "1")]
77    pub id: ::core::option::Option<::prost::alloc::string::String>,
78    #[prost(enumeration = "super::super::ConnectorType", tag = "3")]
79    pub r#type: i32,
80    #[prost(uint32, optional, tag = "4")]
81    pub team_id: ::core::option::Option<u32>,
82    #[prost(string, tag = "5")]
83    pub name: ::prost::alloc::string::String,
84    #[prost(string, tag = "6")]
85    pub description: ::prost::alloc::string::String,
86    #[prost(message, optional, tag = "7")]
87    pub create_time: ::core::option::Option<::prost_wkt_types::Timestamp>,
88    #[prost(message, optional, tag = "8")]
89    pub update_time: ::core::option::Option<::prost_wkt_types::Timestamp>,
90}
91#[derive(serde::Serialize, serde::Deserialize)]
92#[serde(rename_all = "snake_case")]
93#[derive(Clone, PartialEq, ::prost::Message)]
94pub struct ConnectorConfig {
95    #[prost(message, repeated, tag = "2")]
96    pub fields: ::prost::alloc::vec::Vec<super::super::ConnectorConfigField>,
97}
98#[derive(serde::Serialize, serde::Deserialize)]
99#[serde(rename_all = "snake_case")]
100#[derive(Clone, Copy, PartialEq, ::prost::Message)]
101pub struct ConnectorTypeSummary {
102    #[prost(enumeration = "super::super::ConnectorType", tag = "1")]
103    pub r#type: i32,
104    #[prost(uint32, tag = "2")]
105    pub count: u32,
106}
107#[derive(serde::Serialize, serde::Deserialize)]
108#[serde(rename_all = "snake_case")]
109#[derive(Clone, Copy, PartialEq, ::prost::Message)]
110pub struct Diagnostics {
111    #[prost(enumeration = "diagnostics::Delivery", tag = "1")]
112    pub delivery: i32,
113}
114/// Nested message and enum types in `Diagnostics`.
115pub mod diagnostics {
116    #[derive(serde::Serialize, serde::Deserialize)]
117    #[serde(rename_all = "snake_case")]
118    #[derive(
119        Clone,
120        Copy,
121        Debug,
122        PartialEq,
123        Eq,
124        Hash,
125        PartialOrd,
126        Ord,
127        ::prost::Enumeration
128    )]
129    #[repr(i32)]
130    pub enum Delivery {
131        Unspecified = 0,
132        Disabled = 1,
133        ErrorsOnly = 2,
134    }
135    impl Delivery {
136        /// String value of the enum field names used in the ProtoBuf definition.
137        ///
138        /// The values are not transformed in any way and thus are considered stable
139        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
140        pub fn as_str_name(&self) -> &'static str {
141            match self {
142                Self::Unspecified => "DELIVERY_UNSPECIFIED",
143                Self::Disabled => "DISABLED",
144                Self::ErrorsOnly => "ERRORS_ONLY",
145            }
146        }
147        /// Creates an enum from field names used in the ProtoBuf definition.
148        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
149            match value {
150                "DELIVERY_UNSPECIFIED" => Some(Self::Unspecified),
151                "DISABLED" => Some(Self::Disabled),
152                "ERRORS_ONLY" => Some(Self::ErrorsOnly),
153                _ => None,
154            }
155        }
156    }
157}
158#[derive(serde::Serialize, serde::Deserialize)]
159#[serde(rename_all = "snake_case")]
160#[derive(Clone, PartialEq, ::prost::Message)]
161pub struct CreateConnectorRequest {
162    #[prost(message, optional, tag = "1")]
163    pub connector: ::core::option::Option<Connector>,
164}
165#[derive(serde::Serialize, serde::Deserialize)]
166#[serde(rename_all = "snake_case")]
167#[derive(Clone, PartialEq, ::prost::Message)]
168pub struct CreateConnectorResponse {
169    #[prost(message, optional, tag = "1")]
170    pub connector: ::core::option::Option<Connector>,
171}
172#[derive(serde::Serialize, serde::Deserialize)]
173#[serde(rename_all = "snake_case")]
174#[derive(Clone, PartialEq, ::prost::Message)]
175pub struct ReplaceConnectorRequest {
176    #[prost(message, optional, tag = "1")]
177    pub connector: ::core::option::Option<Connector>,
178}
179#[derive(serde::Serialize, serde::Deserialize)]
180#[serde(rename_all = "snake_case")]
181#[derive(Clone, PartialEq, ::prost::Message)]
182pub struct ReplaceConnectorResponse {
183    #[prost(message, optional, tag = "1")]
184    pub connector: ::core::option::Option<Connector>,
185}
186#[derive(serde::Serialize, serde::Deserialize)]
187#[serde(rename_all = "snake_case")]
188#[derive(Clone, PartialEq, ::prost::Message)]
189pub struct DeleteConnectorRequest {
190    #[prost(string, tag = "3")]
191    pub id: ::prost::alloc::string::String,
192}
193#[derive(serde::Serialize, serde::Deserialize)]
194#[serde(rename_all = "snake_case")]
195#[derive(Clone, Copy, PartialEq, ::prost::Message)]
196pub struct DeleteConnectorResponse {}
197#[derive(serde::Serialize, serde::Deserialize)]
198#[serde(rename_all = "snake_case")]
199#[derive(Clone, PartialEq, ::prost::Message)]
200pub struct GetConnectorRequest {
201    #[prost(string, tag = "3")]
202    pub id: ::prost::alloc::string::String,
203}
204#[derive(serde::Serialize, serde::Deserialize)]
205#[serde(rename_all = "snake_case")]
206#[derive(Clone, PartialEq, ::prost::Message)]
207pub struct GetConnectorResponse {
208    #[prost(message, optional, tag = "1")]
209    pub connector: ::core::option::Option<Connector>,
210}
211#[derive(serde::Serialize, serde::Deserialize)]
212#[serde(rename_all = "snake_case")]
213#[derive(Clone, Copy, PartialEq, ::prost::Message)]
214pub struct ListConnectorsRequest {
215    #[prost(enumeration = "super::super::ConnectorType", optional, tag = "1")]
216    pub connector_type: ::core::option::Option<i32>,
217    #[prost(enumeration = "super::super::EntityType", optional, tag = "4")]
218    pub supported_by_entity_type: ::core::option::Option<i32>,
219}
220#[derive(serde::Serialize, serde::Deserialize)]
221#[serde(rename_all = "snake_case")]
222#[derive(Clone, PartialEq, ::prost::Message)]
223pub struct ListConnectorsResponse {
224    #[prost(message, repeated, tag = "1")]
225    pub connectors: ::prost::alloc::vec::Vec<Connector>,
226}
227#[derive(serde::Serialize, serde::Deserialize)]
228#[serde(rename_all = "snake_case")]
229#[derive(Clone, PartialEq, ::prost::Message)]
230pub struct BatchGetConnectorsRequest {
231    #[prost(string, repeated, tag = "3")]
232    pub connector_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
233}
234#[derive(serde::Serialize, serde::Deserialize)]
235#[serde(rename_all = "snake_case")]
236#[derive(Clone, PartialEq, ::prost::Message)]
237pub struct BatchGetConnectorsResponse {
238    #[prost(map = "string, message", tag = "1")]
239    pub connectors: ::std::collections::HashMap<
240        ::prost::alloc::string::String,
241        Connector,
242    >,
243    #[prost(string, repeated, tag = "2")]
244    pub not_found_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
245}
246#[derive(serde::Serialize, serde::Deserialize)]
247#[serde(rename_all = "snake_case")]
248#[derive(Clone, PartialEq, ::prost::Message)]
249pub struct BatchGetConnectorSummariesRequest {
250    #[prost(string, repeated, tag = "3")]
251    pub connector_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
252}
253#[derive(serde::Serialize, serde::Deserialize)]
254#[serde(rename_all = "snake_case")]
255#[derive(Clone, PartialEq, ::prost::Message)]
256pub struct BatchGetConnectorSummariesResponse {
257    #[prost(map = "string, message", tag = "1")]
258    pub connector_summaries: ::std::collections::HashMap<
259        ::prost::alloc::string::String,
260        ConnectorSummary,
261    >,
262    #[prost(string, repeated, tag = "2")]
263    pub not_found_ids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
264}
265#[derive(serde::Serialize, serde::Deserialize)]
266#[serde(rename_all = "snake_case")]
267#[derive(Clone, Copy, PartialEq, ::prost::Message)]
268pub struct ListConnectorSummariesRequest {
269    #[prost(enumeration = "super::super::ConnectorType", optional, tag = "1")]
270    pub connector_type: ::core::option::Option<i32>,
271    #[prost(enumeration = "super::super::EntityType", optional, tag = "4")]
272    pub supported_by_entity_type: ::core::option::Option<i32>,
273}
274#[derive(serde::Serialize, serde::Deserialize)]
275#[serde(rename_all = "snake_case")]
276#[derive(Clone, PartialEq, ::prost::Message)]
277pub struct ListConnectorSummariesResponse {
278    #[prost(message, repeated, tag = "1")]
279    pub connectors: ::prost::alloc::vec::Vec<ConnectorSummary>,
280}
281#[derive(serde::Serialize, serde::Deserialize)]
282#[serde(rename_all = "snake_case")]
283#[derive(Clone, Copy, PartialEq, ::prost::Message)]
284pub struct GetConnectorTypeSummariesRequest {
285    #[prost(enumeration = "super::super::EntityType", optional, tag = "1")]
286    pub supported_by_entity_type: ::core::option::Option<i32>,
287}
288#[derive(serde::Serialize, serde::Deserialize)]
289#[serde(rename_all = "snake_case")]
290#[derive(Clone, PartialEq, ::prost::Message)]
291pub struct GetConnectorTypeSummariesResponse {
292    #[prost(message, repeated, tag = "1")]
293    pub connector_type_summaries: ::prost::alloc::vec::Vec<ConnectorTypeSummary>,
294}
295/// Generated client implementations.
296pub mod connectors_service_client {
297    #![allow(
298        unused_variables,
299        dead_code,
300        missing_docs,
301        clippy::wildcard_imports,
302        clippy::let_unit_value,
303    )]
304    use tonic::codegen::*;
305    use tonic::codegen::http::Uri;
306    /// Public API that allows managing connectors.
307    #[derive(Debug, Clone)]
308    pub struct ConnectorsServiceClient<T> {
309        inner: tonic::client::Grpc<T>,
310    }
311    impl ConnectorsServiceClient<tonic::transport::Channel> {
312        /// Attempt to create a new client by connecting to a given endpoint.
313        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
314        where
315            D: TryInto<tonic::transport::Endpoint>,
316            D::Error: Into<StdError>,
317        {
318            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
319            Ok(Self::new(conn))
320        }
321    }
322    impl<T> ConnectorsServiceClient<T>
323    where
324        T: tonic::client::GrpcService<tonic::body::BoxBody>,
325        T::Error: Into<StdError>,
326        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
327        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
328    {
329        pub fn new(inner: T) -> Self {
330            let inner = tonic::client::Grpc::new(inner);
331            Self { inner }
332        }
333        pub fn with_origin(inner: T, origin: Uri) -> Self {
334            let inner = tonic::client::Grpc::with_origin(inner, origin);
335            Self { inner }
336        }
337        pub fn with_interceptor<F>(
338            inner: T,
339            interceptor: F,
340        ) -> ConnectorsServiceClient<InterceptedService<T, F>>
341        where
342            F: tonic::service::Interceptor,
343            T::ResponseBody: Default,
344            T: tonic::codegen::Service<
345                http::Request<tonic::body::BoxBody>,
346                Response = http::Response<
347                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
348                >,
349            >,
350            <T as tonic::codegen::Service<
351                http::Request<tonic::body::BoxBody>,
352            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
353        {
354            ConnectorsServiceClient::new(InterceptedService::new(inner, interceptor))
355        }
356        /// Compress requests with the given encoding.
357        ///
358        /// This requires the server to support it otherwise it might respond with an
359        /// error.
360        #[must_use]
361        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
362            self.inner = self.inner.send_compressed(encoding);
363            self
364        }
365        /// Enable decompressing responses.
366        #[must_use]
367        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
368            self.inner = self.inner.accept_compressed(encoding);
369            self
370        }
371        /// Limits the maximum size of a decoded message.
372        ///
373        /// Default: `4MB`
374        #[must_use]
375        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
376            self.inner = self.inner.max_decoding_message_size(limit);
377            self
378        }
379        /// Limits the maximum size of an encoded message.
380        ///
381        /// Default: `usize::MAX`
382        #[must_use]
383        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
384            self.inner = self.inner.max_encoding_message_size(limit);
385            self
386        }
387        pub async fn create_connector(
388            &mut self,
389            request: impl tonic::IntoRequest<super::CreateConnectorRequest>,
390        ) -> std::result::Result<
391            tonic::Response<super::CreateConnectorResponse>,
392            tonic::Status,
393        > {
394            self.inner
395                .ready()
396                .await
397                .map_err(|e| {
398                    tonic::Status::unknown(
399                        format!("Service was not ready: {}", e.into()),
400                    )
401                })?;
402            let codec = tonic::codec::ProstCodec::default();
403            let path = http::uri::PathAndQuery::from_static(
404                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/CreateConnector",
405            );
406            let mut req = request.into_request();
407            req.extensions_mut()
408                .insert(
409                    GrpcMethod::new(
410                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
411                        "CreateConnector",
412                    ),
413                );
414            self.inner.unary(req, path, codec).await
415        }
416        pub async fn replace_connector(
417            &mut self,
418            request: impl tonic::IntoRequest<super::ReplaceConnectorRequest>,
419        ) -> std::result::Result<
420            tonic::Response<super::ReplaceConnectorResponse>,
421            tonic::Status,
422        > {
423            self.inner
424                .ready()
425                .await
426                .map_err(|e| {
427                    tonic::Status::unknown(
428                        format!("Service was not ready: {}", e.into()),
429                    )
430                })?;
431            let codec = tonic::codec::ProstCodec::default();
432            let path = http::uri::PathAndQuery::from_static(
433                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/ReplaceConnector",
434            );
435            let mut req = request.into_request();
436            req.extensions_mut()
437                .insert(
438                    GrpcMethod::new(
439                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
440                        "ReplaceConnector",
441                    ),
442                );
443            self.inner.unary(req, path, codec).await
444        }
445        pub async fn delete_connector(
446            &mut self,
447            request: impl tonic::IntoRequest<super::DeleteConnectorRequest>,
448        ) -> std::result::Result<
449            tonic::Response<super::DeleteConnectorResponse>,
450            tonic::Status,
451        > {
452            self.inner
453                .ready()
454                .await
455                .map_err(|e| {
456                    tonic::Status::unknown(
457                        format!("Service was not ready: {}", e.into()),
458                    )
459                })?;
460            let codec = tonic::codec::ProstCodec::default();
461            let path = http::uri::PathAndQuery::from_static(
462                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/DeleteConnector",
463            );
464            let mut req = request.into_request();
465            req.extensions_mut()
466                .insert(
467                    GrpcMethod::new(
468                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
469                        "DeleteConnector",
470                    ),
471                );
472            self.inner.unary(req, path, codec).await
473        }
474        pub async fn get_connector(
475            &mut self,
476            request: impl tonic::IntoRequest<super::GetConnectorRequest>,
477        ) -> std::result::Result<
478            tonic::Response<super::GetConnectorResponse>,
479            tonic::Status,
480        > {
481            self.inner
482                .ready()
483                .await
484                .map_err(|e| {
485                    tonic::Status::unknown(
486                        format!("Service was not ready: {}", e.into()),
487                    )
488                })?;
489            let codec = tonic::codec::ProstCodec::default();
490            let path = http::uri::PathAndQuery::from_static(
491                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/GetConnector",
492            );
493            let mut req = request.into_request();
494            req.extensions_mut()
495                .insert(
496                    GrpcMethod::new(
497                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
498                        "GetConnector",
499                    ),
500                );
501            self.inner.unary(req, path, codec).await
502        }
503        pub async fn list_connectors(
504            &mut self,
505            request: impl tonic::IntoRequest<super::ListConnectorsRequest>,
506        ) -> std::result::Result<
507            tonic::Response<super::ListConnectorsResponse>,
508            tonic::Status,
509        > {
510            self.inner
511                .ready()
512                .await
513                .map_err(|e| {
514                    tonic::Status::unknown(
515                        format!("Service was not ready: {}", e.into()),
516                    )
517                })?;
518            let codec = tonic::codec::ProstCodec::default();
519            let path = http::uri::PathAndQuery::from_static(
520                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/ListConnectors",
521            );
522            let mut req = request.into_request();
523            req.extensions_mut()
524                .insert(
525                    GrpcMethod::new(
526                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
527                        "ListConnectors",
528                    ),
529                );
530            self.inner.unary(req, path, codec).await
531        }
532        pub async fn batch_get_connectors(
533            &mut self,
534            request: impl tonic::IntoRequest<super::BatchGetConnectorsRequest>,
535        ) -> std::result::Result<
536            tonic::Response<super::BatchGetConnectorsResponse>,
537            tonic::Status,
538        > {
539            self.inner
540                .ready()
541                .await
542                .map_err(|e| {
543                    tonic::Status::unknown(
544                        format!("Service was not ready: {}", e.into()),
545                    )
546                })?;
547            let codec = tonic::codec::ProstCodec::default();
548            let path = http::uri::PathAndQuery::from_static(
549                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/BatchGetConnectors",
550            );
551            let mut req = request.into_request();
552            req.extensions_mut()
553                .insert(
554                    GrpcMethod::new(
555                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
556                        "BatchGetConnectors",
557                    ),
558                );
559            self.inner.unary(req, path, codec).await
560        }
561        pub async fn batch_get_connector_summaries(
562            &mut self,
563            request: impl tonic::IntoRequest<super::BatchGetConnectorSummariesRequest>,
564        ) -> std::result::Result<
565            tonic::Response<super::BatchGetConnectorSummariesResponse>,
566            tonic::Status,
567        > {
568            self.inner
569                .ready()
570                .await
571                .map_err(|e| {
572                    tonic::Status::unknown(
573                        format!("Service was not ready: {}", e.into()),
574                    )
575                })?;
576            let codec = tonic::codec::ProstCodec::default();
577            let path = http::uri::PathAndQuery::from_static(
578                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/BatchGetConnectorSummaries",
579            );
580            let mut req = request.into_request();
581            req.extensions_mut()
582                .insert(
583                    GrpcMethod::new(
584                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
585                        "BatchGetConnectorSummaries",
586                    ),
587                );
588            self.inner.unary(req, path, codec).await
589        }
590        pub async fn list_connector_summaries(
591            &mut self,
592            request: impl tonic::IntoRequest<super::ListConnectorSummariesRequest>,
593        ) -> std::result::Result<
594            tonic::Response<super::ListConnectorSummariesResponse>,
595            tonic::Status,
596        > {
597            self.inner
598                .ready()
599                .await
600                .map_err(|e| {
601                    tonic::Status::unknown(
602                        format!("Service was not ready: {}", e.into()),
603                    )
604                })?;
605            let codec = tonic::codec::ProstCodec::default();
606            let path = http::uri::PathAndQuery::from_static(
607                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/ListConnectorSummaries",
608            );
609            let mut req = request.into_request();
610            req.extensions_mut()
611                .insert(
612                    GrpcMethod::new(
613                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
614                        "ListConnectorSummaries",
615                    ),
616                );
617            self.inner.unary(req, path, codec).await
618        }
619        pub async fn get_connector_type_summaries(
620            &mut self,
621            request: impl tonic::IntoRequest<super::GetConnectorTypeSummariesRequest>,
622        ) -> std::result::Result<
623            tonic::Response<super::GetConnectorTypeSummariesResponse>,
624            tonic::Status,
625        > {
626            self.inner
627                .ready()
628                .await
629                .map_err(|e| {
630                    tonic::Status::unknown(
631                        format!("Service was not ready: {}", e.into()),
632                    )
633                })?;
634            let codec = tonic::codec::ProstCodec::default();
635            let path = http::uri::PathAndQuery::from_static(
636                "/com.coralogixapis.notification_center.connectors.v1.ConnectorsService/GetConnectorTypeSummaries",
637            );
638            let mut req = request.into_request();
639            req.extensions_mut()
640                .insert(
641                    GrpcMethod::new(
642                        "com.coralogixapis.notification_center.connectors.v1.ConnectorsService",
643                        "GetConnectorTypeSummaries",
644                    ),
645                );
646            self.inner.unary(req, path, codec).await
647        }
648    }
649}
cx_api/generated/com.coralogixapis.notification_center.connectors.v1.rs

cx_api/generated/
com.coralogixapis.notification_center.connectors.v1.rs
