lock

Documentation

Index

• type DefaultLocker
  • func (dl DefaultLocker) Lock(k, v string) error
  • func (dl DefaultLocker) Unlock(k string) error
• type DynamodbLock
  • func (dl DynamodbLock) Lock(lockID, eventID string) error
  • func (dl DynamodbLock) Unlock(lockID string) error
• type Locker
  • func NewDynamodbLock(profile, region, table string) Locker

Types

type DefaultLocker

type DefaultLocker struct{}

DefaultLocker do nothing

func (DefaultLocker) Lock

func (dl DefaultLocker) Lock(k, v string) error

Lock DefaultLocker

func (DefaultLocker) Unlock

func (dl DefaultLocker) Unlock(k string) error

Unlock DefaultLocker

type DynamodbLock

type DynamodbLock struct {
	TableName string
	// contains filtered or unexported fields
}

DynamodbLock is to lock job and check duplicated message

func (DynamodbLock) Lock

func (dl DynamodbLock) Lock(lockID, eventID string) error

Lock put a record into dynamodb with lock_id

func (DynamodbLock) Unlock

func (dl DynamodbLock) Unlock(lockID string) error

Unlock delete record from dynamodb with lock_id

type Locker

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

Locker implements lock and unlock

func NewDynamodbLock

func NewDynamodbLock(profile, region, table string) Locker

NewDynamodbLock build DynamodbLock