dlocker

Documentation

Index

• Constants
• Variables
• func MutexLock(lockID string, ttl int32, backend Backend) error
• func MutexTryLock(lockID string, ttl int32, deadline int64, backend Backend) bool
• func MutexUnlock(lockID string, backend Backend) error
• type Backend
  • func NewLockerBackend(s store.Store, ...) (Backend, error)
• type LockerBackend
  • func (w LockerBackend) Del(key []byte) error
  • func (w LockerBackend) Get(key []byte) (*store.Value, error)
  • func (w LockerBackend) TrySetWithTTL(key, value []byte, ttl uint32) error
  • func (w LockerBackend) Watch(key []byte) (store.Watcher, error)

Constants

const (
	Namespace string = "_Locker"
)

Variables

var (
	ErrStatusBusy = errors.New("status busy")
)

Functions

func MutexLock

func MutexLock(lockID string, ttl int32, backend Backend) error

func MutexTryLock

func MutexTryLock(lockID string, ttl int32, deadline int64, backend Backend) bool

func MutexUnlock

func MutexUnlock(lockID string, backend Backend) error

Types

type Backend

type Backend interface {
	Get(key []byte) (*store.Value, error)
	TrySetWithTTL(key, value []byte, ttl uint32) error
	Del(key []byte) error
	Watch(key []byte) (notify store.Watcher, err error)
}

func NewLockerBackend

func NewLockerBackend(
	s store.Store,
	apply func(context.Context, *serverpb.RaftLogPayload, time.Duration) error,
) (Backend, error)

type LockerBackend

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

func (LockerBackend) Del

func (w LockerBackend) Del(key []byte) error

func (LockerBackend) Get

func (w LockerBackend) Get(key []byte) (*store.Value, error)

func (LockerBackend) TrySetWithTTL

func (w LockerBackend) TrySetWithTTL(key, value []byte, ttl uint32) error

func (LockerBackend) Watch

func (w LockerBackend) Watch(key []byte) (store.Watcher, error)