locker

package

v0.1.152 Latest Latest Go to latest Published: Feb 21, 2026 License: MIT Imports: 9 Imported by: 0

Details

View Source

const (
	LOCKER_INMEMORY = "inmemory"
	LOCKER_POSTGRES = "postgres"
)

This section is empty.

This section is empty.

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

func NewInMemoryLocker() *InMemoryLocker

func (m *InMemoryLocker) AcquireLock(ctx context.Context, key string) (Lock, error)

type Lock interface {
	ReleaseLock(ctx context.Context) error
}

type Locker interface {
	AcquireLock(ctx context.Context, key string) (Lock, error)
}

type LockerOption func(*PostgresLocker)

func WithConnMaxIdleTime(d time.Duration) LockerOption

func WithConnMaxLifetime(d time.Duration) LockerOption

func WithMaxIdleConns(n int) LockerOption

func WithMaxOpenConns(n int) LockerOption

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

func NewPostgresLocker(dsn string, opts ...LockerOption) (*PostgresLocker, error)

func (p *PostgresLocker) AcquireLock(ctx context.Context, key string) (Lock, error)