diff --git a/observer.go b/observer.go index 630c50c9d..6a03d565b 100644 --- a/observer.go +++ b/observer.go @@ -19,6 +19,8 @@ type Observation struct { // LeaderObservation is used for the data when leadership changes. type LeaderObservation struct { + // DEPRECATED The LeaderAddr field should now be used + Leader ServerAddress LeaderAddr ServerAddress LeaderID ServerID } diff --git a/raft.go b/raft.go index 1c7aecd89..4b85ac1ef 100644 --- a/raft.go +++ b/raft.go @@ -101,7 +101,7 @@ func (r *Raft) setLeader(leaderAddr ServerAddress, leaderID ServerID) { r.leaderID = leaderID r.leaderLock.Unlock() if oldLeaderAddr != leaderAddr || oldLeaderID != leaderID { - r.observe(LeaderObservation{LeaderAddr: leaderAddr, LeaderID: leaderID}) + r.observe(LeaderObservation{Leader: leaderAddr, LeaderAddr: leaderAddr, LeaderID: leaderID}) } }