const controllerName … const defaultRequeueInterval … const noRequeue … const defaultLeaseDurationSeconds … const electionDuration … const leaseCandidateValidDuration … type Controller … func (c *Controller) Run(ctx context.Context, workers int) { … } func NewController(leaseInformer coordinationv1informers.LeaseInformer, leaseCandidateInformer coordinationv1alpha1.LeaseCandidateInformer, leaseClient coordinationv1client.CoordinationV1Interface, leaseCandidateClient coordinationv1alpha1client.CoordinationV1alpha1Interface) (*Controller, error) { … } func (c *Controller) runElectionWorker(ctx context.Context) { … } func (c *Controller) processNextElectionItem(ctx context.Context) bool { … } func (c *Controller) enqueueCandidate(obj any) { … } func (c *Controller) enqueueLease(obj any) { … } func (c *Controller) electionNeeded(candidates []*v1alpha1.LeaseCandidate, leaseNN types.NamespacedName) (bool, error) { … } // reconcileElectionStep steps through a step in an election. // A step looks at the current state of Lease and LeaseCandidates and takes one of the following action // - do nothing (because leader is already optimal or still waiting for an event) // - request ack from candidates (update LeaseCandidate PingTime) // - finds the most optimal candidate and elect (update the Lease object) // Instead of keeping a map and lock on election, the state is // calculated every time by looking at the lease, and set of available candidates. // PingTime + electionDuration > time.Now: We just asked all candidates to ack and are still waiting for response // PingTime + electionDuration < time.Now: Candidate has not responded within the appropriate PingTime. Continue the election. // RenewTime + 5 seconds > time.Now: All candidates acked in the last 5 seconds, continue the election. func (c *Controller) reconcileElectionStep(ctx context.Context, leaseNN types.NamespacedName) (requeue time.Duration, err error) { … } func (c *Controller) listAdmissableCandidates(leaseNN types.NamespacedName) ([]*v1alpha1.LeaseCandidate, error) { … }
Codebase Browser
kubernetes