diff --git a/block-streamer/proto/block_streamer.proto b/block-streamer/proto/block_streamer.proto index 1415263a..fd24b797 100644 --- a/block-streamer/proto/block_streamer.proto +++ b/block-streamer/proto/block_streamer.proto @@ -126,8 +126,8 @@ enum ProcessingState { IDLE = 1; // Running as expected RUNNING = 2; - // Intentionally paused due to some internal condition - PAUSED = 3; + // Waiting for some internal condition to be met before continuing + WAITING = 3; // Stopped due to some unknown error STALLED = 4; } diff --git a/block-streamer/src/block_stream.rs b/block-streamer/src/block_stream.rs index 5362aab7..dab1c787 100644 --- a/block-streamer/src/block_stream.rs +++ b/block-streamer/src/block_stream.rs @@ -71,7 +71,7 @@ pub enum ProcessingState { /// Block Stream has been intentionally/internally paused due to some condition, i.e. back pressure on /// the Redis Stream. - Paused, + Waiting, /// Block Stream has stalled due to an error or other condition. Must be manually /// restarted. @@ -180,7 +180,7 @@ impl BlockStream { health_lock.processing_state = ProcessingState::Stalled; } Ordering::Equal if stream_size >= Some(MAX_STREAM_SIZE) => { - health_lock.processing_state = ProcessingState::Paused; + health_lock.processing_state = ProcessingState::Waiting; } Ordering::Equal => { health_lock.processing_state = ProcessingState::Stalled; diff --git a/block-streamer/src/server/block_streamer_service.rs b/block-streamer/src/server/block_streamer_service.rs index 06e2729d..4dd3f01a 100644 --- a/block-streamer/src/server/block_streamer_service.rs +++ b/block-streamer/src/server/block_streamer_service.rs @@ -33,8 +33,8 @@ impl From for blockstreamer::Health { block_stream::ProcessingState::Stalled => { blockstreamer::ProcessingState::Stalled as i32 } - block_stream::ProcessingState::Paused => { - blockstreamer::ProcessingState::Paused as i32 + block_stream::ProcessingState::Waiting => { + blockstreamer::ProcessingState::Waiting as i32 } }, updated_at_timestamp_secs: health