leaderelection

Documentation

Index

• Variables
• func RunWithLeaderElection(ctx context.Context, config *rest.Config, newRunnerFn NewRunner)
• type Controller
  • func NewController(leaseInformer coordinationv1informers.LeaseInformer, ...) (*Controller, error)
  • func (c *Controller) Run(ctx context.Context, workers int)
• type LeaseCandidateGCController
  • func NewLeaseCandidateGC(clientset kubernetes.Interface, gcCheckPeriod time.Duration, ...) *LeaseCandidateGCController
  • func (c *LeaseCandidateGCController) Run(ctx context.Context)
• type NewRunner

Variables

var (
	// TODO: Eventually these should be configurable
	LeaseDuration = 15 * time.Second
	RenewDeadline = 10 * time.Second
	RetryPeriod   = 2 * time.Second
)

Functions

func RunWithLeaderElection

func RunWithLeaderElection(ctx context.Context, config *rest.Config, newRunnerFn NewRunner)

RunWithLeaderElection runs the provided runner function with leader election. newRunnerFn might be called multiple times, and it should return another controller instance's Run method each time. RunWithLeaderElection only returns when the context is done, or initial leader election fails.

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller is the leader election controller, which observes component identity leases for components that have self-nominated as candidate leaders for leases and elects leaders for those leases, favoring candidates with higher versions.

func NewController

func NewController(leaseInformer coordinationv1informers.LeaseInformer, leaseCandidateInformer coordinationv1alpha2.LeaseCandidateInformer, leaseClient coordinationv1client.CoordinationV1Interface, leaseCandidateClient coordinationv1alpha2client.CoordinationV1alpha2Interface) (*Controller, error)

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, workers int)

type LeaseCandidateGCController

type LeaseCandidateGCController struct {
	// contains filtered or unexported fields
}

func NewLeaseCandidateGC

func NewLeaseCandidateGC(clientset kubernetes.Interface, gcCheckPeriod time.Duration, leaseCandidateInformer coordinationv1alpha2informers.LeaseCandidateInformer) *LeaseCandidateGCController

NewLeaseCandidateGC creates a new LeaseCandidateGCController.

func (*LeaseCandidateGCController) Run

func (c *LeaseCandidateGCController) Run(ctx context.Context)

Run starts one worker.

type NewRunner

type NewRunner func() (func(ctx context.Context, workers int), error)