election

Documentation

Index

• Constants
• func GetLeader() string
• func IsMaster() (bool, string, error)
• func Start(ctx context.Context, cfg *Config, leaderCallback chan struct{})
• type Config
• type LeaderData
  • func (l *LeaderData) GetLeader() string
  • func (l *LeaderData) SetLeader(name string)

Constants

const PodIp = "POD_IP"

Functions

func GetLeader

func GetLeader() string

func IsMaster

func IsMaster() (bool, string, error)

func Start

func Start(ctx context.Context, cfg *Config, leaderCallback chan struct{})

Types

type Config

type Config struct {
	Id                string
	Kubeconfig        string
	ElectionName      string
	ElectionNamespace string
}

type LeaderData

type LeaderData struct {
	sync.RWMutex
	Name string
	// contains filtered or unexported fields
}

func (*LeaderData) GetLeader

func (l *LeaderData) GetLeader() string

func (*LeaderData) SetLeader

func (l *LeaderData) SetLeader(name string)