Enum CheckpointActivity 

pub enum CheckpointActivity {
    Idle,
    Delayed {
        delayed_since: DateTime<Utc>,
        reasons: Vec<TemporarySuspendError>,
    },
    InProgress {
        started_at: DateTime<Utc>,
    },
}

Current checkpoint activity state.

JSON schema

{
 "description": "Current checkpoint activity state.",
 "oneOf": [
   {
     "type": "object",
     "required": [
       "status"
     ],
     "properties": {
       "status": {
         "type": "string",
         "enum": [
           "idle"
         ]
       }
     }
   },
   {
     "description": "A checkpoint has been requested but is delayed for temporary reasons\n(e.g. replaying, bootstrapping, transaction in progress, or input\nendpoint barriers that require the coordinator to run steps).",
     "type": "object",
     "required": [
       "delayed_since",
       "reasons",
       "status"
     ],
     "properties": {
       "delayed_since": {
         "description": "When the delay started (serialized as ISO 8601).",
         "type": "string",
         "format": "date-time"
       },
       "reasons": {
         "description": "Why the checkpoint cannot proceed yet.",
         "type": "array",
         "items": {
           "$ref": "#/components/schemas/TemporarySuspendError"
         }
       },
       "status": {
         "type": "string",
         "enum": [
           "delayed"
         ]
       }
     }
   },
   {
     "description": "A checkpoint is currently being written to storage.",
     "type": "object",
     "required": [
       "started_at",
       "status"
     ],
     "properties": {
       "started_at": {
         "description": "When the checkpoint write started (serialized as ISO 8601).",
         "type": "string",
         "format": "date-time"
       },
       "status": {
         "type": "string",
         "enum": [
           "in_progress"
         ]
       }
     }
   }
 ]
}

Variants

Idle

Delayed

A checkpoint has been requested but is delayed for temporary reasons (e.g. replaying, bootstrapping, transaction in progress, or input endpoint barriers that require the coordinator to run steps).

Fields

delayed_since: DateTime<Utc>

When the delay started (serialized as ISO 8601).

reasons: Vec<TemporarySuspendError>

Why the checkpoint cannot proceed yet.

InProgress

A checkpoint is currently being written to storage.

Fields

started_at: DateTime<Utc>

When the checkpoint write started (serialized as ISO 8601).

Trait Implementations

impl Clone for CheckpointActivity

fn clone(&self) -> CheckpointActivity

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CheckpointActivity

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CheckpointActivity

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&CheckpointActivity> for CheckpointActivity

fn from(value: &CheckpointActivity) -> Self

Converts to this type from the input type.

impl Serialize for CheckpointActivity

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

where __S: Serializer,

Serialize this value into the given Serde serializer.