mutex

package

v0.0.0-...-3b218eb Latest Latest Go to latest Published: Jul 10, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrNotAcquireLock = errors.New("failed t acquire lock")
)

This section is empty.

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

func (d *DefaultLock) Lock(_ string) error

Lock implements Locker.

func (d *DefaultLock) Unlock(key string) error

Unlock implements Locker.

type EtcdConfig struct {
	Timeout   time.Duration // do handle expired time duration
	Endpoints []string
}

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

func (e *EtcdMutex) Lock(key string) error

Lock implements Locker.

func (e *EtcdMutex) Unlock(key string) error

Unlock implements Locker.

type Locker interface {
	Lock(key string) error
	Unlock(key string) error
}

func NewEtcdMutex(ctx context.Context, cfg EtcdConfig) (Locker, error)

func NewRedisMutex(ctx context.Context, cfg *RedisConfig) (Locker, error)

func NewRedisMutexWithClient(client *redis.Client) (Locker, error)

type RedisConfig struct {
	Addr     string
	Username string
	Password string
	DB       int
}

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

func (r *RedisMutex) Lock(key string) error

Lock implements Locker.

func (r *RedisMutex) Unlock(key string) error

Unlock implements Locker.