1
2
3
4
5
6
7
8
9

// 把一个节点选举为主节点且会设置一个值
// 这是一个阻塞方法，在调用它的时候会被阻塞，直到满足下面的三个条件之一，才会取消阻塞。成功当选为主；此方法返回错误；ctx 被取消
func (e *Election) Campaign(ctx context.Context,val string)error

// 重新设置 Leader 的值，但是不会重新选主，这个方法会返回新值设置成功或者失败的信息
func (e *Election) Proclaim(ctx context.Context, val string) error

// 开始新一次选举。这个方法会返回新的选举成功或者失败的信息
func (e *Election) Resign(ctx context.Context) (err error)

1
2
3
4
5
6

// 查询当前 Leader 的方法 Leader，如果当前还没有 Leader，就返回一个错误
// 可以使用这个方法来查询主节点信息。
func (e *Election) Leader(ctx context.Context) (*v3.GetResponse, error)

// 每次主节点的变动都会生成一个新的版本号，你还可以查询版本号信息（Rev 方法），了解主节点变动情况
func (e *Election) Rev() int64

1
2
3
4

// 监控主节点的变化
// 它会返回一个 chan，显示主节点的变动信息
// 需要注意的是它不会返回主节点的全部历史变动信息，而是只返回最近的一条变动信息以及之后的变动信息
func (e *Election) Observe(ctx context.Context) <-chan v3.GetResponse

1

func NewLocker(s *Session,pfx string) sync.Locker