leader

Documentation

Index

• func NewClient() (*kubernetes.Clientset, error)
• type Candidate
  • func NewAlwaysLeaderCandidate() Candidate
  • func NewKubernetesCandidate(client kubernetes.Interface, namespace, name, id string, ctrl Controller, ...) (Candidate, error)
• type Controller
• type LoggingController
  • func (c LoggingController) OnNewLeader(self bool, identity string)
  • func (c LoggingController) OnStartedLeading(ctx context.Context)
  • func (c LoggingController) OnStoppedLeading()

Functions

func NewClient

func NewClient() (*kubernetes.Clientset, error)

Types

type Candidate

type Candidate interface {
	Start(ctx context.Context) error
	IsLeader() bool
}

func NewAlwaysLeaderCandidate

func NewAlwaysLeaderCandidate() Candidate

func NewKubernetesCandidate

func NewKubernetesCandidate(client kubernetes.Interface, namespace, name, id string, ctrl Controller, logger log.Logger) (Candidate, error)

type Controller

type Controller interface {
	OnNewLeader(self bool, identity string)
	OnStartedLeading(ctx context.Context)
	OnStoppedLeading()
}

type LoggingController

type LoggingController struct {
	log.Logger
}

func (LoggingController) OnNewLeader

func (c LoggingController) OnNewLeader(self bool, identity string)

func (LoggingController) OnStartedLeading

func (c LoggingController) OnStartedLeading(ctx context.Context)

func (LoggingController) OnStoppedLeading

func (c LoggingController) OnStoppedLeading()