Reconcile enqueues a resource for reconciliation. If the resource is currently reconciling, the current reconciler will be cancelled first.
(ctx context.Context, name *runtimev1.ResourceName)
| 762 | // Reconcile enqueues a resource for reconciliation. |
| 763 | // If the resource is currently reconciling, the current reconciler will be cancelled first. |
| 764 | func (c *Controller) Reconcile(ctx context.Context, name *runtimev1.ResourceName) error { |
| 765 | if err := c.checkRunning(); err != nil { |
| 766 | return err |
| 767 | } |
| 768 | if ctx.Err() != nil { |
| 769 | return ctx.Err() |
| 770 | } |
| 771 | c.lock(ctx, false) |
| 772 | defer c.unlock(ctx, false) |
| 773 | c.enqueue(name) |
| 774 | return nil |
| 775 | } |
| 776 | |
| 777 | // Cancel cancels the current invocation of a resource's reconciler (if it's running). |
| 778 | // It does not re-enqueue the resource for reconciliation. |
nothing calls this directly
no test coverage detected