dplock

Aug 13, 2021

Changes in this version

+ var ErrUnlockMaxRetries = errors.New("cannot unlock, maximum number of retries has been reached")

+ var UnlockMaxRetries = 100

+ var UnlockPeriod = 5 * time.Millisecond

Jul 9, 2021

Changes in this version

+ const PurgerPeriod

+ const TTL

+ var AcquireMaxRetries = 10

+ var AcquirePeriod = 250 * time.Millisecond

+ var ErrAcquireMaxRetries = errors.New("cannot acquire lock, maximum number of retries has been reached")

+ var ErrMongoDbClosing = errors.New("mongo db is being closed")

+ var GenerateTimeID = func() int

+ type Client interface

+ Unlock func(ctx context.Context, lockID string) ([]lock.LockStatus, error)

+ XLock func(ctx context.Context, resourceName, lockID string, ld lock.LockDetails) error

+ type Lock struct

+ Client Client

+ CloserChannel chan struct{}

+ Purger Purger

+ Resource string

+ WaitGroup *sync.WaitGroup

+ func New(ctx context.Context, mongoConnection *mongoDriver.MongoConnection, ...) *Lock

+ func (l *Lock) Acquire(ctx context.Context, id string) (lockID string, err error)

+ func (l *Lock) Close(ctx context.Context)

+ func (l *Lock) Init(ctx context.Context, lockClient Client, lockPurger Purger)

+ func (l *Lock) Lock(ctx context.Context, resourceID string) (lockID string, err error)

+ func (l *Lock) Unlock(ctx context.Context, lockID string) error

+ type Purger interface

+ Purge func(ctx context.Context) ([]lock.LockStatus, error)