mirror of
https://github.com/lightningnetwork/lnd.git
synced 2024-11-19 01:43:16 +01:00
8e0534f756
This commit extends our healtcheck with an optional leader check. This is to ensure that given network partition or other cluster wide failure we act as soon as possible to avoid a split-brain situation where a new leader is elected but we still hold onto our etcd client.
30 lines
820 B
Go
30 lines
820 B
Go
package cluster
|
|
|
|
import (
|
|
"context"
|
|
)
|
|
|
|
const (
|
|
// EtcdLeaderElector is the id used when constructing an
|
|
// etcdLeaderElector instance through the factory.
|
|
EtcdLeaderElector = "etcd"
|
|
)
|
|
|
|
// LeaderElector is a general interface implementing basic leader elections
|
|
// in a clustered environment.
|
|
type LeaderElector interface {
|
|
// Campaign starts a run for leadership. Campaign will block until
|
|
// the caller is elected as the leader.
|
|
Campaign(ctx context.Context) error
|
|
|
|
// Resign resigns from the leader role, allowing other election members
|
|
// to take on leadership.
|
|
Resign(ctx context.Context) error
|
|
|
|
// Leader returns the leader value for the current election.
|
|
Leader(ctx context.Context) (string, error)
|
|
|
|
// IsLeader returns true if the caller is the leader.
|
|
IsLeader(ctx context.Context) (bool, error)
|
|
}
|