leader

README

leader

Documentation

Index

• Variables
• func Acquire()
• func Lead() bool
• func ProcessID() string
• func Run(f func()) bool
• type Operation

Variables

var (
	HeartBeat               = 15 * time.Second
	Timeout                 = 25 * time.Second
	Op            Operation = noop{}
	OnLeadChanged           = func(lead bool) {}
)

Configs

Functions

func Acquire

func Acquire()

Acquire starts acquire loop (must run in go routine)

func Lead

func Lead() bool

Lead returns true if current process is the leader

func ProcessID

func ProcessID() string

ProcessID returns process id

func Run

func Run(f func()) bool

Run runs f if current process is the leader

Types

type Operation

type Operation interface {
	Begin() error
	Commit() error
	Rollback() error

	Current() (processID string, lastHeartBeat, now time.Time, err error)
	TryAcquire(processID string) error
}

Operation type