lock

package

v0.5.1 Latest Latest Go to latest Published: Mar 4, 2021 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type DefaultLocker struct{}

DefaultLocker do nothing

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

Lock DefaultLocker

func (dl DefaultLocker) Unlock(k string) error

Unlock DefaultLocker

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

DynamodbLock is to lock job and check duplicated message

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

Lock put a record into dynamodb with lock_id

func (dl DynamodbLock) Unlock(lockID string) error

Unlock delete record from dynamodb with lock_id

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

Locker implements lock and unlock

func NewDynamodbLock(profile, region, table string) Locker

NewDynamodbLock build DynamodbLock