locker

Documentation

Index

• type LocalLocker
  • func (ml *LocalLocker) Lock(ctx context.Context, resource string) (Release, error)
  • func (ml *LocalLocker) LockWithtimeout(ctx context.Context, resource string, timeout time.Duration) (Release, error)
• type Locker
  • func InitLocalLocker() Locker
• type Release

Types

type LocalLocker

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

func (*LocalLocker) Lock

func (ml *LocalLocker) Lock(ctx context.Context, resource string) (Release, error)

func (*LocalLocker) LockWithtimeout

func (ml *LocalLocker) LockWithtimeout(ctx context.Context, resource string, timeout time.Duration) (Release, error)

type Locker

type Locker interface {
	Lock(ctx context.Context, resource string) (Release, error)
	LockWithtimeout(ctx context.Context, resource string, timeout time.Duration) (Release, error)
}

func InitLocalLocker

func InitLocalLocker() Locker

type Release

type Release func(context.Context) error