id_cluster

package

v1.0.2 Latest Latest Go to latest Published: May 8, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var (
	DefaultIdKeyFormat   = "id:type:%s"
	DefaultIdLockTimeout = time.Second * 3
)

This section is empty.

type IdClusterHandler struct {
	*id_storage.IdStorage
	// contains filtered or unexported fields
}

func NewIdClusterHandler(dbService db.IService, redisService redis.IService) (res *IdClusterHandler)

func (this_ *IdClusterHandler) CacheId(ctx context.Context, idType module_id.IdType, id int64) error

func (this_ *IdClusterHandler) FormatIdKey(idType module_id.IdType) string

func (this_ *IdClusterHandler) Increment(ctx context.Context, idType module_id.IdType, size int64) (int64, error)

func (this_ *IdClusterHandler) PersistLock(ctx context.Context, idType module_id.IdType) (unlocker module_id.Unlocker, err error)

func (this_ *IdClusterHandler) RecoverLock(ctx context.Context, idType module_id.IdType) (unlocker module_id.Unlocker, err error)

func (this_ *IdClusterHandler) ShouldCheckAndPersist() bool

func (this_ *IdClusterHandler) WithIdKey(idKeyFormat string) *IdClusterHandler

func (this_ *IdClusterHandler) WithLockTimeout(lockTimeout time.Duration) *IdClusterHandler

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

func (this_ *RedisUnlocker) Unlock()