Struct DiagnoseCommand

pub struct DiagnoseCommand {
    metadata_manager: MetadataManager,
    hummock_manger: HummockManagerRef,
    event_log_manager: EventLogManagerRef,
    prometheus_client: Option<Client>,
    prometheus_selector: String,
}

Fields

metadata_manager: MetadataManager

hummock_manger: HummockManagerRef

event_log_manager: EventLogManagerRef

prometheus_client: Option<Client>

prometheus_selector: String

Implementations

impl DiagnoseCommand

pub fn new( metadata_manager: MetadataManager, hummock_manger: HummockManagerRef, event_log_manager: EventLogManagerRef, prometheus_client: Option<Client>, prometheus_selector: String, ) -> Self

pub async fn report(&self) -> String

async fn write_catalog(&self, s: &mut String)

async fn write_catalog_inner(&self, s: &mut String)

async fn write_worker_nodes(&self, s: &mut String)

fn write_event_logs(&self, s: &mut String)

fn write_event_logs_impl<'a, F>( s: &mut String, event_logs: impl Iterator<Item = &'a EventLog>, get_event_info: F, limit: Option<usize>, )

where F: Fn(&Event) -> Option<String>,

async fn write_storage(&self, s: &mut String)

async fn write_streaming_prometheus(&self, s: &mut String)

async fn write_storage_prometheus(&self, s: &mut String)

async fn write_instant_vector_impl<'a>( &self, s: &mut String, query: &str, labels: Vec<&str>, )

async fn write_await_tree(&self, s: &mut String)

async fn write_table_definition(&self, s: &mut String) -> MetaResult<()>