dynamodb

Jan 7, 2017

Changes in this version

+ func CreateLockTable(tableName string, readCapacityUnits int, writeCapacityUnits int, ...) error

+ func CreateLockTableIfNecessary(tableName string, client *dynamodb.DynamoDB, ...) error

+ func DeleteTable(tableName string, client *dynamodb.DynamoDB) error

+ type CountingSemaphore chan empty

+ func NewCountingSemaphore(size int) CountingSemaphore

+ func (semaphore CountingSemaphore) Acquire()

+ func (semaphore CountingSemaphore) Release()

Sep 28, 2016

Changes in this version

+ const ATTR_CREATION_DATE

+ const ATTR_IP

+ const ATTR_STATE_FILE_ID

+ const ATTR_USERNAME

+ const DEFAULT_AWS_REGION

+ const DEFAULT_MAX_RETRIES_WAITING_FOR_LOCK

+ const DEFAULT_READ_CAPACITY_UNITS

+ const DEFAULT_TABLE_NAME

+ const DEFAULT_TEST_REGION

+ const DEFAULT_WRITE_CAPACITY_UNITS

+ const MAX_RETRIES_WAITING_FOR_TABLE_TO_BE_ACTIVE

+ const SLEEP_BETWEEN_TABLE_LOCK_ACQUIRE_ATTEMPTS

+ const SLEEP_BETWEEN_TABLE_STATUS_CHECKS

+ var StateFileIdMissing = fmt.Errorf("state_file_id cannot be empty")

+ func New(conf map[string]string) (locks.Lock, error)

+ type AcquireLockRetriesExceeded struct

+ ItemId string

+ Retries int

+ func (err AcquireLockRetriesExceeded) Error() string

+ type AttributeMissing struct

+ AttributeName string

+ func (err AttributeMissing) Error() string

+ type DynamoDbLock struct

+ AwsRegion string

+ MaxLockRetries int

+ StateFileId string

+ TableName string

+ func (dynamoDbLock DynamoDbLock) AcquireLock() error

+ func (dynamoDbLock DynamoDbLock) ReleaseLock() error

+ func (dynamoLock DynamoDbLock) String() string

+ type InvalidDateFormat struct

+ Date string

+ UnderlyingErr error

+ func (err InvalidDateFormat) Error() string

+ type InvalidMaxLockRetriesValue struct

+ ValidationErr error

+ func (err *InvalidMaxLockRetriesValue) Error() string

+ type TableActiveRetriesExceeded struct

+ Retries int

+ TableName string

+ func (err TableActiveRetriesExceeded) Error() string