MCPcopy Index your code
hub / github.com/rilldata/rill / Cancel

Method Cancel

runtime/controller.go:779–790  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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.
779func (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.
793func (c *Controller) AcquireConn(ctx context.Context, connector string) (drivers.Handle, func(), error) {

Callers 2

reconcileParserMethod · 0.80

Calls 5

checkRunningMethod · 0.95
lockMethod · 0.95
unlockMethod · 0.95
cancelIfRunningMethod · 0.95
ErrMethod · 0.65

Tested by

no test coverage detected