dsync

Documentation

Index

• Variables
• type DelayFunc
• type DistMutexOptions
• type GenValueFunc
• type IDistMutex
• type IDistSync

Variables

var (
	Name  = self.Name
	Using = self.Using
)

var (
	// ErrDsync dsync errors.
	ErrDsync = errors.New("dsync")
	// ErrNotAcquired is an error indicating that the distributed lock was not acquired. It is returned by IDistMutex.Unlock and IDistMutex.Extend when the lock was not successfully acquired or has expired.
	ErrNotAcquired = fmt.Errorf("%w: lock is not acquired", ErrDsync)
)

var With _Option

Types

type DelayFunc

type DelayFunc = generic.Func1[int, time.Duration]

A DelayFunc is used to decide the amount of time to wait between retries.

type DistMutexOptions

type DistMutexOptions struct {
	Expiry        time.Duration
	Tries         int
	DelayFunc     DelayFunc
	DriftFactor   float64
	TimeoutFactor float64
	GenValueFunc  GenValueFunc
	Value         string
}

DistMutexOptions represents the options for acquiring a distributed mutex.

type GenValueFunc

type GenValueFunc = generic.PairFunc0[string, error]

GenValueFunc is used to generate a random value.

type IDistMutex

type IDistMutex interface {
	// Name returns mutex name.
	Name() string
	// Value returns the current random value. The value will be empty until a lock is acquired (or Value option is used).
	Value() string
	// Until returns the time of validity of acquired lock. The value will be zero value until a lock is acquired.
	Until() time.Time
	// Lock locks m. In case it returns an error on failure, you may retry to acquire the lock by calling this method again.
	Lock(ctx context.Context) error
	// Unlock unlocks m and returns the status of unlock.
	Unlock(ctx context.Context) error
	// Extend resets the mutex's expiry and returns the status of expiry extension.
	Extend(ctx context.Context) error
	// Valid returns true if the lock acquired through m is still valid. It may also return true erroneously if quorum is achieved during the call and at
	// least one node then takes long enough to respond for the lock to expire.
	Valid(ctx context.Context) (bool, error)
}

A IDistMutex is a distributed mutual exclusion lock. Avoid sharing the same IDistMutex instance among multiple goroutines. Create a separate IDistMutex instance for each goroutine.

type IDistSync

type IDistSync interface {
	// NewMutex returns a new distributed mutex with given name.
	NewMutex(name string, settings ...option.Setting[DistMutexOptions]) IDistMutex
	// GetSeparator return name path separator.
	GetSeparator() string
}

IDistSync represents a distributed synchronization mechanism.