Skip to content

Commit

Permalink
fix: rename _heartbeatMessage var
Browse files Browse the repository at this point in the history
  • Loading branch information
nick-bisonai committed Mar 4, 2024
1 parent d7a87a5 commit 31676a2
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions node/pkg/raft/raft.go
Original file line number Diff line number Diff line change
Expand Up @@ -210,22 +210,22 @@ func (r *Raft) PublishMessage(msg Message) error {
}

func (r *Raft) sendHeartbeat() error {
_heartbeatMessage := HeartbeatMessage{
heartbeatMessage := HeartbeatMessage{
LeaderID: r.GetHostId(),
Term: r.GetCurrentTerm(),
}
marshalledHeartbeatMsg, err := json.Marshal(_heartbeatMessage)
marshalledHeartbeatMsg, err := json.Marshal(heartbeatMessage)
if err != nil {
log.Error().Err(err).Msg("failed to marshal heartbeat message")
return err
}

heartbeatMessage := Message{
message := Message{
Type: Heartbeat,
SentFrom: r.GetHostId(),
Data: json.RawMessage(marshalledHeartbeatMsg),
}
err = r.PublishMessage(heartbeatMessage)
err = r.PublishMessage(message)
if err != nil {
log.Error().Err(err).Msg("failed to send heartbeat")
return err
Expand Down

0 comments on commit 31676a2

Please sign in to comment.