cx_api/generated/
com.coralogix.metrics.metrics_configurator.rs

Help
1// This file is @generated by prost-build.
2#[derive(serde::Serialize, serde::Deserialize)]
3#[serde(rename_all = "snake_case")]
4#[derive(Clone, Copy, PartialEq, ::prost::Message)]
5pub struct RetentionPolicy {
6    #[prost(int32, tag = "1")]
7    pub resolution: i32,
8    #[prost(int32, tag = "2")]
9    pub retention_days: i32,
10}
11#[derive(serde::Serialize, serde::Deserialize)]
12#[serde(rename_all = "snake_case")]
13#[derive(Clone, PartialEq, ::prost::Message)]
14pub struct S3Config {
15    #[prost(string, tag = "1")]
16    pub bucket: ::prost::alloc::string::String,
17    #[prost(string, tag = "2")]
18    pub region: ::prost::alloc::string::String,
19}
20#[derive(serde::Serialize, serde::Deserialize)]
21#[serde(rename_all = "snake_case")]
22#[derive(Clone, PartialEq, ::prost::Message)]
23pub struct IbmConfig {
24    #[prost(string, tag = "1")]
25    pub bucket: ::prost::alloc::string::String,
26    #[prost(string, tag = "2")]
27    pub region: ::prost::alloc::string::String,
28    #[prost(string, tag = "3")]
29    pub endpoint: ::prost::alloc::string::String,
30    #[prost(string, tag = "4")]
31    pub crn: ::prost::alloc::string::String,
32}
33#[derive(serde::Serialize, serde::Deserialize)]
34#[serde(rename_all = "snake_case")]
35#[derive(Clone, PartialEq, ::prost::Message)]
36pub struct IbmConfigV2 {
37    /// Endpoint to use to access the bucket
38    #[prost(string, tag = "3")]
39    pub endpoint: ::prost::alloc::string::String,
40    /// Cloud Object Storage bucket CRN
41    #[prost(string, tag = "4")]
42    pub crn: ::prost::alloc::string::String,
43    /// A CRN of a service instance which will be storing data in the bucket.
44    /// Team ID is comming in AuthContext
45    #[prost(string, tag = "5")]
46    pub service_crn: ::prost::alloc::string::String,
47}
48#[derive(serde::Serialize, serde::Deserialize)]
49#[serde(rename_all = "snake_case")]
50#[derive(Clone, PartialEq, ::prost::Message)]
51pub struct TenantConfigV2 {
52    #[prost(uint32, tag = "1")]
53    pub tenant_id: u32,
54    #[prost(message, optional, tag = "4")]
55    pub retention_policy: ::core::option::Option<RetentionPolicyRequest>,
56    #[prost(string, tag = "7")]
57    pub prefix: ::prost::alloc::string::String,
58    #[prost(bool, tag = "9")]
59    pub disabled: bool,
60    #[prost(oneof = "tenant_config_v2::StorageConfig", tags = "5, 6")]
61    pub storage_config: ::core::option::Option<tenant_config_v2::StorageConfig>,
62}
63/// Nested message and enum types in `TenantConfigV2`.
64pub mod tenant_config_v2 {
65    #[derive(serde::Serialize, serde::Deserialize)]
66    #[serde(rename_all = "snake_case")]
67    #[derive(Clone, PartialEq, ::prost::Oneof)]
68    pub enum StorageConfig {
69        #[prost(message, tag = "5")]
70        Ibm(super::IbmConfigV2),
71        #[prost(message, tag = "6")]
72        S3(super::S3Config),
73    }
74}
75#[derive(serde::Serialize, serde::Deserialize)]
76#[serde(rename_all = "snake_case")]
77#[derive(Clone, PartialEq, ::prost::Message)]
78pub struct ConfigureTenantRequest {
79    #[prost(message, optional, tag = "1")]
80    pub retention_policy: ::core::option::Option<RetentionPolicyRequest>,
81    #[prost(oneof = "configure_tenant_request::StorageConfig", tags = "2, 3")]
82    pub storage_config: ::core::option::Option<configure_tenant_request::StorageConfig>,
83}
84/// Nested message and enum types in `ConfigureTenantRequest`.
85pub mod configure_tenant_request {
86    #[derive(serde::Serialize, serde::Deserialize)]
87    #[serde(rename_all = "snake_case")]
88    #[derive(Clone, PartialEq, ::prost::Oneof)]
89    pub enum StorageConfig {
90        #[prost(message, tag = "2")]
91        Ibm(super::IbmConfigV2),
92        #[prost(message, tag = "3")]
93        S3(super::S3Config),
94    }
95}
96#[derive(serde::Serialize, serde::Deserialize)]
97#[serde(rename_all = "snake_case")]
98#[derive(Clone, PartialEq, ::prost::Message)]
99pub struct UpdateRequest {
100    #[prost(uint32, optional, tag = "1")]
101    pub retention_days: ::core::option::Option<u32>,
102    #[prost(oneof = "update_request::StorageConfig", tags = "2, 3")]
103    pub storage_config: ::core::option::Option<update_request::StorageConfig>,
104}
105/// Nested message and enum types in `UpdateRequest`.
106pub mod update_request {
107    #[derive(serde::Serialize, serde::Deserialize)]
108    #[serde(rename_all = "snake_case")]
109    #[derive(Clone, PartialEq, ::prost::Oneof)]
110    pub enum StorageConfig {
111        #[prost(message, tag = "2")]
112        Ibm(super::IbmConfigV2),
113        #[prost(message, tag = "3")]
114        S3(super::S3Config),
115    }
116}
117#[derive(serde::Serialize, serde::Deserialize)]
118#[serde(rename_all = "snake_case")]
119#[derive(Clone, PartialEq, ::prost::Message)]
120pub struct InternalUpdateRequest {
121    #[prost(uint32, tag = "1")]
122    pub tenant_id: u32,
123    #[prost(uint32, optional, tag = "2")]
124    pub retention_days: ::core::option::Option<u32>,
125    #[prost(oneof = "internal_update_request::StorageConfig", tags = "3, 4")]
126    pub storage_config: ::core::option::Option<internal_update_request::StorageConfig>,
127}
128/// Nested message and enum types in `InternalUpdateRequest`.
129pub mod internal_update_request {
130    #[derive(serde::Serialize, serde::Deserialize)]
131    #[serde(rename_all = "snake_case")]
132    #[derive(Clone, PartialEq, ::prost::Oneof)]
133    pub enum StorageConfig {
134        #[prost(message, tag = "3")]
135        Ibm(super::IbmConfigV2),
136        #[prost(message, tag = "4")]
137        S3(super::S3Config),
138    }
139}
140#[derive(serde::Serialize, serde::Deserialize)]
141#[serde(rename_all = "snake_case")]
142#[derive(Clone, PartialEq, ::prost::Message)]
143pub struct ValidateBucketRequest {
144    #[prost(oneof = "validate_bucket_request::StorageConfig", tags = "1, 2")]
145    pub storage_config: ::core::option::Option<validate_bucket_request::StorageConfig>,
146}
147/// Nested message and enum types in `ValidateBucketRequest`.
148pub mod validate_bucket_request {
149    #[derive(serde::Serialize, serde::Deserialize)]
150    #[serde(rename_all = "snake_case")]
151    #[derive(Clone, PartialEq, ::prost::Oneof)]
152    pub enum StorageConfig {
153        #[prost(message, tag = "1")]
154        Ibm(super::IbmConfigV2),
155        #[prost(message, tag = "2")]
156        S3(super::S3Config),
157    }
158}
159#[derive(serde::Serialize, serde::Deserialize)]
160#[serde(rename_all = "snake_case")]
161#[derive(Clone, Copy, PartialEq, ::prost::Message)]
162pub struct RetentionPolicyRequest {
163    #[prost(uint32, tag = "1")]
164    pub raw_resolution: u32,
165    #[prost(uint32, tag = "2")]
166    pub five_minutes_resolution: u32,
167    #[prost(uint32, tag = "3")]
168    pub one_hour_resolution: u32,
169}
170#[derive(serde::Serialize, serde::Deserialize)]
171#[serde(rename_all = "snake_case")]
172#[derive(Clone, PartialEq, ::prost::Message)]
173pub struct TenantConfig {
174    #[prost(uint32, tag = "1")]
175    pub tenant_id: u32,
176    #[deprecated]
177    #[prost(string, tag = "2")]
178    pub bucket_name: ::prost::alloc::string::String,
179    #[deprecated]
180    #[prost(string, tag = "3")]
181    pub region: ::prost::alloc::string::String,
182    #[prost(message, repeated, tag = "4")]
183    pub retention_policy: ::prost::alloc::vec::Vec<RetentionPolicy>,
184    #[prost(string, tag = "7")]
185    pub prefix: ::prost::alloc::string::String,
186    #[prost(uint32, tag = "8")]
187    pub index_version: u32,
188    #[prost(bool, tag = "9")]
189    pub disabled: bool,
190    #[prost(oneof = "tenant_config::StorageConfig", tags = "5, 6")]
191    pub storage_config: ::core::option::Option<tenant_config::StorageConfig>,
192}
193/// Nested message and enum types in `TenantConfig`.
194pub mod tenant_config {
195    #[derive(serde::Serialize, serde::Deserialize)]
196    #[serde(rename_all = "snake_case")]
197    #[derive(Clone, PartialEq, ::prost::Oneof)]
198    pub enum StorageConfig {
199        #[prost(message, tag = "5")]
200        Ibm(super::IbmConfig),
201        #[prost(message, tag = "6")]
202        S3(super::S3Config),
203    }
204}
205#[derive(serde::Serialize, serde::Deserialize)]
206#[serde(rename_all = "snake_case")]
207#[derive(Clone, Copy, PartialEq, ::prost::Message)]
208pub struct GetTenantConfigRequest {
209    #[prost(uint32, tag = "1")]
210    pub tenant_id: u32,
211}
212#[derive(serde::Serialize, serde::Deserialize)]
213#[serde(rename_all = "snake_case")]
214#[derive(Clone, PartialEq, ::prost::Message)]
215pub struct GetTenantConfigResponse {
216    #[prost(message, optional, tag = "1")]
217    pub tenant_config: ::core::option::Option<TenantConfig>,
218}
219#[derive(serde::Serialize, serde::Deserialize)]
220#[serde(rename_all = "snake_case")]
221#[derive(Clone, PartialEq, ::prost::Message)]
222pub struct GetTenantConfigResponseV2 {
223    #[prost(message, optional, tag = "1")]
224    pub tenant_config: ::core::option::Option<TenantConfigV2>,
225}
226#[derive(serde::Serialize, serde::Deserialize)]
227#[serde(rename_all = "snake_case")]
228#[derive(Clone, Copy, PartialEq, ::prost::Message)]
229pub struct ListTenantConfigsRequest {}
230#[derive(serde::Serialize, serde::Deserialize)]
231#[serde(rename_all = "snake_case")]
232#[derive(Clone, PartialEq, ::prost::Message)]
233pub struct ListTenantConfigsResponse {
234    #[prost(message, repeated, tag = "1")]
235    pub tenant_configs: ::prost::alloc::vec::Vec<TenantConfig>,
236}
237#[derive(serde::Serialize, serde::Deserialize)]
238#[serde(rename_all = "snake_case")]
239#[derive(Clone, PartialEq, ::prost::Message)]
240pub struct HotStoreConfig {
241    #[prost(uint32, tag = "1")]
242    pub tenant_id: u32,
243    #[prost(string, tag = "2")]
244    pub cluster_name: ::prost::alloc::string::String,
245}
246#[derive(serde::Serialize, serde::Deserialize)]
247#[serde(rename_all = "snake_case")]
248#[derive(Clone, Copy, PartialEq, ::prost::Message)]
249pub struct MigrateTenantRequest {
250    #[prost(uint32, tag = "1")]
251    pub tenant_id: u32,
252}
253#[derive(serde::Serialize, serde::Deserialize)]
254#[serde(rename_all = "snake_case")]
255#[derive(Clone, Copy, PartialEq, ::prost::Message)]
256pub struct ListHotStoreConfigsRequest {}
257#[derive(serde::Serialize, serde::Deserialize)]
258#[serde(rename_all = "snake_case")]
259#[derive(Clone, PartialEq, ::prost::Message)]
260pub struct ListHotStoreConfigsResponse {
261    #[prost(message, repeated, tag = "1")]
262    pub configs: ::prost::alloc::vec::Vec<HotStoreConfig>,
263}
264/// Generated client implementations.
265pub mod metrics_configurator_public_service_client {
266    #![allow(
267        unused_variables,
268        dead_code,
269        missing_docs,
270        clippy::wildcard_imports,
271        clippy::let_unit_value,
272    )]
273    use tonic::codegen::*;
274    use tonic::codegen::http::Uri;
275    #[derive(Debug, Clone)]
276    pub struct MetricsConfiguratorPublicServiceClient<T> {
277        inner: tonic::client::Grpc<T>,
278    }
279    impl MetricsConfiguratorPublicServiceClient<tonic::transport::Channel> {
280        /// Attempt to create a new client by connecting to a given endpoint.
281        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
282        where
283            D: TryInto<tonic::transport::Endpoint>,
284            D::Error: Into<StdError>,
285        {
286            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
287            Ok(Self::new(conn))
288        }
289    }
290    impl<T> MetricsConfiguratorPublicServiceClient<T>
291    where
292        T: tonic::client::GrpcService<tonic::body::BoxBody>,
293        T::Error: Into<StdError>,
294        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
295        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
296    {
297        pub fn new(inner: T) -> Self {
298            let inner = tonic::client::Grpc::new(inner);
299            Self { inner }
300        }
301        pub fn with_origin(inner: T, origin: Uri) -> Self {
302            let inner = tonic::client::Grpc::with_origin(inner, origin);
303            Self { inner }
304        }
305        pub fn with_interceptor<F>(
306            inner: T,
307            interceptor: F,
308        ) -> MetricsConfiguratorPublicServiceClient<InterceptedService<T, F>>
309        where
310            F: tonic::service::Interceptor,
311            T::ResponseBody: Default,
312            T: tonic::codegen::Service<
313                http::Request<tonic::body::BoxBody>,
314                Response = http::Response<
315                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
316                >,
317            >,
318            <T as tonic::codegen::Service<
319                http::Request<tonic::body::BoxBody>,
320            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
321        {
322            MetricsConfiguratorPublicServiceClient::new(
323                InterceptedService::new(inner, interceptor),
324            )
325        }
326        /// Compress requests with the given encoding.
327        ///
328        /// This requires the server to support it otherwise it might respond with an
329        /// error.
330        #[must_use]
331        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
332            self.inner = self.inner.send_compressed(encoding);
333            self
334        }
335        /// Enable decompressing responses.
336        #[must_use]
337        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
338            self.inner = self.inner.accept_compressed(encoding);
339            self
340        }
341        /// Limits the maximum size of a decoded message.
342        ///
343        /// Default: `4MB`
344        #[must_use]
345        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
346            self.inner = self.inner.max_decoding_message_size(limit);
347            self
348        }
349        /// Limits the maximum size of an encoded message.
350        ///
351        /// Default: `usize::MAX`
352        #[must_use]
353        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
354            self.inner = self.inner.max_encoding_message_size(limit);
355            self
356        }
357        pub async fn configure_tenant(
358            &mut self,
359            request: impl tonic::IntoRequest<super::ConfigureTenantRequest>,
360        ) -> std::result::Result<tonic::Response<()>, tonic::Status> {
361            self.inner
362                .ready()
363                .await
364                .map_err(|e| {
365                    tonic::Status::unknown(
366                        format!("Service was not ready: {}", e.into()),
367                    )
368                })?;
369            let codec = tonic::codec::ProstCodec::default();
370            let path = http::uri::PathAndQuery::from_static(
371                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService/ConfigureTenant",
372            );
373            let mut req = request.into_request();
374            req.extensions_mut()
375                .insert(
376                    GrpcMethod::new(
377                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService",
378                        "ConfigureTenant",
379                    ),
380                );
381            self.inner.unary(req, path, codec).await
382        }
383        pub async fn update(
384            &mut self,
385            request: impl tonic::IntoRequest<super::UpdateRequest>,
386        ) -> std::result::Result<tonic::Response<()>, tonic::Status> {
387            self.inner
388                .ready()
389                .await
390                .map_err(|e| {
391                    tonic::Status::unknown(
392                        format!("Service was not ready: {}", e.into()),
393                    )
394                })?;
395            let codec = tonic::codec::ProstCodec::default();
396            let path = http::uri::PathAndQuery::from_static(
397                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService/Update",
398            );
399            let mut req = request.into_request();
400            req.extensions_mut()
401                .insert(
402                    GrpcMethod::new(
403                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService",
404                        "Update",
405                    ),
406                );
407            self.inner.unary(req, path, codec).await
408        }
409        pub async fn validate_bucket(
410            &mut self,
411            request: impl tonic::IntoRequest<super::ValidateBucketRequest>,
412        ) -> std::result::Result<tonic::Response<()>, tonic::Status> {
413            self.inner
414                .ready()
415                .await
416                .map_err(|e| {
417                    tonic::Status::unknown(
418                        format!("Service was not ready: {}", e.into()),
419                    )
420                })?;
421            let codec = tonic::codec::ProstCodec::default();
422            let path = http::uri::PathAndQuery::from_static(
423                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService/ValidateBucket",
424            );
425            let mut req = request.into_request();
426            req.extensions_mut()
427                .insert(
428                    GrpcMethod::new(
429                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService",
430                        "ValidateBucket",
431                    ),
432                );
433            self.inner.unary(req, path, codec).await
434        }
435        pub async fn get_tenant_config(
436            &mut self,
437            request: impl tonic::IntoRequest<()>,
438        ) -> std::result::Result<
439            tonic::Response<super::GetTenantConfigResponseV2>,
440            tonic::Status,
441        > {
442            self.inner
443                .ready()
444                .await
445                .map_err(|e| {
446                    tonic::Status::unknown(
447                        format!("Service was not ready: {}", e.into()),
448                    )
449                })?;
450            let codec = tonic::codec::ProstCodec::default();
451            let path = http::uri::PathAndQuery::from_static(
452                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService/GetTenantConfig",
453            );
454            let mut req = request.into_request();
455            req.extensions_mut()
456                .insert(
457                    GrpcMethod::new(
458                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService",
459                        "GetTenantConfig",
460                    ),
461                );
462            self.inner.unary(req, path, codec).await
463        }
464        pub async fn enable_archive(
465            &mut self,
466            request: impl tonic::IntoRequest<()>,
467        ) -> std::result::Result<tonic::Response<()>, tonic::Status> {
468            self.inner
469                .ready()
470                .await
471                .map_err(|e| {
472                    tonic::Status::unknown(
473                        format!("Service was not ready: {}", e.into()),
474                    )
475                })?;
476            let codec = tonic::codec::ProstCodec::default();
477            let path = http::uri::PathAndQuery::from_static(
478                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService/EnableArchive",
479            );
480            let mut req = request.into_request();
481            req.extensions_mut()
482                .insert(
483                    GrpcMethod::new(
484                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService",
485                        "EnableArchive",
486                    ),
487                );
488            self.inner.unary(req, path, codec).await
489        }
490        pub async fn disable_archive(
491            &mut self,
492            request: impl tonic::IntoRequest<()>,
493        ) -> std::result::Result<tonic::Response<()>, tonic::Status> {
494            self.inner
495                .ready()
496                .await
497                .map_err(|e| {
498                    tonic::Status::unknown(
499                        format!("Service was not ready: {}", e.into()),
500                    )
501                })?;
502            let codec = tonic::codec::ProstCodec::default();
503            let path = http::uri::PathAndQuery::from_static(
504                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService/DisableArchive",
505            );
506            let mut req = request.into_request();
507            req.extensions_mut()
508                .insert(
509                    GrpcMethod::new(
510                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorPublicService",
511                        "DisableArchive",
512                    ),
513                );
514            self.inner.unary(req, path, codec).await
515        }
516    }
517}
518/// Generated client implementations.
519pub mod metrics_configurator_service_client {
520    #![allow(
521        unused_variables,
522        dead_code,
523        missing_docs,
524        clippy::wildcard_imports,
525        clippy::let_unit_value,
526    )]
527    use tonic::codegen::*;
528    use tonic::codegen::http::Uri;
529    #[derive(Debug, Clone)]
530    pub struct MetricsConfiguratorServiceClient<T> {
531        inner: tonic::client::Grpc<T>,
532    }
533    impl MetricsConfiguratorServiceClient<tonic::transport::Channel> {
534        /// Attempt to create a new client by connecting to a given endpoint.
535        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
536        where
537            D: TryInto<tonic::transport::Endpoint>,
538            D::Error: Into<StdError>,
539        {
540            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
541            Ok(Self::new(conn))
542        }
543    }
544    impl<T> MetricsConfiguratorServiceClient<T>
545    where
546        T: tonic::client::GrpcService<tonic::body::BoxBody>,
547        T::Error: Into<StdError>,
548        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
549        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
550    {
551        pub fn new(inner: T) -> Self {
552            let inner = tonic::client::Grpc::new(inner);
553            Self { inner }
554        }
555        pub fn with_origin(inner: T, origin: Uri) -> Self {
556            let inner = tonic::client::Grpc::with_origin(inner, origin);
557            Self { inner }
558        }
559        pub fn with_interceptor<F>(
560            inner: T,
561            interceptor: F,
562        ) -> MetricsConfiguratorServiceClient<InterceptedService<T, F>>
563        where
564            F: tonic::service::Interceptor,
565            T::ResponseBody: Default,
566            T: tonic::codegen::Service<
567                http::Request<tonic::body::BoxBody>,
568                Response = http::Response<
569                    <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
570                >,
571            >,
572            <T as tonic::codegen::Service<
573                http::Request<tonic::body::BoxBody>,
574            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
575        {
576            MetricsConfiguratorServiceClient::new(
577                InterceptedService::new(inner, interceptor),
578            )
579        }
580        /// Compress requests with the given encoding.
581        ///
582        /// This requires the server to support it otherwise it might respond with an
583        /// error.
584        #[must_use]
585        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
586            self.inner = self.inner.send_compressed(encoding);
587            self
588        }
589        /// Enable decompressing responses.
590        #[must_use]
591        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
592            self.inner = self.inner.accept_compressed(encoding);
593            self
594        }
595        /// Limits the maximum size of a decoded message.
596        ///
597        /// Default: `4MB`
598        #[must_use]
599        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
600            self.inner = self.inner.max_decoding_message_size(limit);
601            self
602        }
603        /// Limits the maximum size of an encoded message.
604        ///
605        /// Default: `usize::MAX`
606        #[must_use]
607        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
608            self.inner = self.inner.max_encoding_message_size(limit);
609            self
610        }
611        pub async fn get_tenant_config(
612            &mut self,
613            request: impl tonic::IntoRequest<super::GetTenantConfigRequest>,
614        ) -> std::result::Result<
615            tonic::Response<super::GetTenantConfigResponse>,
616            tonic::Status,
617        > {
618            self.inner
619                .ready()
620                .await
621                .map_err(|e| {
622                    tonic::Status::unknown(
623                        format!("Service was not ready: {}", e.into()),
624                    )
625                })?;
626            let codec = tonic::codec::ProstCodec::default();
627            let path = http::uri::PathAndQuery::from_static(
628                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService/GetTenantConfig",
629            );
630            let mut req = request.into_request();
631            req.extensions_mut()
632                .insert(
633                    GrpcMethod::new(
634                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService",
635                        "GetTenantConfig",
636                    ),
637                );
638            self.inner.unary(req, path, codec).await
639        }
640        pub async fn list_tenant_configs(
641            &mut self,
642            request: impl tonic::IntoRequest<super::ListTenantConfigsRequest>,
643        ) -> std::result::Result<
644            tonic::Response<super::ListTenantConfigsResponse>,
645            tonic::Status,
646        > {
647            self.inner
648                .ready()
649                .await
650                .map_err(|e| {
651                    tonic::Status::unknown(
652                        format!("Service was not ready: {}", e.into()),
653                    )
654                })?;
655            let codec = tonic::codec::ProstCodec::default();
656            let path = http::uri::PathAndQuery::from_static(
657                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService/ListTenantConfigs",
658            );
659            let mut req = request.into_request();
660            req.extensions_mut()
661                .insert(
662                    GrpcMethod::new(
663                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService",
664                        "ListTenantConfigs",
665                    ),
666                );
667            self.inner.unary(req, path, codec).await
668        }
669        pub async fn list_host_store_configs(
670            &mut self,
671            request: impl tonic::IntoRequest<super::ListHotStoreConfigsRequest>,
672        ) -> std::result::Result<
673            tonic::Response<super::ListHotStoreConfigsResponse>,
674            tonic::Status,
675        > {
676            self.inner
677                .ready()
678                .await
679                .map_err(|e| {
680                    tonic::Status::unknown(
681                        format!("Service was not ready: {}", e.into()),
682                    )
683                })?;
684            let codec = tonic::codec::ProstCodec::default();
685            let path = http::uri::PathAndQuery::from_static(
686                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService/ListHostStoreConfigs",
687            );
688            let mut req = request.into_request();
689            req.extensions_mut()
690                .insert(
691                    GrpcMethod::new(
692                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService",
693                        "ListHostStoreConfigs",
694                    ),
695                );
696            self.inner.unary(req, path, codec).await
697        }
698        pub async fn migrate_tenant(
699            &mut self,
700            request: impl tonic::IntoRequest<super::MigrateTenantRequest>,
701        ) -> std::result::Result<tonic::Response<()>, tonic::Status> {
702            self.inner
703                .ready()
704                .await
705                .map_err(|e| {
706                    tonic::Status::unknown(
707                        format!("Service was not ready: {}", e.into()),
708                    )
709                })?;
710            let codec = tonic::codec::ProstCodec::default();
711            let path = http::uri::PathAndQuery::from_static(
712                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService/MigrateTenant",
713            );
714            let mut req = request.into_request();
715            req.extensions_mut()
716                .insert(
717                    GrpcMethod::new(
718                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService",
719                        "MigrateTenant",
720                    ),
721                );
722            self.inner.unary(req, path, codec).await
723        }
724        pub async fn update(
725            &mut self,
726            request: impl tonic::IntoRequest<super::InternalUpdateRequest>,
727        ) -> std::result::Result<tonic::Response<()>, tonic::Status> {
728            self.inner
729                .ready()
730                .await
731                .map_err(|e| {
732                    tonic::Status::unknown(
733                        format!("Service was not ready: {}", e.into()),
734                    )
735                })?;
736            let codec = tonic::codec::ProstCodec::default();
737            let path = http::uri::PathAndQuery::from_static(
738                "/com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService/Update",
739            );
740            let mut req = request.into_request();
741            req.extensions_mut()
742                .insert(
743                    GrpcMethod::new(
744                        "com.coralogix.metrics.metrics_configurator.MetricsConfiguratorService",
745                        "Update",
746                    ),
747                );
748            self.inner.unary(req, path, codec).await
749        }
750    }
751}
cx_api/generated/com.coralogix.metrics.metrics_configurator.rs

cx_api/generated/
com.coralogix.metrics.metrics_configurator.rs
