const maxUpdateRetries … const maxBackoff … type Controller … type ProcessLeaseFunc … type controller … // NewController constructs and returns a controller func NewController(clock clock.Clock, client clientset.Interface, holderIdentity string, leaseDurationSeconds int32, onRepeatedHeartbeatFailure func(), renewInterval time.Duration, leaseName, leaseNamespace string, newLeasePostProcessFunc ProcessLeaseFunc) Controller { … } // Run runs the controller func (c *controller) Run(ctx context.Context) { … } func (c *controller) sync(ctx context.Context) { … } // backoffEnsureLease attempts to create the lease if it does not exist, // and uses exponentially increasing waits to prevent overloading the API server // with retries. Returns the lease, and true if this call created the lease, // false otherwise. func (c *controller) backoffEnsureLease(ctx context.Context) (*coordinationv1.Lease, bool) { … } // ensureLease creates the lease if it does not exist. Returns the lease and // a bool (true if this call created the lease), or any error that occurs. func (c *controller) ensureLease(ctx context.Context) (*coordinationv1.Lease, bool, error) { … } // retryUpdateLease attempts to update the lease for maxUpdateRetries, // call this once you're sure the lease has been created func (c *controller) retryUpdateLease(ctx context.Context, base *coordinationv1.Lease) error { … } // newLease constructs a new lease if base is nil, or returns a copy of base // with desired state asserted on the copy. // Note that an error will block lease CREATE, causing the CREATE to be retried in // the next iteration; but the error won't block lease refresh (UPDATE). func (c *controller) newLease(base *coordinationv1.Lease) (*coordinationv1.Lease, error) { … } func minDuration(a, b time.Duration) time.Duration { … }
Codebase Browser
kubernetes