leaderelection

Documentation

Index

• func New(name string, leaderElectionClient kubernetes.Interface, ...) (*leaderelection.LeaderElector, error)
• func RunAsLeader(ctx context.Context, log *zap.SugaredLogger, cfg *rest.Config, ...) error

Functions

func New

func New(name string, leaderElectionClient kubernetes.Interface, recorder resourcelock.EventRecorder, callbacks leaderelection.LeaderCallbacks) (*leaderelection.LeaderElector, error)

New returns a new leader elector which uses the "hostname + name" as lock identity

func RunAsLeader

func RunAsLeader(ctx context.Context, log *zap.SugaredLogger, cfg *rest.Config, recorder resourcelock.EventRecorder, leaderName string, callback func(context.Context) error) error