Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dynalock

package module

Go to main page

Versions in this module

v1

v1.3.1

Jul 28, 2021

v1.3.0

Jul 27, 2021

Changes in this version

type Locker

+ LockWithContext func(ctx context.Context) (<-chan struct{}, error)

v1.2.1

Dec 8, 2019

v1.2.0

Dec 1, 2019

Changes in this version

type Store

+ func NewWithDefaults(tableName, partition string) Store

v1.1.0

Apr 29, 2019

Changes in this version

+ var DefaultLockBackOff = 3 * time.Second

type KVPair

+ Expires int64

type WriteOption

+ func WriteWithNoExpires() WriteOption

v1.0.0

Apr 21, 2019

Changes in this version

+ const DefaultLockTTL

+ var ErrKeyExists = errors.New("key already exists in table")

+ var ErrKeyModified = errors.New("key has been modified")

+ var ErrKeyNotFound = errors.New("key not found in table")

+ var ErrLockAcquireCancelled = errors.New("lock acquire was cancelled")

+ func MarshalStruct(in interface{}) (*dynamodb.AttributeValue, error)

+ func UnmarshalStruct(val *dynamodb.AttributeValue, out interface{}) error

+ type Dynalock struct

+ func (ddb *Dynalock) AtomicDelete(key string, previous *KVPair) (bool, error)

+ func (ddb *Dynalock) AtomicPut(key string, options ...WriteOption) (bool, *KVPair, error)

+ func (ddb *Dynalock) Delete(key string) error

+ func (ddb *Dynalock) Exists(key string, options ...ReadOption) (bool, error)

+ func (ddb *Dynalock) Get(key string, options ...ReadOption) (*KVPair, error)

+ func (ddb *Dynalock) List(prefix string, options ...ReadOption) ([]*KVPair, error)

+ func (ddb *Dynalock) NewLock(key string, options ...LockOption) (Locker, error)

+ func (ddb *Dynalock) Put(key string, options ...WriteOption) error

+ type KVPair struct

+ Key string

+ Partition string

+ Version int64

+ func (kv *KVPair) AttributeValue() *dynamodb.AttributeValue

+ func (kv *KVPair) BytesValue() []byte

+ type LockOption func(opts *LockOptions)

+ func LockWithBytes(val []byte) LockOption

+ func LockWithRenewLock(renewLockChan chan struct{}) LockOption

+ func LockWithTTL(ttl time.Duration) LockOption

+ type LockOptions struct

+ func NewLockOptions(opts ...LockOption) *LockOptions

+ type Locker interface

+ Lock func(stopChan chan struct{}) (<-chan struct{}, error)

+ Unlock func() error

+ type ReadOption func(opts *ReadOptions)

+ func ReadConsistentDisable() ReadOption

+ type ReadOptions struct

+ func NewReadOptions(opts ...ReadOption) *ReadOptions

+ type Store interface

+ AtomicDelete func(key string, previous *KVPair) (bool, error)

+ AtomicPut func(key string, options ...WriteOption) (bool, *KVPair, error)

+ Delete func(key string) error

+ Exists func(key string, options ...ReadOption) (bool, error)

+ Get func(key string, options ...ReadOption) (*KVPair, error)

+ List func(prefix string, options ...ReadOption) ([]*KVPair, error)

+ NewLock func(key string, options ...LockOption) (Locker, error)

+ Put func(key string, options ...WriteOption) error

+ func New(dynamoSvc dynamodbiface.DynamoDBAPI, tableName, partition string) Store

+ type WriteOption func(opts *WriteOptions)

+ func WriteWithAttributeValue(av *dynamodb.AttributeValue) WriteOption

+ func WriteWithBytes(val []byte) WriteOption

+ func WriteWithPreviousKV(previous *KVPair) WriteOption

+ func WriteWithTTL(ttl time.Duration) WriteOption

+ type WriteOptions struct

+ func NewWriteOptions(opts ...WriteOption) *WriteOptions

Other modules containing this package

github.com/wolfeidau/dynalock/v2