lock

Documentation

Index

• func SessionInterestLockKey(sessionID string) string
• func SessionLockKey(sessionID string) string
• type GlobalLockAppropriator
  • func NewGlobalLockAppropriator(dynamo *dynamodb.DynamoDB, tableName string, retry time.Duration, ...) GlobalLockAppropriator
  • func (a GlobalLockAppropriator) DoWithLock(ctx context.Context, lockID string, action func(ctx context.Context) error) error
• type Lock

Functions

func SessionInterestLockKey

func SessionInterestLockKey(sessionID string) string

func SessionLockKey

func SessionLockKey(sessionID string) string

Types

type GlobalLockAppropriator

type GlobalLockAppropriator func(ctx context.Context, lockID string) (Lock, error)

GlobalLockAppropriator can be used to acquire global locks on resources

func NewGlobalLockAppropriator

func NewGlobalLockAppropriator(dynamo *dynamodb.DynamoDB, tableName string, retry time.Duration, maxDuration time.Duration) GlobalLockAppropriator

NewGlobalLockAppropriator returns a fully wired GlobalLockAppropriator. If lock acquisition fails it will be retried based on retry until maxDuration has passed at which point acquisition will fail with an error.

func (GlobalLockAppropriator) DoWithLock

func (a GlobalLockAppropriator) DoWithLock(ctx context.Context, lockID string, action func(ctx context.Context) error) error

type Lock

type Lock interface {
	// Unlock releases the lock
	Unlock(ctx context.Context) error
}

Lock represents a distributed lock