consul-leader-election's Introduction

Consul leader election

This package provides leader election through consul

https://www.consul.io/docs/guides/leader-election.html

Fork 改动

创建 session 的 checkID 由之前的 Checks 改为 NodeChecks

旧的

&api.SessionEntry{
	Checks: e.Checks,
	TTL: (3*e.CheckTimeout).String(),
}

新的：

&api.SessionEntry{
	NodeChecks: e.Checks,
	TTL:        (3 * e.CheckTimeout).String(),
}

How to use

package main

   import(
       "github.com/hashicorp/consul/api"
       "github.com/dmitriyGarden/consul-leader-election"
   )
   func main(){
       conf := api.DefaultConfig()
   	consul, _ := api.NewClient(conf)
   	type notify struct {
   	    T  string
   	}

       func (n *notify)EventLeader(f bool)  {
           if f {
                fmt.Println(n.T, "I'm the leader!")
           } else {
               fmt.Println(n.T, "I'm no longer the leader!")
           }
       }

       n := &notify{
       	T: "My service",
       }

   	elconf := &ElectionConfig{
                 	CheckTimeout: 5 * time.Second,
                 	Client: consul,
                 	Checks: []string{"healthID"},
                 	Key: "service/test-election/leader",
                 	LogLevel: election.LogDebug
                 	Event: n,
                }
   	e := election.NewElection(elconf)
   	// start election
   	go  e.Init()
   	if e.IsLeader() {
           fmt.Println("I'm a leader!")
       }
   	// to do something ....
   	if e.IsLeader() {
   		fmt.Println("I'm a leader!")
   	}
   	// re-election
   	e.ReElection()
   	// to do something ....
   	if e.IsLeader() {
   		fmt.Println("I'm a leader!")
   	}
   	e.Stop()
   }

Recommend Projects