leadership

Documentation

Index

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

Functions

func GetNewLock

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

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.

func SetupLivenessEndpoint

func SetupLivenessEndpoint()

Healthz sets up 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.