dsync

type DistMutexOptions struct {
	Expiry         time.Duration  // Expiry 是锁租约的有效期。
	Tries          int            // Tries 是后端尝试获取锁的次数。
	RetryDelayFunc RetryDelayFunc // RetryDelayFunc 计算相邻重试间隔。
	DriftFactor    float64        // DriftFactor 是计算有效期时预留的时钟漂移比例。
	TimeoutFactor  float64        // TimeoutFactor 是单次后端操作占租约时长的比例。
	GenUIDFunc     GenUIDFunc     // GenUIDFunc 为新锁生成所有权 ID。
	UID            string         // UID 显式指定所有权 ID；部分后端不支持。
}

type GenUIDFunc = generic.FuncPair0[string, error]

type IDistMutex interface {
	// Name 返回不含后端键前缀的锁名称。
	Name() string
	// UID 返回当前锁所有权标识；后端不支持或尚未加锁时可能为空。
	UID() string
	// Until 返回当前租约的预计失效时间；后端不支持时返回零值。
	Until() time.Time
	// TryLock 尝试获取锁；重试策略由具体后端和 Option 决定。
	TryLock(ctx context.Context) error
	// Lock 等待并获取锁；等待受 ctx 及具体后端超时策略约束。
	Lock(ctx context.Context) error
	// Unlock 释放当前持有的锁。
	Unlock(ctx context.Context) error
	// Extend 延长当前锁租约；不支持续期的后端会返回错误。
	Extend(ctx context.Context) error
}

type IDistSync interface {
	// NewMutex 创建逻辑名称为 name 的分布式锁句柄；创建本身不会获取锁。
	NewMutex(name string, settings ...option.Setting[DistMutexOptions]) IDistMutex
	// Separator 返回该后端组织层级锁名称时使用的分隔符。
	Separator() string
}

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