Skip to content

diamanticom/etcd-lock

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

20 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

etcd-lock

master.go

  • Master election using etcd.
  • TTL is refreshed by the lockholder.
  • Master failure results in another node acquiring the lock and becoming master.
  • Sample usage below.

rwlock.go

  • Distributed read write lock implementation using etcd.
  • Implemented using CreateInOrder (queue).
  • Fairness ensured by not letting reads leapfrog writes.
  • Queue TTL protects against node failures after requesting a lock.
  • Lock TTL protects against node failures after acquiring a lock.

Sample usage

import ".../utils"

func someFunc() {
  // Create an etcd client and a lock.
  lock, err := utils.NewMaster(utils.NewEtcdRegistry(), "foo", "172.16.1.101", 30)

  // Start a go routine to process events.
  go processEvents(lock.EventsChan())

  // Start the attempt to acquire the lock.
  lock.Start()
}

func processEvents(eventsCh <-chan utils.MasterEvent) {
     for {
        select {
        case e := <-k.eventsCh:
            if e.Type == utils.MasterAdded {
               // Acquired the lock.
            } else if e.Type == utils.MasterDeleted {
               // Lost the lock.
            } else {
               // Lock ownership changed.
            }
        ...
        }
     }
}

About

Distributed lock implementation using etcd

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages