distrubutedlock

Documentation

Index

• Variables
• func Init(ctx context.Context, client *mongo.Client, dbName, collectionName string) error
• type DistributedLock
  • func New(lockKey string, expiration time.Duration, labels map[string]string) *DistributedLock
  • func (d *DistributedLock) Acquire(ctx context.Context) error
  • func (d *DistributedLock) GetLabels(ctx context.Context) (map[string]string, error)
  • func (d *DistributedLock) IsLocked(ctx context.Context) (bool, error)
  • func (d *DistributedLock) Release(ctx context.Context) error

Variables

var (
	ErrLockAcquired    = errors.New("lock already acquired")
	ErrLockNotAcquired = errors.New("lock not acquired")
)

Functions

func Init

func Init(ctx context.Context, client *mongo.Client, dbName, collectionName string) error

Types

type DistributedLock

type DistributedLock struct {
	// contains filtered or unexported fields
}

func New

func New(lockKey string, expiration time.Duration, labels map[string]string) *DistributedLock

func (*DistributedLock) Acquire

func (d *DistributedLock) Acquire(ctx context.Context) error

func (*DistributedLock) GetLabels

func (d *DistributedLock) GetLabels(ctx context.Context) (map[string]string, error)

func (*DistributedLock) IsLocked

func (d *DistributedLock) IsLocked(ctx context.Context) (bool, error)

func (*DistributedLock) Release

func (d *DistributedLock) Release(ctx context.Context) error