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{