#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Filter {
#[prost(string, tag = "1")]
pub what_expression: ::prost::alloc::string::String,
#[prost(oneof = "filter::WhichAlerts", tags = "2, 3")]
pub which_alerts: ::core::option::Option<filter::WhichAlerts>,
}
pub mod filter {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum WhichAlerts {
#[prost(message, tag = "2")]
AlertMetaLabels(super::MetaLabels),
#[prost(message, tag = "3")]
AlertUniqueIds(super::AlertUniqueIds),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AlertUniqueIds {
#[prost(string, repeated, tag = "1")]
pub value: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MetaLabels {
#[prost(message, repeated, tag = "1")]
pub value: ::prost::alloc::vec::Vec<
super::super::meta_labels_protobuf::v1::MetaLabel,
>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Timeframe {
#[prost(string, tag = "1")]
pub start_time: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub timezone: ::prost::alloc::string::String,
#[prost(oneof = "timeframe::Until", tags = "2, 3")]
pub until: ::core::option::Option<timeframe::Until>,
}
pub mod timeframe {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Until {
#[prost(string, tag = "2")]
EndTime(::prost::alloc::string::String),
#[prost(message, tag = "3")]
Duration(super::Duration),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Duration {
#[prost(int32, tag = "1")]
pub for_over: i32,
#[prost(enumeration = "DurationFrequency", tag = "2")]
pub frequency: i32,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum DurationFrequency {
Unspecified = 0,
Minute = 1,
Hour = 2,
Day = 3,
}
impl DurationFrequency {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "DURATION_FREQUENCY_UNSPECIFIED",
Self::Minute => "DURATION_FREQUENCY_MINUTE",
Self::Hour => "DURATION_FREQUENCY_HOUR",
Self::Day => "DURATION_FREQUENCY_DAY",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"DURATION_FREQUENCY_UNSPECIFIED" => Some(Self::Unspecified),
"DURATION_FREQUENCY_MINUTE" => Some(Self::Minute),
"DURATION_FREQUENCY_HOUR" => Some(Self::Hour),
"DURATION_FREQUENCY_DAY" => Some(Self::Day),
_ => None,
}
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Schedule {
#[prost(enumeration = "ScheduleOperation", tag = "1")]
pub schedule_operation: i32,
#[prost(oneof = "schedule::Scheduler", tags = "2, 3")]
pub scheduler: ::core::option::Option<schedule::Scheduler>,
}
pub mod schedule {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Scheduler {
#[prost(message, tag = "2")]
OneTime(super::OneTime),
#[prost(message, tag = "3")]
Recurring(super::Recurring),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OneTime {
#[prost(message, optional, tag = "1")]
pub timeframe: ::core::option::Option<Timeframe>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Recurring {
#[prost(oneof = "recurring::Condition", tags = "1, 2")]
pub condition: ::core::option::Option<recurring::Condition>,
}
pub mod recurring {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Always {}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Dynamic {
#[prost(int32, tag = "1")]
pub repeat_every: i32,
#[prost(message, optional, tag = "5")]
pub timeframe: ::core::option::Option<super::Timeframe>,
#[prost(string, optional, tag = "6")]
pub termination_date: ::core::option::Option<::prost::alloc::string::String>,
#[prost(oneof = "dynamic::Frequency", tags = "2, 3, 4")]
pub frequency: ::core::option::Option<dynamic::Frequency>,
}
pub mod dynamic {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Frequency {
#[prost(message, tag = "2")]
Daily(super::super::Daily),
#[prost(message, tag = "3")]
Weekly(super::super::Weekly),
#[prost(message, tag = "4")]
Monthly(super::super::Monthly),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Condition {
#[prost(message, tag = "1")]
Always(Always),
#[prost(message, tag = "2")]
Dynamic(Dynamic),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct Daily {}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Weekly {
#[prost(int32, repeated, tag = "1")]
pub days_of_week: ::prost::alloc::vec::Vec<i32>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Monthly {
#[prost(int32, repeated, tag = "1")]
pub days_of_month: ::prost::alloc::vec::Vec<i32>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ScheduleOperation {
Unspecified = 0,
Mute = 1,
Activate = 2,
}
impl ScheduleOperation {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "SCHEDULE_OPERATION_UNSPECIFIED",
Self::Mute => "SCHEDULE_OPERATION_MUTE",
Self::Activate => "SCHEDULE_OPERATION_ACTIVATE",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"SCHEDULE_OPERATION_UNSPECIFIED" => Some(Self::Unspecified),
"SCHEDULE_OPERATION_MUTE" => Some(Self::Mute),
"SCHEDULE_OPERATION_ACTIVATE" => Some(Self::Activate),
_ => None,
}
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AlertSchedulerRule {
#[prost(string, optional, tag = "1")]
pub unique_identifier: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, optional, tag = "2")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, tag = "3")]
pub name: ::prost::alloc::string::String,
#[prost(string, optional, tag = "4")]
pub description: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, repeated, tag = "5")]
pub meta_labels: ::prost::alloc::vec::Vec<
super::super::meta_labels_protobuf::v1::MetaLabel,
>,
#[prost(message, optional, tag = "6")]
pub filter: ::core::option::Option<Filter>,
#[prost(message, optional, tag = "7")]
pub schedule: ::core::option::Option<Schedule>,
#[prost(bool, tag = "8")]
pub enabled: bool,
#[prost(string, optional, tag = "9")]
pub created_at: ::core::option::Option<::prost::alloc::string::String>,
#[prost(string, optional, tag = "10")]
pub updated_at: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ActiveTimeframe {
#[prost(string, tag = "1")]
pub start_time: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub end_time: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub timezone: ::prost::alloc::string::String,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAlertSchedulerRuleRequest {
#[prost(string, tag = "1")]
pub alert_scheduler_rule_id: ::prost::alloc::string::String,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateAlertSchedulerRuleRequest {
#[prost(message, optional, tag = "1")]
pub alert_scheduler_rule: ::core::option::Option<AlertSchedulerRule>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateAlertSchedulerRuleRequest {
#[prost(message, optional, tag = "1")]
pub alert_scheduler_rule: ::core::option::Option<AlertSchedulerRule>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteAlertSchedulerRuleRequest {
#[prost(string, tag = "1")]
pub alert_scheduler_rule_id: ::prost::alloc::string::String,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AlertSchedulerRuleIds {
#[prost(string, repeated, tag = "1")]
pub alert_scheduler_rule_ids: ::prost::alloc::vec::Vec<
::prost::alloc::string::String,
>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AlertSchedulerRuleVersionIds {
#[prost(string, repeated, tag = "1")]
pub alert_scheduler_rule_version_ids: ::prost::alloc::vec::Vec<
::prost::alloc::string::String,
>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FilterByAlertSchedulerRuleIds {
#[prost(
oneof = "filter_by_alert_scheduler_rule_ids::AlertSchedulerRuleIds",
tags = "3, 4"
)]
pub alert_scheduler_rule_ids: ::core::option::Option<
filter_by_alert_scheduler_rule_ids::AlertSchedulerRuleIds,
>,
}
pub mod filter_by_alert_scheduler_rule_ids {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum AlertSchedulerRuleIds {
#[prost(message, tag = "3")]
AlertSchedulerIds(super::AlertSchedulerRuleIds),
#[prost(message, tag = "4")]
AlertSchedulerVersionIds(super::AlertSchedulerRuleVersionIds),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetBulkAlertSchedulerRuleRequest {
#[prost(message, optional, tag = "1")]
pub active_timeframe: ::core::option::Option<ActiveTimeframe>,
#[prost(bool, optional, tag = "2")]
pub enabled: ::core::option::Option<bool>,
#[prost(message, optional, tag = "3")]
pub alert_scheduler_rules_ids: ::core::option::Option<FilterByAlertSchedulerRuleIds>,
#[prost(string, optional, tag = "15")]
pub next_page_token: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateBulkAlertSchedulerRuleRequest {
#[prost(message, repeated, tag = "1")]
pub create_alert_scheduler_rule_requests: ::prost::alloc::vec::Vec<
CreateAlertSchedulerRuleRequest,
>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateBulkAlertSchedulerRuleRequest {
#[prost(message, repeated, tag = "1")]
pub update_alert_scheduler_rule_requests: ::prost::alloc::vec::Vec<
UpdateAlertSchedulerRuleRequest,
>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteBulkAlertSchedulerRuleRequest {
#[prost(message, repeated, tag = "1")]
pub delete_alert_scheduler_rule_requests: ::prost::alloc::vec::Vec<
DeleteAlertSchedulerRuleRequest,
>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetAlertSchedulerRuleResponse {
#[prost(message, optional, tag = "1")]
pub alert_scheduler_rule: ::core::option::Option<AlertSchedulerRule>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateAlertSchedulerRuleResponse {
#[prost(message, optional, tag = "1")]
pub alert_scheduler_rule: ::core::option::Option<AlertSchedulerRule>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateAlertSchedulerRuleResponse {
#[prost(message, optional, tag = "1")]
pub alert_scheduler_rule: ::core::option::Option<AlertSchedulerRule>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct DeleteAlertSchedulerRuleResponse {}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateBulkAlertSchedulerRuleResponse {
#[prost(message, repeated, tag = "1")]
pub create_suppression_responses: ::prost::alloc::vec::Vec<
CreateAlertSchedulerRuleResponse,
>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateBulkAlertSchedulerRuleResponse {
#[prost(message, repeated, tag = "1")]
pub update_suppression_responses: ::prost::alloc::vec::Vec<
UpdateAlertSchedulerRuleResponse,
>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetBulkAlertSchedulerRuleResponse {
#[prost(message, repeated, tag = "1")]
pub alert_scheduler_rules: ::prost::alloc::vec::Vec<
AlertSchedulerRuleWithActiveTimeframe,
>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AlertSchedulerRuleWithActiveTimeframe {
#[prost(message, optional, tag = "1")]
pub alert_scheduler_rule: ::core::option::Option<AlertSchedulerRule>,
#[prost(message, repeated, tag = "2")]
pub next_active_timeframes: ::prost::alloc::vec::Vec<ActiveTimeframe>,
}
pub mod alert_scheduler_rule_service_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value,
)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct AlertSchedulerRuleServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl AlertSchedulerRuleServiceClient<tonic::transport::Channel> {
pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
where
D: TryInto<tonic::transport::Endpoint>,
D::Error: Into<StdError>,
{
let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
Ok(Self::new(conn))
}
}
impl<T> AlertSchedulerRuleServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> AlertSchedulerRuleServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
AlertSchedulerRuleServiceClient::new(
InterceptedService::new(inner, interceptor),
)
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn get_alert_scheduler_rule(
&mut self,
request: impl tonic::IntoRequest<super::GetAlertSchedulerRuleRequest>,
) -> std::result::Result<
tonic::Response<super::GetAlertSchedulerRuleResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService/GetAlertSchedulerRule",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService",
"GetAlertSchedulerRule",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_alert_scheduler_rule(
&mut self,
request: impl tonic::IntoRequest<super::CreateAlertSchedulerRuleRequest>,
) -> std::result::Result<
tonic::Response<super::CreateAlertSchedulerRuleResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService/CreateAlertSchedulerRule",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService",
"CreateAlertSchedulerRule",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_alert_scheduler_rule(
&mut self,
request: impl tonic::IntoRequest<super::UpdateAlertSchedulerRuleRequest>,
) -> std::result::Result<
tonic::Response<super::UpdateAlertSchedulerRuleResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService/UpdateAlertSchedulerRule",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService",
"UpdateAlertSchedulerRule",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_alert_scheduler_rule(
&mut self,
request: impl tonic::IntoRequest<super::DeleteAlertSchedulerRuleRequest>,
) -> std::result::Result<
tonic::Response<super::DeleteAlertSchedulerRuleResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService/DeleteAlertSchedulerRule",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService",
"DeleteAlertSchedulerRule",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_bulk_alert_scheduler_rule(
&mut self,
request: impl tonic::IntoRequest<super::GetBulkAlertSchedulerRuleRequest>,
) -> std::result::Result<
tonic::Response<super::GetBulkAlertSchedulerRuleResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService/GetBulkAlertSchedulerRule",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService",
"GetBulkAlertSchedulerRule",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_bulk_alert_scheduler_rule(
&mut self,
request: impl tonic::IntoRequest<super::CreateBulkAlertSchedulerRuleRequest>,
) -> std::result::Result<
tonic::Response<super::CreateBulkAlertSchedulerRuleResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService/CreateBulkAlertSchedulerRule",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService",
"CreateBulkAlertSchedulerRule",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_bulk_alert_scheduler_rule(
&mut self,
request: impl tonic::IntoRequest<super::UpdateBulkAlertSchedulerRuleRequest>,
) -> std::result::Result<
tonic::Response<super::UpdateBulkAlertSchedulerRuleResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::unknown(
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService/UpdateBulkAlertSchedulerRule",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogixapis.alerting.alert_scheduler_rule_protobuf.v1.AlertSchedulerRuleService",
"UpdateBulkAlertSchedulerRule",
),
);
self.inner.unary(req, path, codec).await
}
}
}