leadership

Documentation

Index

• func GetNewLock(client coordinationv1.CoordinationV1Interface, ...) *resourcelock.LeaseLock
• func Healthz() error
• func RunLeaderElection(lock *resourcelock.LeaseLock, ctx context.Context, cancel context.CancelFunc, ...)

Functions

func GetNewLock

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

func Healthz

func Healthz() error

Healthz serves the liveness probe endpoint. If leadership election is enabled and a replica stops leading the liveness probe will fail and the kubelet will restart the container.

func RunLeaderElection

func RunLeaderElection(lock *resourcelock.LeaseLock, ctx context.Context, cancel context.CancelFunc, id string, controllers []*controller.Controller)

runLeaderElection runs leadership election. If an instance of the controller is the leader and stops leading it will shutdown.