Struct GlobalControllerMetrics

Source

pub struct GlobalControllerMetrics {Show 22 fields
    pub bootstrap_in_progress: bool,
    pub buffered_input_bytes: i64,
    pub buffered_input_records: i64,
    pub cpu_msecs: i64,
    pub incarnation_uuid: Uuid,
    pub initial_start_time: i64,
    pub pipeline_complete: bool,
    pub rss_bytes: i64,
    pub runtime_elapsed_msecs: i64,
    pub start_time: i64,
    pub state: PipelineState,
    pub storage_bytes: i64,
    pub storage_mb_secs: i64,
    pub total_completed_records: i64,
    pub total_input_bytes: i64,
    pub total_input_records: i64,
    pub total_processed_bytes: i64,
    pub total_processed_records: i64,
    pub transaction_id: i64,
    pub transaction_initiators: TransactionInitiators,
    pub transaction_status: TransactionStatus,
    pub uptime_msecs: i64,
}

Expand description

Global controller metrics.

JSON schema

{
 "description": "Global controller metrics.",
 "type": "object",
 "required": [
   "bootstrap_in_progress",
   "buffered_input_bytes",
   "buffered_input_records",
   "cpu_msecs",
   "incarnation_uuid",
   "initial_start_time",
   "pipeline_complete",
   "rss_bytes",
   "runtime_elapsed_msecs",
   "start_time",
   "state",
   "storage_bytes",
   "storage_mb_secs",
   "total_completed_records",
   "total_input_bytes",
   "total_input_records",
   "total_processed_bytes",
   "total_processed_records",
   "transaction_id",
   "transaction_initiators",
   "transaction_status",
   "uptime_msecs"
 ],
 "properties": {
   "bootstrap_in_progress": {
     "description": "The pipeline has been resumed from a checkpoint and is currently bootstrapping new and modified views.",
     "type": "boolean"
   },
   "buffered_input_bytes": {
     "description": "Total number of bytes currently buffered by all endpoints.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "buffered_input_records": {
     "description": "Total number of records currently buffered by all endpoints.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "cpu_msecs": {
     "description": "CPU time used by the pipeline across all threads, in milliseconds.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "incarnation_uuid": {
     "description": "Uniquely identifies the pipeline process that started at start_time.",
     "type": "string",
     "format": "uuid"
   },
   "initial_start_time": {
     "description": "Time at which the pipeline process from which we resumed started, in seconds since the epoch.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "pipeline_complete": {
     "description": "True if the pipeline has processed all input data to completion.",
     "type": "boolean"
   },
   "rss_bytes": {
     "description": "Resident set size of the pipeline process, in bytes.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "runtime_elapsed_msecs": {
     "description": "Time elapsed while the pipeline is executing a step, multiplied by the number of threads, in milliseconds.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "start_time": {
     "description": "Time at which the pipeline process started, in seconds since the epoch.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "state": {
     "$ref": "#/components/schemas/PipelineState"
   },
   "storage_bytes": {
     "description": "Current storage usage in bytes.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "storage_mb_secs": {
     "description": "Storage usage integrated over time, in megabytes * seconds.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "total_completed_records": {
     "description": "Total number of input records processed to completion.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "total_input_bytes": {
     "description": "Total number of bytes received from all endpoints.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "total_input_records": {
     "description": "Total number of records received from all endpoints.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "total_processed_bytes": {
     "description": "Total bytes of input records processed by the DBSP engine.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "total_processed_records": {
     "description": "Total number of input records processed by the DBSP engine.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   },
   "transaction_id": {
     "description": "ID of the current transaction or 0 if no transaction is in progress.",
     "type": "integer",
     "format": "int64"
   },
   "transaction_initiators": {
     "$ref": "#/components/schemas/TransactionInitiators"
   },
   "transaction_status": {
     "$ref": "#/components/schemas/TransactionStatus"
   },
   "uptime_msecs": {
     "description": "Time since the pipeline process started, in milliseconds.",
     "type": "integer",
     "format": "int64",
     "minimum": 0.0
   }
 }
}