locker

package

v0.1.149 Latest Latest Go to latest Published: Dec 23, 2025 License: MIT Imports: 8 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 PostgresLocker struct {
	// contains filtered or unexported fields
}

func NewPostgresLocker(dsn string) (*PostgresLocker, error)

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