lock

package

v1.5.1 Latest Latest Go to latest Published: Aug 12, 2026 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/yi-nology/git-sync-service

Links

Open Source Insights

Documentation ¶

Index ¶

type DistLock
type LocalLock
- func NewLocalLock() *LocalLock
type RedisLock
- func NewRedisLock(addr, password string, db int) *RedisLock
type Semaphore
- func NewSemaphore(client *redis.Client, key string, max int) *Semaphore

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DistLock ¶

type DistLock interface {
	TryLock(ctx context.Context, key string) (bool, error)
	TryLockWithTTL(ctx context.Context, key string, ttl time.Duration) (bool, error)
	Lock(ctx context.Context, key string) error
	Unlock(ctx context.Context, key string) error
}

type LocalLock ¶

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

func NewLocalLock ¶

func NewLocalLock() *LocalLock

func (*LocalLock) Lock ¶

func (l *LocalLock) Lock(ctx context.Context, key string) error

func (*LocalLock) TryLock ¶

func (l *LocalLock) TryLock(ctx context.Context, key string) (bool, error)

func (*LocalLock) TryLockWithTTL ¶

func (l *LocalLock) TryLockWithTTL(ctx context.Context, key string, ttl time.Duration) (bool, error)

func (*LocalLock) Unlock ¶

func (l *LocalLock) Unlock(ctx context.Context, key string) error

type RedisLock ¶

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

func NewRedisLock ¶

func NewRedisLock(addr, password string, db int) *RedisLock

func (*RedisLock) Client ¶

func (l *RedisLock) Client() *redis.Client

func (*RedisLock) Close ¶

func (l *RedisLock) Close() error

func (*RedisLock) ExtendLock ¶

func (l *RedisLock) ExtendLock(ctx context.Context, key string, ttl time.Duration) error

func (*RedisLock) Lock ¶

func (l *RedisLock) Lock(ctx context.Context, key string) error

func (*RedisLock) LockWithTTL ¶

func (l *RedisLock) LockWithTTL(ctx context.Context, key string, ttl time.Duration) (bool, string, error)

func (*RedisLock) Ping ¶

func (l *RedisLock) Ping(ctx context.Context) error

func (*RedisLock) TryLock ¶

func (l *RedisLock) TryLock(ctx context.Context, key string) (bool, error)

func (*RedisLock) TryLockWithTTL ¶

func (l *RedisLock) TryLockWithTTL(ctx context.Context, key string, ttl time.Duration) (bool, error)

func (*RedisLock) Unlock ¶

func (l *RedisLock) Unlock(ctx context.Context, key string) error

func (*RedisLock) UnlockWithValue ¶

func (l *RedisLock) UnlockWithValue(ctx context.Context, key, value string) error

type Semaphore ¶

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

func NewSemaphore ¶

func NewSemaphore(client *redis.Client, key string, max int) *Semaphore

func (*Semaphore) Acquire ¶

func (s *Semaphore) Acquire(ctx context.Context, identifier string) (bool, error)

func (*Semaphore) Cleanup ¶

func (s *Semaphore) Cleanup(ctx context.Context, olderThan time.Duration) error

func (*Semaphore) Release ¶

func (s *Semaphore) Release(ctx context.Context, identifier string) error

Source Files ¶

View all Source files

lock.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL