distributed

package

v1.1.0 Latest Latest Go to latest Published: Apr 30, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewDistributed(opts ...Option) *Distributed

func (d *Distributed) Mutex(ctx context.Context, option LockOption, fn func(ctx context.Context) error) error

type LockOption struct {
	Name string
	TTL  time.Duration
}

type Locker interface {
	TryLock(ctx context.Context, option LockOption) (acquired bool, err error)
}

type Option func(*Distributed)

func WithLocker(locker Locker) Option

func WithLogger(logger *zap.SugaredLogger) Option

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

func NewRedisLocker(client *redis.Client) *RedisLocker

func (l *RedisLocker) TryLock(ctx context.Context, option LockOption) (bool, error)