From 77b90ad317b98e7fc8dd535fe38aad9c49556a5b Mon Sep 17 00:00:00 2001 From: Marius Date: Fri, 4 Mar 2016 22:14:09 +0100 Subject: [PATCH] Add UseIn() function for ConsulLocker --- consullocker/consullocker.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/consullocker/consullocker.go b/consullocker/consullocker.go index c7b846b..de6a273 100644 --- a/consullocker/consullocker.go +++ b/consullocker/consullocker.go @@ -45,6 +45,10 @@ func New(client *consul.Client) *ConsulLocker { } } +func (locker *ConsulLocker) UseIn(composer *tusd.StoreComposer) { + composer.UseLocker(locker) +} + // LockUpload tries to obtain the exclusive lock. func (locker *ConsulLocker) LockUpload(id string) error { lock, err := locker.Client.LockOpts(&consul.LockOptions{