package lease

import "k8s.io/component-helpers/lease"

Index ¶

• type Controller
• func NewController(clock clock.Clock, client clientset.Interface, holderIdentity string, leaseDurationSeconds int32, onRepeatedHeartbeatFailure func(), renewInterval time.Duration, leaseNamespace string, newLeasePostProcessFunc ProcessLeaseFunc) Controller
• type ProcessLeaseFunc

Types ¶

type Controller ¶

type Controller interface {
	Run(stopCh <-chan struct{})
}

Controller manages creating and renewing the lease for this component (kube-apiserver, kubelet, etc.)

func NewController ¶

func NewController(clock clock.Clock, client clientset.Interface, holderIdentity string, leaseDurationSeconds int32, onRepeatedHeartbeatFailure func(), renewInterval time.Duration, leaseNamespace string, newLeasePostProcessFunc ProcessLeaseFunc) Controller

NewController constructs and returns a controller

type ProcessLeaseFunc ¶

type ProcessLeaseFunc func(*coordinationv1.Lease) error

ProcessLeaseFunc processes the given lease in-place

Source Files ¶

controller.go