leaderelection

Documentation

Index

• type Elector
  • func NewK8sLeaderElector(k8sclient kubernetes.Interface, namespace string, leaseName string, ...) Elector
• type LeaderCallbacks
• type Option
  • func WithLeaseDuration(f time.Duration) Option
  • func WithRenewDeadline(f time.Duration) Option
  • func WithRetryPeriod(f time.Duration) Option

Types

type Elector

type Elector interface {
	RunOrDie(context.Context, LeaderCallbacks)
}

func NewK8sLeaderElector

func NewK8sLeaderElector(k8sclient kubernetes.Interface, namespace string, leaseName string, identifier string, opts ...Option) Elector

type LeaderCallbacks

type LeaderCallbacks struct {
	OnStartedLeading func(context.Context)
	OnStoppedLeading func()
}

type Option

type Option func(*k8selector)

func WithLeaseDuration

func WithLeaseDuration(f time.Duration) Option

WithLeaseDuration sets lease duration.

func WithRenewDeadline

func WithRenewDeadline(f time.Duration) Option

WithRenewDeadline sets renew deadline.

func WithRetryPeriod

func WithRetryPeriod(f time.Duration) Option

WithRetryPeriod sets retry period.