etcd

Documentation

Index

• Constants
• func AmILeader(ctx context.Context, client *etcd.Client) (isLeader bool, err error)
• func NewDetector(pollInterval time.Duration, client *etcd.Client) *leader.Poller
• func NewStore(c *etcd.Client) leader.Store
• type Store
  • func (s Store) GetLocation() (*url.URL, error)
  • func (s Store) UpdateLocation(location *url.URL) error

Constants

const (

	// DefaultKey is the key used to persist the location
	DefaultKey = "infrakit/leader/location"
)

Functions

func AmILeader

func AmILeader(ctx context.Context, client *etcd.Client) (isLeader bool, err error)

AmILeader checks if this node is a leader

func NewDetector

func NewDetector(pollInterval time.Duration, client *etcd.Client) *leader.Poller

NewDetector return an implementation of leader detector

func NewStore

func NewStore(c *etcd.Client) leader.Store

NewStore returns a store for registration of leader location

Types

type Store

type Store struct {
	// contains filtered or unexported fields
}

Store uses ectd as the backend for registration of leader location

func (Store) GetLocation

func (s Store) GetLocation() (*url.URL, error)

GetLocation returns the location of the leader

func (Store) UpdateLocation

func (s Store) UpdateLocation(location *url.URL) error

UpdateLocation writes the location to etcd.