dynamodb

Documentation

Index

• Constants
• func CreateDynamoDbClient(config *aws_helper.AwsSessionConfig, ...) (*dynamodb.DynamoDB, error)
• func CreateLockTable(tableName string, tags map[string]string, readCapacityUnits int, ...) error
• func CreateLockTableIfNecessary(tableName string, tags map[string]string, client *dynamodb.DynamoDB, ...) error
• func DeleteTable(tableName string, client *dynamodb.DynamoDB) error
• func LockTableCheckSSEncryptionIsOn(tableName string, client *dynamodb.DynamoDB) (bool, error)
• func LockTableExistsAndIsActive(tableName string, client *dynamodb.DynamoDB) (bool, error)
• func UpdateLockTableSetSSEncryptionOnIfNecessary(tableName string, client *dynamodb.DynamoDB, ...) error
• type CountingSemaphore
  • func NewCountingSemaphore(size int) CountingSemaphore
  • func (semaphore CountingSemaphore) Acquire()
  • func (semaphore CountingSemaphore) Release()
• type TableActiveRetriesExceeded
  • func (err TableActiveRetriesExceeded) Error() string
• type TableDoesNotExist
  • func (err TableDoesNotExist) Error() string
• type TableEncryptedRetriesExceeded
  • func (err TableEncryptedRetriesExceeded) Error() string

Constants

const ATTR_LOCK_ID = "LockID"

Terraform requires the DynamoDB table to have a primary key with this name

const DEFAULT_READ_CAPACITY_UNITS = 1

const DEFAULT_TEST_REGION = "us-east-1"

For simplicity, do all testing in the us-east-1 region

const DEFAULT_WRITE_CAPACITY_UNITS = 1

const MAX_RETRIES_WAITING_FOR_TABLE_TO_BE_ACTIVE = 30

Default is to retry for up to 5 minutes

const SLEEP_BETWEEN_TABLE_STATUS_CHECKS = 10 * time.Second

Functions

func CreateDynamoDbClient

func CreateDynamoDbClient(config *aws_helper.AwsSessionConfig, terragruntOptions *options.TerragruntOptions) (*dynamodb.DynamoDB, error)

Create an authenticated client for DynamoDB

func CreateLockTable

func CreateLockTable(tableName string, tags map[string]string, readCapacityUnits int, writeCapacityUnits int, client *dynamodb.DynamoDB, terragruntOptions *options.TerragruntOptions) error

Create a lock table in DynamoDB and wait until it is in "active" state. If the table already exists, merely wait until it is in "active" state.

func CreateLockTableIfNecessary

func CreateLockTableIfNecessary(tableName string, tags map[string]string, client *dynamodb.DynamoDB, terragruntOptions *options.TerragruntOptions) error

Create the lock table in DynamoDB if it doesn't already exist

func DeleteTable

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

Delete the given table in DynamoDB

func LockTableCheckSSEncryptionIsOn

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

Return true if the lock table's SSEncryption is turned on

func LockTableExistsAndIsActive

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

Return true if the lock table exists in DynamoDB and is in "active" state

func UpdateLockTableSetSSEncryptionOnIfNecessary

func UpdateLockTableSetSSEncryptionOnIfNecessary(tableName string, client *dynamodb.DynamoDB, terragruntOptions *options.TerragruntOptions) error

Encrypt the TFState Lock table - If Necessary

Types

type CountingSemaphore

type CountingSemaphore chan empty

func NewCountingSemaphore

func NewCountingSemaphore(size int) CountingSemaphore

A bare-bones counting semaphore implementation based on: http://www.golangpatterns.info/concurrency/semaphores

func (CountingSemaphore) Acquire

func (semaphore CountingSemaphore) Acquire()

func (CountingSemaphore) Release

func (semaphore CountingSemaphore) Release()

type TableActiveRetriesExceeded

type TableActiveRetriesExceeded struct {
	TableName string
	Retries   int
}

func (TableActiveRetriesExceeded) Error

func (err TableActiveRetriesExceeded) Error() string

type TableDoesNotExist

type TableDoesNotExist struct {
	TableName  string
	Underlying error
}

func (TableDoesNotExist) Error

func (err TableDoesNotExist) Error() string

type TableEncryptedRetriesExceeded

type TableEncryptedRetriesExceeded struct {
	TableName string
	Retries   int
}

func (TableEncryptedRetriesExceeded) Error

func (err TableEncryptedRetriesExceeded) Error() string