leader

package
v0.14.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 25, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package leader provides functionality for etcd-backed leader elections.

The following diagram illustrates the states of an election:

                      FOLLOWER<---------------+
                         +                    ^
                         |                    |
       Campaign() blocks +-------------------->
                         |     Resign()       |
                         |                    |
                         v                    |
                +--------+                    |
                |        |                    |
                |        | Campaign() OK      |
                |        |                    |
                |        |                    |
Campaign() Err  |        v      Resign()      |
                |      LEADER+--------------->+
                |        +                    ^
                |        | Lose session       |
                |        |                    |
                |        v                    |
                +----->ERROR+-----------------+
                             Campaign() again

An election starts in FOLLOWER state when a call to Campaign() is first made. The underlying call to etcd will block until the client is either (a) elected (in which case the election will be in LEADER state) or (b) an error is encountered (in which case election will be in ERROR state). If an election is in LEADER state but the session expires in the background it will transition to ERROR state (and Campaign() will need to be called again to progress). If an election is in LEADER state and the user calls Resign() it will transition back to FOLLOWER state. Finally, if an election is in FOLLOWER state and a blocking call to Campaign() is ongoing and the user calls Resign(), the campaign will be cancelled and the election back in FOLLOWER state.

Callers of Campaign() MUST consume the returned channel until it is closed or risk goroutine leaks.

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrNoLeader is returned when a call to Leader() is made to an election
	// with no leader. We duplicate this error so the user doesn't have to
	// import etcd's concurrency package in order to check the cause of the
	// error.
	ErrNoLeader = concurrency.ErrElectionNoLeader

	// ErrCampaignInProgress is returned when a call to Campaign() is made while
	// the caller is either already (a) campaigning or (b) the leader.
	ErrCampaignInProgress = errors.New("campaign in progress")
)

Functions

func NewService

func NewService(cli *clientv3.Client, opts Options) (services.LeaderService, error)

NewService creates a new leader service client based on an etcd client.

Types

type Options

type Options interface {
	// Service the election is campaigning for.
	ServiceID() services.ServiceID
	SetServiceID(sid services.ServiceID) Options

	ElectionOpts() services.ElectionOptions
	SetElectionOpts(e services.ElectionOptions) Options

	Validate() error
}

Options describe options for creating a leader service.

func NewOptions

func NewOptions() Options

NewOptions returns an instance of leader options.

Directories

Path Synopsis
Package campaign encapsulates the state of a campaign.
Package campaign encapsulates the state of a campaign.
Package election provides a wrapper around a subset of the Election functionality of etcd's concurrency package with error handling for common failure scenarios such as lease expiration.
Package election provides a wrapper around a subset of the Election functionality of etcd's concurrency package with error handling for common failure scenarios such as lease expiration.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL