package etcd

import "github.com/google/trillian/util/election2/etcd"

Package etcd provides an implementation of master election based on etcd.

Index ¶

• type Election
• func (e *Election) Await(ctx context.Context) error
• func (e *Election) Close(ctx context.Context) error
• func (e *Election) Resign(ctx context.Context) error
• func (e *Election) WithMastership(ctx context.Context) (context.Context, error)
• type Factory
• func NewFactory(instanceID string, client *clientv3.Client, lockDir string) *Factory
• func (f *Factory) NewElection(ctx context.Context, resourceID string) (election2.Election, error)

Types ¶

type Election ¶

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

Election is an implementation of election2.Election based on etcd.

func (*Election) Await ¶

func (e *Election) Await(ctx context.Context) error

Await blocks until the instance captures mastership.

func (*Election) Close ¶

func (e *Election) Close(ctx context.Context) error

Close resigns and permanently stops participating in election. No other method should be called after Close.

func (*Election) Resign ¶

func (e *Election) Resign(ctx context.Context) error

Resign releases mastership for this instance. The instance can be elected again using Await. Idempotent, might be useful to retry if fails.

func (*Election) WithMastership ¶

func (e *Election) WithMastership(ctx context.Context) (context.Context, error)

WithMastership returns a "mastership context" which remains active until the instance stops being the master, or the passed in context is canceled.

type Factory ¶

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

Factory creates Election instances.

func NewFactory ¶

func NewFactory(instanceID string, client *clientv3.Client, lockDir string) *Factory

NewFactory builds an election factory that uses the given parameters. The passed in etcd client should remain valid for the lifetime of the object.

func (*Factory) NewElection ¶

func (f *Factory) NewElection(ctx context.Context, resourceID string) (election2.Election, error)

NewElection creates a specific Election instance.

Source Files ¶

election.go