go - 了解 etcd Leader 选举 API

Question

我试图理解 etcd election api 提供的各种功能以及它们在语义上的含义。

在他们的官方文档中非常简单地提到了每个功能的作用，并且没有提供示例。例如我们有方法:

func (e *Election) Campaign(ctx context.Context, val string) error

根据我的理解，campaign 用于在选举中登记节点以获得领导地位，它会被阻止，直到实现或出现某些错误。

func ResumeElection(s *Session, pfx string, leaderKey string, leaderRev int64) *Election

这个我不太确定为什么要恢复选举，假设node已经是leader了。也许我缺乏理解是由于这里使用的语义。

既然我们必须使用一个共同的选举标识符，为什么单次选举还不够呢？

最后我的用例是运行多个节点并且只允许领导者进行一些计算/更新，在什么情况下如果单次选举不够我必须创建新的选举。

Answer 1

1. 在代码库中，ResumeElection API 仅在electionServer) Resign 和electionServer) Proclaim 中调用。

2. 有一些评论

// Resign lets a leader start a new election.
func (e *Election) Resign(ctx context.Context) (err error) {

// Proclaim lets the leader announce a new value without another election.
func (e *Election) Proclaim(ctx context.Context, val string) error {

1. ResumeElection 的实现只是返回一个结构。

// ResumeElection initializes an election with a known leader.
func ResumeElection(s *Session, pfx string, leaderKey string, leaderRev int64) *Election {
    return &Election{
        keyPrefix:     pfx,
        session:       s,
        leaderKey:     leaderKey,
        leaderRev:     leaderRev,
        leaderSession: s,
    }
}

因此，您的问题的答案是:ResumeElection 的对面是 NewElection，而不是 Campaign。

更多的是，当客户端已经有一个领导者，并且想要改变集群的状态(设置一个变量或放弃领导者)。它将调用 ResumeElection 而不是 Campaign。