cluster

Documentation

Index

• Constants
• func DisableLog()
• func RegisterLeaderElectorFactory(id string, factory leaderElectorFactoryFunc)
• func UseLogger(logger bronlog.Logger)
• type LeaderElector
  • func MakeLeaderElector(ctx context.Context, id string, args ...interface{}) (LeaderElector, error)

Constants

const (
	// EtcdLeaderElector is the id used when constructing an
	// etcdLeaderElector instance through the factory.
	EtcdLeaderElector = "etcd"
)

const Subsystem = "CLUS"

Subsystem defines the logging code for this subsystem.

Functions

func DisableLog

func DisableLog()

DisableLog disables all logging output.

func RegisterLeaderElectorFactory

func RegisterLeaderElectorFactory(id string, factory leaderElectorFactoryFunc)

RegisterLeaderElectorFactory will register a new LeaderElector factory method corresponding to the passed id.

func UseLogger

func UseLogger(logger bronlog.Logger)

UseLogger uses a specified Logger to output package logging info.

Types

type LeaderElector

type LeaderElector interface {
	// Campaign starts a run for leadership. Campaign will block until
	// the caller is elected as the leader.
	Campaign(ctx context.Context) error

	// Resign resigns from the leader role, allowing other election members
	// to take on leadership.
	Resign() error

	// Leader returns the leader value for the current election.
	Leader(ctx context.Context) (string, error)
}

LeaderElector is a general interface implementing basic leader elections in a clustered environment.

func MakeLeaderElector

func MakeLeaderElector(ctx context.Context, id string, args ...interface{}) (
	LeaderElector, error)

MakeLeaderElector will constuct a LeaderElector identified by id with the passed arguments.