leaderelection

Documentation

Index

• func GenIdentity() (string, error)
• func NewResourceLock(rc *rest.Config, options Options) (resourcelock.Interface, error)
• func Start(ctx context.Context, rc *rest.Config, options Options) error
• type Options

Functions

func GenIdentity

func GenIdentity() (string, error)

func NewResourceLock

func NewResourceLock(rc *rest.Config, options Options) (resourcelock.Interface, error)

func Start

func Start(ctx context.Context, rc *rest.Config, options Options) error

Start leader election loop

Types

type Options

type Options struct {
	Identity                   string
	LeaderElectionResourceLock string
	LeaderElectionNamespace    string
	LeaderElectionID           string

	LeaseDuration time.Duration
	RenewDeadline time.Duration
	RetryPeriod   time.Duration

	EventRecorder resourcelock.EventRecorder

	OnNewLeaderFun   func(identity string)
	OnStartedLeading func(ctx context.Context)
	OnStoppedLeading func()
}