rdlock

package

v0.0.2 Latest Latest Go to latest Published: Jul 11, 2025 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (c *Dclient) NewDlock(_ context.Context, key string, expiration time.Duration) (dlock.Dlock, error)

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

func NewDClientBuilder(rc redis.Cmdable) *DclientBuilder

func (b *DclientBuilder) Build() *Dclient

func (b *DclientBuilder) WithRetryStrategy(strategy retry.Strategy) *DclientBuilder

WithRetryStrategy 指定重试策略

func (b *DclientBuilder) WithTimeout(timeout time.Duration) *DclientBuilder

func (b *DclientBuilder) WithValFunc(valFunc func() string) *DclientBuilder

WithValFunc 指定值生成方法

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

func NewDlock(client redis.Cmdable, key string, expiration time.Duration, opts ...option.Opt[Dlock]) (*Dlock, error)

func (l *Dlock) Refresh(ctx context.Context) error

Refresh 刷新锁的过期时间，失败不会重试。

func (l *Dlock) TryLock(ctx context.Context) error

TryLock 尝试获取分布式锁，当失败时候会根据重试策略进行重试。默认重试策略为指数退避策略（初始间隔 100ms，最大间隔 1s，最大重试次数 8 次）。

func (l *Dlock) Unlock(ctx context.Context) error

Unlock 释放锁，失败不会重试。