#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AuditLogDescription {
#[prost(string, optional, tag = "1")]
pub description: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetPolicyRequest {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ArchiveRetention {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
}
#[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 Priority {
TypeUnspecified = 0,
TypeBlock = 1,
TypeLow = 2,
TypeMedium = 3,
TypeHigh = 4,
}
impl Priority {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::TypeUnspecified => "PRIORITY_TYPE_UNSPECIFIED",
Self::TypeBlock => "PRIORITY_TYPE_BLOCK",
Self::TypeLow => "PRIORITY_TYPE_LOW",
Self::TypeMedium => "PRIORITY_TYPE_MEDIUM",
Self::TypeHigh => "PRIORITY_TYPE_HIGH",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"PRIORITY_TYPE_UNSPECIFIED" => Some(Self::TypeUnspecified),
"PRIORITY_TYPE_BLOCK" => Some(Self::TypeBlock),
"PRIORITY_TYPE_LOW" => Some(Self::TypeLow),
"PRIORITY_TYPE_MEDIUM" => Some(Self::TypeMedium),
"PRIORITY_TYPE_HIGH" => Some(Self::TypeHigh),
_ => None,
}
}
}
#[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 Severity {
Unspecified = 0,
Debug = 1,
Verbose = 2,
Info = 3,
Warning = 4,
Error = 5,
Critical = 6,
}
impl Severity {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "SEVERITY_UNSPECIFIED",
Self::Debug => "SEVERITY_DEBUG",
Self::Verbose => "SEVERITY_VERBOSE",
Self::Info => "SEVERITY_INFO",
Self::Warning => "SEVERITY_WARNING",
Self::Error => "SEVERITY_ERROR",
Self::Critical => "SEVERITY_CRITICAL",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"SEVERITY_UNSPECIFIED" => Some(Self::Unspecified),
"SEVERITY_DEBUG" => Some(Self::Debug),
"SEVERITY_VERBOSE" => Some(Self::Verbose),
"SEVERITY_INFO" => Some(Self::Info),
"SEVERITY_WARNING" => Some(Self::Warning),
"SEVERITY_ERROR" => Some(Self::Error),
"SEVERITY_CRITICAL" => Some(Self::Critical),
_ => None,
}
}
}
#[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 SourceType {
Unspecified = 0,
Logs = 1,
Spans = 2,
}
impl SourceType {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "SOURCE_TYPE_UNSPECIFIED",
Self::Logs => "SOURCE_TYPE_LOGS",
Self::Spans => "SOURCE_TYPE_SPANS",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"SOURCE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
"SOURCE_TYPE_LOGS" => Some(Self::Logs),
"SOURCE_TYPE_SPANS" => Some(Self::Spans),
_ => None,
}
}
}
#[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 RuleTypeId {
Unspecified = 0,
Is = 2,
IsNot = 3,
StartWith = 4,
Includes = 6,
}
impl RuleTypeId {
pub fn as_str_name(&self) -> &'static str {
match self {
Self::Unspecified => "RULE_TYPE_ID_UNSPECIFIED",
Self::Is => "RULE_TYPE_ID_IS",
Self::IsNot => "RULE_TYPE_ID_IS_NOT",
Self::StartWith => "RULE_TYPE_ID_START_WITH",
Self::Includes => "RULE_TYPE_ID_INCLUDES",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"RULE_TYPE_ID_UNSPECIFIED" => Some(Self::Unspecified),
"RULE_TYPE_ID_IS" => Some(Self::Is),
"RULE_TYPE_ID_IS_NOT" => Some(Self::IsNot),
"RULE_TYPE_ID_START_WITH" => Some(Self::StartWith),
"RULE_TYPE_ID_INCLUDES" => Some(Self::Includes),
_ => None,
}
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Rule {
#[prost(enumeration = "RuleTypeId", tag = "1")]
pub rule_type_id: i32,
#[prost(message, optional, tag = "2")]
pub name: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LogRules {
#[prost(enumeration = "Severity", repeated, tag = "1")]
pub severities: ::prost::alloc::vec::Vec<i32>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TagRule {
#[prost(enumeration = "RuleTypeId", tag = "1")]
pub rule_type_id: i32,
#[prost(message, optional, tag = "2")]
pub tag_name: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "3")]
pub tag_value: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SpanRules {
#[prost(message, optional, tag = "1")]
pub service_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "2")]
pub action_rule: ::core::option::Option<Rule>,
#[prost(message, repeated, tag = "3")]
pub tag_rules: ::prost::alloc::vec::Vec<TagRule>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Policy {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub company_id: ::core::option::Option<i32>,
#[prost(message, optional, tag = "3")]
pub name: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "4")]
pub description: ::core::option::Option<::prost::alloc::string::String>,
#[prost(enumeration = "Priority", tag = "5")]
pub priority: i32,
#[prost(message, optional, tag = "6")]
pub deleted: ::core::option::Option<bool>,
#[prost(message, optional, tag = "7")]
pub enabled: ::core::option::Option<bool>,
#[prost(message, optional, tag = "8")]
pub order: ::core::option::Option<i32>,
#[prost(message, optional, tag = "9")]
pub application_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "10")]
pub subsystem_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "13")]
pub created_at: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "14")]
pub updated_at: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "15")]
pub archive_retention: ::core::option::Option<ArchiveRetention>,
#[prost(oneof = "policy::SourceTypeRules", tags = "11, 12")]
pub source_type_rules: ::core::option::Option<policy::SourceTypeRules>,
}
pub mod policy {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum SourceTypeRules {
#[prost(message, tag = "11")]
LogRules(super::LogRules),
#[prost(message, tag = "12")]
SpanRules(super::SpanRules),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetPolicyResponse {
#[prost(message, optional, tag = "1")]
pub policy: ::core::option::Option<Policy>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreatePolicyRequest {
#[prost(message, optional, tag = "1")]
pub name: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub description: ::core::option::Option<::prost::alloc::string::String>,
#[prost(enumeration = "Priority", tag = "3")]
pub priority: i32,
#[prost(message, optional, tag = "4")]
pub application_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "5")]
pub subsystem_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "6")]
pub archive_retention: ::core::option::Option<ArchiveRetention>,
#[prost(oneof = "create_policy_request::SourceTypeRules", tags = "7, 8")]
pub source_type_rules: ::core::option::Option<
create_policy_request::SourceTypeRules,
>,
}
pub mod create_policy_request {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum SourceTypeRules {
#[prost(message, tag = "7")]
LogRules(super::LogRules),
#[prost(message, tag = "8")]
SpanRules(super::SpanRules),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreatePolicyResponse {
#[prost(message, optional, tag = "1")]
pub policy: ::core::option::Option<Policy>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdatePolicyRequest {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub name: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "3")]
pub description: ::core::option::Option<::prost::alloc::string::String>,
#[prost(enumeration = "Priority", tag = "4")]
pub priority: i32,
#[prost(message, optional, tag = "5")]
pub application_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "6")]
pub subsystem_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "7")]
pub archive_retention: ::core::option::Option<ArchiveRetention>,
#[prost(message, optional, tag = "10")]
pub enabled: ::core::option::Option<bool>,
#[prost(oneof = "update_policy_request::SourceTypeRules", tags = "8, 9")]
pub source_type_rules: ::core::option::Option<
update_policy_request::SourceTypeRules,
>,
}
pub mod update_policy_request {
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum SourceTypeRules {
#[prost(message, tag = "8")]
LogRules(super::LogRules),
#[prost(message, tag = "9")]
SpanRules(super::SpanRules),
}
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdatePolicyResponse {
#[prost(message, optional, tag = "1")]
pub policy: ::core::option::Option<Policy>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct GetCompanyPoliciesRequest {
#[prost(message, optional, tag = "1")]
pub enabled_only: ::core::option::Option<bool>,
#[prost(enumeration = "SourceType", optional, tag = "2")]
pub source_type: ::core::option::Option<i32>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCompanyPoliciesResponse {
#[prost(message, repeated, tag = "1")]
pub policies: ::prost::alloc::vec::Vec<Policy>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeletePolicyRequest {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeletePolicyResponse {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PolicyOrder {
#[prost(message, optional, tag = "1")]
pub order: ::core::option::Option<i32>,
#[prost(message, optional, tag = "2")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReorderPoliciesRequest {
#[prost(message, repeated, tag = "1")]
pub orders: ::prost::alloc::vec::Vec<PolicyOrder>,
#[prost(enumeration = "SourceType", tag = "2")]
pub source_type: i32,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReorderPoliciesResponse {
#[prost(message, repeated, tag = "1")]
pub orders: ::prost::alloc::vec::Vec<PolicyOrder>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LogMetaFieldsValues {
#[prost(message, optional, tag = "1")]
pub application_name_values: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub severity_values: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "3")]
pub subsystem_name_values: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BulkTestLogPoliciesRequest {
#[prost(message, repeated, tag = "1")]
pub meta_fields_values_list: ::prost::alloc::vec::Vec<LogMetaFieldsValues>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TestPoliciesResult {
#[prost(message, optional, tag = "1")]
pub meta_fields_values: ::core::option::Option<LogMetaFieldsValues>,
#[prost(message, optional, tag = "2")]
pub matched: ::core::option::Option<bool>,
#[prost(message, optional, tag = "3")]
pub policy: ::core::option::Option<Policy>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BulkTestLogPoliciesResponse {
#[prost(message, repeated, tag = "1")]
pub test_policies_bulk_result: ::prost::alloc::vec::Vec<TestPoliciesResult>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TogglePolicyRequest {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub enabled: ::core::option::Option<bool>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TogglePolicyResponse {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub enabled: ::core::option::Option<bool>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AtomicBatchCreatePolicyRequest {
#[prost(message, repeated, tag = "1")]
pub policy_requests: ::prost::alloc::vec::Vec<CreatePolicyRequest>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AtomicBatchCreatePolicyResponse {
#[prost(message, repeated, tag = "1")]
pub create_responses: ::prost::alloc::vec::Vec<CreatePolicyResponse>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AtomicOverwriteLogPoliciesResponse {
#[prost(message, repeated, tag = "1")]
pub create_responses: ::prost::alloc::vec::Vec<CreatePolicyResponse>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AtomicOverwriteSpanPoliciesResponse {
#[prost(message, repeated, tag = "1")]
pub create_responses: ::prost::alloc::vec::Vec<CreatePolicyResponse>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AtomicOverwriteLogPoliciesRequest {
#[prost(message, repeated, tag = "1")]
pub policies: ::prost::alloc::vec::Vec<CreateLogPolicyRequest>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AtomicOverwriteSpanPoliciesRequest {
#[prost(message, repeated, tag = "1")]
pub policies: ::prost::alloc::vec::Vec<CreateSpanPolicyRequest>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateSpanPolicyRequest {
#[prost(message, optional, tag = "1")]
pub policy: ::core::option::Option<CreateGenericPolicyRequest>,
#[prost(message, optional, tag = "2")]
pub span_rules: ::core::option::Option<SpanRules>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateLogPolicyRequest {
#[prost(message, optional, tag = "1")]
pub policy: ::core::option::Option<CreateGenericPolicyRequest>,
#[prost(message, optional, tag = "2")]
pub log_rules: ::core::option::Option<LogRules>,
}
#[derive(serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "snake_case")]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateGenericPolicyRequest {
#[prost(message, optional, tag = "1")]
pub name: ::core::option::Option<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub description: ::core::option::Option<::prost::alloc::string::String>,
#[prost(enumeration = "Priority", tag = "3")]
pub priority: i32,
#[prost(message, optional, tag = "4")]
pub application_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "5")]
pub subsystem_rule: ::core::option::Option<Rule>,
#[prost(message, optional, tag = "6")]
pub archive_retention: ::core::option::Option<ArchiveRetention>,
}
pub mod policies_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 PoliciesServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl PoliciesServiceClient<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> PoliciesServiceClient<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,
) -> PoliciesServiceClient<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,
{
PoliciesServiceClient::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_policy(
&mut self,
request: impl tonic::IntoRequest<super::GetPolicyRequest>,
) -> std::result::Result<
tonic::Response<super::GetPolicyResponse>,
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.coralogix.quota.v1.PoliciesService/GetPolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"GetPolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn create_policy(
&mut self,
request: impl tonic::IntoRequest<super::CreatePolicyRequest>,
) -> std::result::Result<
tonic::Response<super::CreatePolicyResponse>,
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.coralogix.quota.v1.PoliciesService/CreatePolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"CreatePolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_policy(
&mut self,
request: impl tonic::IntoRequest<super::UpdatePolicyRequest>,
) -> std::result::Result<
tonic::Response<super::UpdatePolicyResponse>,
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.coralogix.quota.v1.PoliciesService/UpdatePolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"UpdatePolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_company_policies(
&mut self,
request: impl tonic::IntoRequest<super::GetCompanyPoliciesRequest>,
) -> std::result::Result<
tonic::Response<super::GetCompanyPoliciesResponse>,
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.coralogix.quota.v1.PoliciesService/GetCompanyPolicies",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"GetCompanyPolicies",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_policy(
&mut self,
request: impl tonic::IntoRequest<super::DeletePolicyRequest>,
) -> std::result::Result<
tonic::Response<super::DeletePolicyResponse>,
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.coralogix.quota.v1.PoliciesService/DeletePolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"DeletePolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn reorder_policies(
&mut self,
request: impl tonic::IntoRequest<super::ReorderPoliciesRequest>,
) -> std::result::Result<
tonic::Response<super::ReorderPoliciesResponse>,
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.coralogix.quota.v1.PoliciesService/ReorderPolicies",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"ReorderPolicies",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn bulk_test_log_policies(
&mut self,
request: impl tonic::IntoRequest<super::BulkTestLogPoliciesRequest>,
) -> std::result::Result<
tonic::Response<super::BulkTestLogPoliciesResponse>,
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.coralogix.quota.v1.PoliciesService/BulkTestLogPolicies",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"BulkTestLogPolicies",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn toggle_policy(
&mut self,
request: impl tonic::IntoRequest<super::TogglePolicyRequest>,
) -> std::result::Result<
tonic::Response<super::TogglePolicyResponse>,
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.coralogix.quota.v1.PoliciesService/TogglePolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"TogglePolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn atomic_batch_create_policy(
&mut self,
request: impl tonic::IntoRequest<super::AtomicBatchCreatePolicyRequest>,
) -> std::result::Result<
tonic::Response<super::AtomicBatchCreatePolicyResponse>,
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.coralogix.quota.v1.PoliciesService/AtomicBatchCreatePolicy",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"AtomicBatchCreatePolicy",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn atomic_overwrite_log_policies(
&mut self,
request: impl tonic::IntoRequest<super::AtomicOverwriteLogPoliciesRequest>,
) -> std::result::Result<
tonic::Response<super::AtomicOverwriteLogPoliciesResponse>,
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.coralogix.quota.v1.PoliciesService/AtomicOverwriteLogPolicies",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"AtomicOverwriteLogPolicies",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn atomic_overwrite_span_policies(
&mut self,
request: impl tonic::IntoRequest<super::AtomicOverwriteSpanPoliciesRequest>,
) -> std::result::Result<
tonic::Response<super::AtomicOverwriteSpanPoliciesResponse>,
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.coralogix.quota.v1.PoliciesService/AtomicOverwriteSpanPolicies",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"com.coralogix.quota.v1.PoliciesService",
"AtomicOverwriteSpanPolicies",
),
);
self.inner.unary(req, path, codec).await
}
}
}