lock

Documentation

Index

• Variables
• type DLock
  • func NewMetaLock(ctx context.Context, metadata metadata.Metadata, options MetaLockOptions) DLock
• type MetaLock
  • func (m *MetaLock) Acquire(key []byte, value []byte, cb callback.Callback[any])
  • func (m *MetaLock) Release(cb callback.Callback[error])
• type MetaLockOptions

Variables

var (
	ErrLockHasReleased  = errors.New("lock has released")
	ErrUnexpectedStatus = errors.New("unexpected status")
)

Types

type DLock

type DLock interface {
	Acquire(key []byte, value []byte, callback callback.Callback[any])

	Release(cb callback.Callback[error])
}

func NewMetaLock

func NewMetaLock(ctx context.Context, metadata metadata.Metadata, options MetaLockOptions) DLock

type MetaLock

type MetaLock struct {
	*slog.Logger
	sync.Mutex
	// contains filtered or unexported fields
}

func (*MetaLock) Acquire

func (m *MetaLock) Acquire(key []byte, value []byte, cb callback.Callback[any])

func (*MetaLock) Release

func (m *MetaLock) Release(cb callback.Callback[error])

type MetaLockOptions

type MetaLockOptions struct {
	OnRelease callback.Callback[DLock]
}