Cancel cancels the current invocation of a resource's reconciler (if it's running). It does not re-enqueue the resource for reconciliation.
(ctx context.Context, name *runtimev1.ResourceName)
| 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. |
| 779 | func (c *Controller) Cancel(ctx context.Context, name *runtimev1.ResourceName) error { |
| 780 | if err := c.checkRunning(); err != nil { |
| 781 | return err |
| 782 | } |
| 783 | if ctx.Err() != nil { |
| 784 | return ctx.Err() |
| 785 | } |
| 786 | c.lock(ctx, false) |
| 787 | defer c.unlock(ctx, false) |
| 788 | c.cancelIfRunning(name) |
| 789 | return nil |
| 790 | } |
| 791 | |
| 792 | // AcquireOLAP gets a handle for a connector in the controller's instance. |
| 793 | func (c *Controller) AcquireConn(ctx context.Context, connector string) (drivers.Handle, func(), error) { |
no test coverage detected