mutexlocker

Documentation

Index

• type Locker
  • func New(minBufferSize int) *Locker
  • func (l *Locker) Lock(ctx context.Context, key string) (unlock func(), err error)
  • func (l *Locker) LockWithExpiry(ctx context.Context, key string, expiry time.Duration) (unlock func(), err error)

Types

type Locker

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

Locker - реализует интерфейс блокировщика указанного ключа основанный на mutex.

func New

func New(minBufferSize int) *Locker

New - создаёт объект Locker.

func (*Locker) Lock

func (l *Locker) Lock(ctx context.Context, key string) (unlock func(), err error)

Lock - блокирует указанный ключ в рамках приложения с временем блокировки по умолчанию и возвращает функцию разблокировки.

func (*Locker) LockWithExpiry

func (l *Locker) LockWithExpiry(ctx context.Context, key string, expiry time.Duration) (unlock func(), err error)

LockWithExpiry - блокирует указанный ключ в рамках приложения с указанием времени блокировки и возвращает функцию разблокировки. Если указана expiry равная нулю, то будет установлено время блокировки по умолчанию.