locker

type CallBackFunc func(key string, err error)

type Executor interface {
}

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

type Lock struct {
	Key   string
	Token string
}

type LockType string

type Locker interface {
	// Acquire 申请分布式锁
	Acquire(ctx context.Context, resource string, expiration time.Duration, callback CallBackFunc) (Lock, error)
	// Release 释放分布式锁
	Release(ctx context.Context, key, token string) error
	// Stop 停止分布式锁管理器
	Stop()
}

type ManagerConfig struct {
	// 锁的前缀
	Prefix string
	// 管理器节点标识
	NodeID string
	// 分片的数量
	ShardCount int
	// 每一个分片下的Worker数量，这个Worker是处理同一批
	// 的锁的续约的功能，这里定义的是最多有几个
	ShardWorkers int
	// 每一个分片下的优先级队列的长度，每一个分片有一个
	QueueSize int
	// 每一个分片批次续约的锁数量
	BatchSize int
	// 单节点的最大锁数量
	MaxLocks int
	// 批次续约的时间间隔，比如每一轮次续约需要间隔(休眠)100毫秒
	RefreshInterval time.Duration
}

type ManagerStatus bool

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

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

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

type Priority int

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

type RefreshTask struct {
	Key           string // 锁的key
	NextRefreshAt int64  // 下次续约时间戳（毫秒）
	// contains filtered or unexported fields
}

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