dlock

package

v0.0.0-...-c23f155 Latest Latest Go to latest Published: May 4, 2024 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Rendered for

This section is empty.

This section is empty.

func EtcdDLockBuilder(ctx context.Context, client *clientv3.Client) *etcdDLockOptions

func RedisDLockBuilder(ctx context.Context, scripter func() redis.Scripter) *redisDLockOptions

type DLockErr string

const (
	ErrDLockAcquireFailed DLockErr = "failed to acquire dlock"
	ErrDLockNoInit        DLockErr = "no init the dlock"
)

func (err DLockErr) Error() string

type DLocker interface {
	Lock() error
	Unlock() error
	Renewal(newTTL time.Duration) error
	TTL() (time.Duration, error)
}

func EtcdDLock(ctx context.Context, client *clientv3.Client, opts ...EtcdDLockOption) (DLocker, error)

func RedisDLock(ctx context.Context, scripter func() redis.Scripter, opts ...RedisDLockOption) (DLocker, error)

type EtcdDLockOption func(opt *etcdDLockOptions)

func WithEtcdDLockKeys(keys ...string) EtcdDLockOption

func WithEtcdDLockRetry(strategy RetryStrategy) EtcdDLockOption

func WithEtcdDLockTTL(ttl time.Duration) EtcdDLockOption

type RedisDLockOption func(opt *redisDLockOptions)

func WithRedisDLockKeys(keys ...string) RedisDLockOption

func WithRedisDLockRetry(strategy RetryStrategy) RedisDLockOption

func WithRedisDLockTTL(ttl time.Duration) RedisDLockOption

func WithRedisDLockToken(token string) RedisDLockOption

type RetryStrategy interface {
	Next() time.Duration
}

func DefaultExponentialBackoffRetry() RetryStrategy

func EndlessRetry(backoff time.Duration) RetryStrategy

func ExponentialBackoffRetry(maxSteps int64, initBackoff, maxBackoff time.Duration, backoffFactor, jitter float64) RetryStrategy

func LimitedRetry(backoff time.Duration, maxCount int64) RetryStrategy

func NoRetry() RetryStrategy