Documentation ¶
Index ¶
- type ConsulLeaderElector
- func (le *ConsulLeaderElector) HasLeader() (bool, error)
- func (le *ConsulLeaderElector) IsLeader() bool
- func (le *ConsulLeaderElector) Run() error
- func (le *ConsulLeaderElector) Stop()
- func (le *ConsulLeaderElector) String() string
- func (le *ConsulLeaderElector) WaitForLeader(wait, tick time.Duration) error
- type LeaderElector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsulLeaderElector ¶
type ConsulLeaderElector struct {
// contains filtered or unexported fields
}
func NewConsulLeaderElector ¶
func (*ConsulLeaderElector) HasLeader ¶
func (le *ConsulLeaderElector) HasLeader() (bool, error)
func (*ConsulLeaderElector) IsLeader ¶
func (le *ConsulLeaderElector) IsLeader() bool
func (*ConsulLeaderElector) Run ¶
func (le *ConsulLeaderElector) Run() error
func (*ConsulLeaderElector) Stop ¶
func (le *ConsulLeaderElector) Stop()
func (*ConsulLeaderElector) String ¶
func (le *ConsulLeaderElector) String() string
func (*ConsulLeaderElector) WaitForLeader ¶
func (le *ConsulLeaderElector) WaitForLeader(wait, tick time.Duration) error
WaitForLeader waits for someone to acquire leadership. It returns an error if the timer times out. wait is how long to wait before timing out tick is how often to check
Click to show internal directories.
Click to hide internal directories.