leadership

Documentation

Index

• func GetNewLock(client coordinationv1.CoordinationV1Interface, ...) *resourcelock.LeaseLock
• type HealthChecker
  • func NewHealthChecker() HealthChecker
• type LeaderElector
  • func NewLeaderElector(lock *resourcelock.LeaseLock, cfg *config.Config, id string, ...) LeaderElector
• type LeaderFunc

Functions

func GetNewLock

func GetNewLock(client coordinationv1.CoordinationV1Interface, lockName, podname, namespace string) *resourcelock.LeaseLock

Types

type HealthChecker

type HealthChecker interface {
	SetupLivenessEndpoint()
}

func NewHealthChecker

func NewHealthChecker() HealthChecker

type LeaderElector

type LeaderElector interface {
	RunLeaderElection(ctx context.Context, stopChan chan struct{})
}

func NewLeaderElector

func NewLeaderElector(lock *resourcelock.LeaseLock, cfg *config.Config, id string, clientset k8s.KubernetesClient, leaderFunc LeaderFunc) LeaderElector

type LeaderFunc

type LeaderFunc func(ctx context.Context, stopChan chan struct{}, cfg *config.Config, clientset k8s.KubernetesClient)