risingwave_pb/sim/

telemetry.rs

// This file is @generated by prost-build.
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SystemMemory {
    #[prost(uint64, tag = "1")]
    pub used: u64,
    #[prost(uint64, tag = "2")]
    pub total: u64,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SystemOs {
    #[prost(string, tag = "1")]
    pub name: ::prost::alloc::string::String,
    #[prost(string, tag = "2")]
    pub version: ::prost::alloc::string::String,
    #[prost(string, tag = "3")]
    pub kernel_version: ::prost::alloc::string::String,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct SystemCpu {
    #[prost(float, tag = "1")]
    pub available: f32,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SystemData {
    #[prost(message, optional, tag = "1")]
    pub memory: ::core::option::Option<SystemMemory>,
    #[prost(message, optional, tag = "2")]
    pub os: ::core::option::Option<SystemOs>,
    #[prost(message, optional, tag = "3")]
    pub cpu: ::core::option::Option<SystemCpu>,
}
/// NodeCount represents how many nodes in this cluster
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct NodeCount {
    #[prost(uint32, tag = "1")]
    pub meta: u32,
    #[prost(uint32, tag = "2")]
    pub compute: u32,
    #[prost(uint32, tag = "3")]
    pub frontend: u32,
    #[prost(uint32, tag = "4")]
    pub compactor: u32,
}
/// RwVersion represents the version of RisingWave
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RwVersion {
    /// Version is the Cargo package version of RisingWave
    #[prost(string, tag = "1")]
    pub rw_version: ::prost::alloc::string::String,
    /// GitSHA is the Git commit SHA of RisingWave
    #[prost(string, tag = "2")]
    pub git_sha: ::prost::alloc::string::String,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReportBase {
    /// tracking_id is persistent in meta data
    #[prost(string, tag = "1")]
    pub tracking_id: ::prost::alloc::string::String,
    /// session_id is reset every time node restarts
    #[prost(string, tag = "2")]
    pub session_id: ::prost::alloc::string::String,
    /// system_data is hardware and os info
    #[prost(message, optional, tag = "3")]
    pub system_data: ::core::option::Option<SystemData>,
    /// up_time is how long the node has been running
    #[prost(uint64, tag = "4")]
    pub up_time: u64,
    /// report_time is when the report is created
    #[prost(uint64, tag = "5")]
    pub report_time: u64,
    /// node_type is the node that creates the report
    #[prost(enumeration = "TelemetryNodeType", tag = "6")]
    pub node_type: i32,
    /// mark the report is a test message
    /// if so, the backend do validations but not store it
    #[prost(bool, tag = "7")]
    pub is_test: bool,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MetaReport {
    #[prost(message, optional, tag = "1")]
    pub base: ::core::option::Option<ReportBase>,
    /// meta_backend is the backend of meta data
    #[prost(enumeration = "MetaBackend", tag = "2")]
    pub meta_backend: i32,
    /// node_count is the count of each node type
    #[prost(message, optional, tag = "3")]
    pub node_count: ::core::option::Option<NodeCount>,
    /// rw_version is the version of RisingWave
    #[prost(message, optional, tag = "4")]
    pub rw_version: ::core::option::Option<RwVersion>,
    /// This field represents the "number of running streaming jobs"
    /// and is used to indicate whether the cluster is active.
    #[prost(uint32, tag = "5")]
    pub stream_job_count: u32,
    /// stream_jobs is the list of running streaming jobs
    /// and is used to collect the table_id, connector_name and table_optimizations
    #[prost(message, repeated, tag = "6")]
    pub stream_jobs: ::prost::alloc::vec::Vec<StreamJobDesc>,
    /// How the cluster is deployed
    #[prost(enumeration = "TelemetryClusterType", tag = "7")]
    pub cluster_type: i32,
    /// The object store media type obtained from ObjectStore::store_media_type
    #[prost(string, tag = "8")]
    pub object_store_media_type: ::prost::alloc::string::String,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct StreamJobDesc {
    #[prost(int32, tag = "1")]
    pub table_id: i32,
    #[prost(string, optional, tag = "2")]
    pub connector_name: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(enumeration = "PlanOptimization", repeated, tag = "3")]
    pub plan_optimizations: ::prost::alloc::vec::Vec<i32>,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ComputeReport {
    #[prost(message, optional, tag = "1")]
    pub base: ::core::option::Option<ReportBase>,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FrontendReport {
    #[prost(message, optional, tag = "1")]
    pub base: ::core::option::Option<ReportBase>,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CompactorReport {
    #[prost(message, optional, tag = "1")]
    pub base: ::core::option::Option<ReportBase>,
}
#[derive(prost_helpers::AnyPB)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EventMessage {
    /// tracking_id is persistent in meta data
    #[prost(string, tag = "1")]
    pub tracking_id: ::prost::alloc::string::String,
    /// event_time is when the event is created
    #[prost(uint64, tag = "3")]
    pub event_time_sec: u64,
    /// event_stage describes in which process the event happens
    #[prost(enumeration = "TelemetryEventStage", tag = "4")]
    pub event_stage: i32,
    /// feature_name is the name of the feature triggered the event
    #[prost(string, tag = "5")]
    pub event_name: ::prost::alloc::string::String,
    /// connector_name is the name of the connector involves
    #[prost(string, optional, tag = "6")]
    pub connector_name: ::core::option::Option<::prost::alloc::string::String>,
    /// connector_direction is the direction of data flow, can be source or sink
    #[prost(enumeration = "TelemetryDatabaseObject", optional, tag = "10")]
    pub object: ::core::option::Option<i32>,
    /// catalog_id is the id of the catalog involves (table_id/source_id/...)
    #[prost(int64, tag = "7")]
    pub catalog_id: i64,
    /// attributes is the additional information of the event: json format ser to string
    #[prost(string, optional, tag = "8")]
    pub attributes: ::core::option::Option<::prost::alloc::string::String>,
    /// node is the node that creates the event
    #[prost(string, tag = "9")]
    pub node: ::prost::alloc::string::String,
    /// mark the event is a test message
    #[prost(bool, tag = "11")]
    pub is_test: bool,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum MetaBackend {
    Unspecified = 0,
    Memory = 1,
    Rdb = 3,
}
impl MetaBackend {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            MetaBackend::Unspecified => "META_BACKEND_UNSPECIFIED",
            MetaBackend::Memory => "META_BACKEND_MEMORY",
            MetaBackend::Rdb => "META_BACKEND_RDB",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "META_BACKEND_UNSPECIFIED" => Some(Self::Unspecified),
            "META_BACKEND_MEMORY" => Some(Self::Memory),
            "META_BACKEND_RDB" => Some(Self::Rdb),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum TelemetryNodeType {
    Unspecified = 0,
    Meta = 1,
    Compute = 2,
    Frontend = 3,
    Compactor = 4,
}
impl TelemetryNodeType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            TelemetryNodeType::Unspecified => "TELEMETRY_NODE_TYPE_UNSPECIFIED",
            TelemetryNodeType::Meta => "TELEMETRY_NODE_TYPE_META",
            TelemetryNodeType::Compute => "TELEMETRY_NODE_TYPE_COMPUTE",
            TelemetryNodeType::Frontend => "TELEMETRY_NODE_TYPE_FRONTEND",
            TelemetryNodeType::Compactor => "TELEMETRY_NODE_TYPE_COMPACTOR",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TELEMETRY_NODE_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "TELEMETRY_NODE_TYPE_META" => Some(Self::Meta),
            "TELEMETRY_NODE_TYPE_COMPUTE" => Some(Self::Compute),
            "TELEMETRY_NODE_TYPE_FRONTEND" => Some(Self::Frontend),
            "TELEMETRY_NODE_TYPE_COMPACTOR" => Some(Self::Compactor),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum TelemetryClusterType {
    Unspecified = 0,
    SingleNode = 1,
    DockerCompose = 2,
    Kubernetes = 3,
    CloudHosted = 4,
}
impl TelemetryClusterType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            TelemetryClusterType::Unspecified => "TELEMETRY_CLUSTER_TYPE_UNSPECIFIED",
            TelemetryClusterType::SingleNode => "TELEMETRY_CLUSTER_TYPE_SINGLE_NODE",
            TelemetryClusterType::DockerCompose => {
                "TELEMETRY_CLUSTER_TYPE_DOCKER_COMPOSE"
            }
            TelemetryClusterType::Kubernetes => "TELEMETRY_CLUSTER_TYPE_KUBERNETES",
            TelemetryClusterType::CloudHosted => "TELEMETRY_CLUSTER_TYPE_CLOUD_HOSTED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TELEMETRY_CLUSTER_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "TELEMETRY_CLUSTER_TYPE_SINGLE_NODE" => Some(Self::SingleNode),
            "TELEMETRY_CLUSTER_TYPE_DOCKER_COMPOSE" => Some(Self::DockerCompose),
            "TELEMETRY_CLUSTER_TYPE_KUBERNETES" => Some(Self::Kubernetes),
            "TELEMETRY_CLUSTER_TYPE_CLOUD_HOSTED" => Some(Self::CloudHosted),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum PlanOptimization {
    TableOptimizationUnspecified = 0,
}
impl PlanOptimization {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            PlanOptimization::TableOptimizationUnspecified => {
                "TABLE_OPTIMIZATION_UNSPECIFIED"
            }
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TABLE_OPTIMIZATION_UNSPECIFIED" => Some(Self::TableOptimizationUnspecified),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum TelemetryEventStage {
    Unspecified = 0,
    CreateStreamJob = 1,
    UpdateStreamJob = 2,
    DropStreamJob = 3,
    Query = 4,
    Recovery = 5,
}
impl TelemetryEventStage {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            TelemetryEventStage::Unspecified => "TELEMETRY_EVENT_STAGE_UNSPECIFIED",
            TelemetryEventStage::CreateStreamJob => {
                "TELEMETRY_EVENT_STAGE_CREATE_STREAM_JOB"
            }
            TelemetryEventStage::UpdateStreamJob => {
                "TELEMETRY_EVENT_STAGE_UPDATE_STREAM_JOB"
            }
            TelemetryEventStage::DropStreamJob => "TELEMETRY_EVENT_STAGE_DROP_STREAM_JOB",
            TelemetryEventStage::Query => "TELEMETRY_EVENT_STAGE_QUERY",
            TelemetryEventStage::Recovery => "TELEMETRY_EVENT_STAGE_RECOVERY",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TELEMETRY_EVENT_STAGE_UNSPECIFIED" => Some(Self::Unspecified),
            "TELEMETRY_EVENT_STAGE_CREATE_STREAM_JOB" => Some(Self::CreateStreamJob),
            "TELEMETRY_EVENT_STAGE_UPDATE_STREAM_JOB" => Some(Self::UpdateStreamJob),
            "TELEMETRY_EVENT_STAGE_DROP_STREAM_JOB" => Some(Self::DropStreamJob),
            "TELEMETRY_EVENT_STAGE_QUERY" => Some(Self::Query),
            "TELEMETRY_EVENT_STAGE_RECOVERY" => Some(Self::Recovery),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum TelemetryDatabaseObject {
    Unspecified = 0,
    Source = 1,
    Mv = 2,
    Table = 3,
    Sink = 4,
    Index = 5,
}
impl TelemetryDatabaseObject {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            TelemetryDatabaseObject::Unspecified => {
                "TELEMETRY_DATABASE_OBJECT_UNSPECIFIED"
            }
            TelemetryDatabaseObject::Source => "TELEMETRY_DATABASE_OBJECT_SOURCE",
            TelemetryDatabaseObject::Mv => "TELEMETRY_DATABASE_OBJECT_MV",
            TelemetryDatabaseObject::Table => "TELEMETRY_DATABASE_OBJECT_TABLE",
            TelemetryDatabaseObject::Sink => "TELEMETRY_DATABASE_OBJECT_SINK",
            TelemetryDatabaseObject::Index => "TELEMETRY_DATABASE_OBJECT_INDEX",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TELEMETRY_DATABASE_OBJECT_UNSPECIFIED" => Some(Self::Unspecified),
            "TELEMETRY_DATABASE_OBJECT_SOURCE" => Some(Self::Source),
            "TELEMETRY_DATABASE_OBJECT_MV" => Some(Self::Mv),
            "TELEMETRY_DATABASE_OBJECT_TABLE" => Some(Self::Table),
            "TELEMETRY_DATABASE_OBJECT_SINK" => Some(Self::Sink),
            "TELEMETRY_DATABASE_OBJECT_INDEX" => Some(Self::Index),
            _ => None,
        }
    }
}