Skip to content

Commit

Permalink
rename grpc variant Heartbeat
Browse files Browse the repository at this point in the history
  • Loading branch information
musitdev committed Feb 27, 2025
1 parent 26a8bce commit 5797173
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ impl StreamBlocks {
tracing::info!("Receive PassedThroughBlob blob");
(blob.data, blob.timestamp, blob.blob_id, blob.height)
}
blob_response::BlobType::HeartbeatBlob(_) => {
blob_response::BlobType::Heartbeat(_) => {
tracing::info!("Receive heartbeat blob");
continue;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -116,8 +116,8 @@ where
blob_response::BlobType::PassedThroughBlob(blob) => {
(blob.data, blob.timestamp, blob.blob_id, blob.height)
}
blob_response::BlobType::HeartbeatBlob(_) => {
tracing::info!("Receive heartbeat blob");
blob_response::BlobType::Heartbeat(_) => {
tracing::info!("Receive DA heartbeat");
// Do nothing.
return Ok(());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ message BlobResponse {
Blob passed_through_blob = 1;
Blob sequenced_blob_intent = 2;
Blob sequenced_blob_block = 3;
bool heartbeat_blob = 4;
bool heartbeat = 4;
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,7 @@ where
// Yield the periodic tick
_ = tick_interval.tick() => {
//Heart beat. The value can be use to indicate some status.
BlobResponse { blob_type: Some(movement_da_light_node_proto::blob_response::BlobType::HeartbeatBlob(true)) }
BlobResponse { blob_type: Some(movement_da_light_node_proto::blob_response::BlobType::Heartbeat(true)) }
}
};
let response = StreamReadFromHeightResponse {
Expand Down

0 comments on commit 5797173

Please sign in to comment.