(ctx context.Context)
| 63 | } |
| 64 | |
| 65 | func (c *Client) AcquirePullCAPILock(ctx context.Context) error { |
| 66 | // delete orphan "old" lock if present |
| 67 | err := c.ReleaseLockWithTimeout(ctx, CapiPullLockName, CAPIPullLockTimeout) |
| 68 | if err != nil { |
| 69 | log.Errorf("unable to release pullCAPI lock: %s", err) |
| 70 | } |
| 71 | |
| 72 | return c.AcquireLock(ctx, CapiPullLockName) |
| 73 | } |
| 74 | |
| 75 | func (c *Client) ReleasePullCAPILock(ctx context.Context) error { |
| 76 | log.Debugf("deleting lock %s", CapiPullLockName) |
no test coverage detected