module_id

type IdFace interface {
	GetId(ctx context.Context, idType IdType) (int64, error)
	GetIds(ctx context.Context, idType IdType, size int64) ([]int64, error)
}

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

type IdHandler interface {
	ShouldCheckAndPersist() bool
	// Increment 增长，使用 redis 的 incr 指令实现原子操作
	// 如果缓存不存在则返回的 id 为 0
	Increment(ctx context.Context, idType IdType, size int64) (int64, error)
	// CacheId 缓存 id，缓存中不存在则通过 QueryId 查询恢复
	CacheId(ctx context.Context, idType IdType, id int64) error
	// StorageQueryId 存储 查询 id，缓存中不存在时进行查询
	StorageQueryId(ctx context.Context, idType IdType) (int64, error)
	// StorageInsert 存储 新增 id
	StorageInsert(ctx context.Context, idType IdType, id int64) error
	// StorageUpdate 存储 更新 id
	StorageUpdate(ctx context.Context, idType IdType, id int64) error
	// RecoverLock id 恢复锁，通常在存储时使用
	RecoverLock(ctx context.Context, idType IdType) (Unlocker, error)
	// PersistLock id 入库落地锁，通常在存储时使用
	PersistLock(ctx context.Context, idType IdType) (Unlocker, error)
}

type IdType string

type Unlocker interface {
	Unlock()
}