Struct ExternalGlobalControllerMetrics 

pub struct ExternalGlobalControllerMetrics {

    pub state: PipelineState,
    pub bootstrap_in_progress: bool,
    pub transaction_status: TransactionStatus,
    pub transaction_id: TransactionId,
    pub transaction_initiators: ExternalTransactionInitiators,
    pub rss_bytes: u64,
    pub cpu_msecs: u64,
    pub uptime_msecs: u64,
    pub start_time: DateTime<Utc>,
    pub incarnation_uuid: Uuid,
    pub initial_start_time: DateTime<Utc>,
    pub storage_bytes: u64,
    pub storage_mb_secs: u64,
    pub runtime_elapsed_msecs: u64,
    pub buffered_input_records: u64,
    pub buffered_input_bytes: u64,
    pub total_input_records: u64,
    pub total_input_bytes: u64,
    pub total_processed_records: u64,
    pub total_processed_bytes: u64,
    pub total_completed_records: u64,
    pub pipeline_complete: bool,
}

Global controller metrics.

Fields

state: PipelineState

State of the pipeline: running, paused, or terminating.

bootstrap_in_progress: bool

The pipeline has been resumed from a checkpoint and is currently bootstrapping new and modified views.

transaction_status: TransactionStatus

Status of the current transaction.

transaction_id: TransactionId

ID of the current transaction or 0 if no transaction is in progress.

transaction_initiators: ExternalTransactionInitiators

Entities that initiated the current transaction.

rss_bytes: u64

Resident set size of the pipeline process, in bytes.

cpu_msecs: u64

CPU time used by the pipeline across all threads, in milliseconds.

uptime_msecs: u64

Time since the pipeline process started, in milliseconds.

start_time: DateTime<Utc>

Time at which the pipeline process started, in seconds since the epoch.

incarnation_uuid: Uuid

Uniquely identifies the pipeline process that started at start_time.

initial_start_time: DateTime<Utc>

Time at which the pipeline process from which we resumed started, in seconds since the epoch.

storage_bytes: u64

Current storage usage in bytes.

storage_mb_secs: u64

Storage usage integrated over time, in megabytes * seconds.

runtime_elapsed_msecs: u64

Time elapsed while the pipeline is executing a step, multiplied by the number of threads, in milliseconds.

buffered_input_records: u64

Total number of records currently buffered by all endpoints.

buffered_input_bytes: u64

Total number of bytes currently buffered by all endpoints.

total_input_records: u64

Total number of records received from all endpoints.

total_input_bytes: u64

Total number of bytes received from all endpoints.

total_processed_records: u64

Total number of input records processed by the DBSP engine.

total_processed_bytes: u64

Total bytes of input records processed by the DBSP engine.

total_completed_records: u64

Total number of input records processed to completion.

pipeline_complete: bool

True if the pipeline has processed all input data to completion.

Trait Implementations

impl Default for ExternalGlobalControllerMetrics

fn default() -> ExternalGlobalControllerMetrics

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExternalGlobalControllerMetrics

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExternalGlobalControllerMetrics

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<'__s> ToSchema<'__s> for ExternalGlobalControllerMetrics

fn schema() -> (&'__s str, RefOr<Schema>)

Return a tuple of name and schema or reference to a schema that can be referenced by the name or inlined directly to responses, request bodies or parameters.

fn aliases() -> Vec<(&'__s str, Schema)>

Optional set of alias schemas for the ToSchema::schema.