dynamodb

Oct 5, 2017

Changes in this version

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

Apr 21, 2017

Changes in this version

+ const ATTR_LOCK_ID

+ func CreateDynamoDbClient(awsRegion, awsProfile string) (*dynamodb.DynamoDB, error)

+ 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()

+ type TableDoesNotExist struct

+ TableName string

+ Underlying error

+ func (err TableDoesNotExist) Error() string

Sep 14, 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("The dynamodb.stateFileId field cannot be empty")

+ 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) Validate() error

+ func (dynamoDbLock DynamoDbLock) AcquireLock() error

+ func (dynamoDbLock DynamoDbLock) ReleaseLock() error

+ func (dynamoLock *DynamoDbLock) FillDefaults()

+ func (dynamoLock DynamoDbLock) String() string

+ type InvalidDateFormat struct

+ Date string

+ UnderlyingErr error

+ func (err InvalidDateFormat) Error() string

+ type TableActiveRetriesExceeded struct

+ Retries int

+ TableName string

+ func (err TableActiveRetriesExceeded) Error() string