dynamodb

package

v0.9.9 Latest Latest Go to latest Published: Feb 4, 2017 License: MIT Imports: 17 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

Repository

github.com/dtx/terragrunt

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
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
func New(conf map[string]string) (locks.Lock, error)
type AcquireLockRetriesExceeded
- func (err AcquireLockRetriesExceeded) Error() string
type AttributeMissing
- func (err AttributeMissing) Error() string
type CountingSemaphore
- func NewCountingSemaphore(size int) CountingSemaphore
- func (semaphore CountingSemaphore) Acquire()
- func (semaphore CountingSemaphore) Release()
type DynamoDbLock
- func (dynamoDbLock DynamoDbLock) AcquireLock(terragruntOptions *options.TerragruntOptions) error
- func (dynamoDbLock DynamoDbLock) ReleaseLock(terragruntOptions *options.TerragruntOptions) error
- func (dynamoLock DynamoDbLock) String() string
type InvalidDateFormat
- func (err InvalidDateFormat) Error() string
type InvalidMaxLockRetriesValue
- func (err *InvalidMaxLockRetriesValue) Error() string
type ItemDoesNotExist
- func (err ItemDoesNotExist) Error() string
type TableActiveRetriesExceeded
- func (err TableActiveRetriesExceeded) Error() string
type TableDoesNotExist
- func (err TableDoesNotExist) Error() string

Constants ¶

View Source

const ATTR_CREATION_DATE = "CreationDate"

View Source

const ATTR_IP = "Ip"

View Source

const ATTR_STATE_FILE_ID = "StateFileId"

The names of attributes we use in the DynamoDB lock table

View Source

const ATTR_USERNAME = "Username"

View Source

const DEFAULT_AWS_REGION = "us-east-1"

View Source

const DEFAULT_MAX_RETRIES_WAITING_FOR_LOCK = 360

Default is to retry for up to 1 hour

View Source

const DEFAULT_READ_CAPACITY_UNITS = 1

View Source

const DEFAULT_TABLE_NAME = "terragrunt_locks"

View Source

const DEFAULT_TEST_REGION = "us-east-1"

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

View Source

const DEFAULT_WRITE_CAPACITY_UNITS = 1

View Source

const MAX_RETRIES_WAITING_FOR_TABLE_TO_BE_ACTIVE = 30

Default is to retry for up to 5 minutes

View Source

const SLEEP_BETWEEN_TABLE_LOCK_ACQUIRE_ATTEMPTS = 10 * time.Second

View Source

const SLEEP_BETWEEN_TABLE_STATUS_CHECKS = 10 * time.Second

Variables ¶

View Source

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

Functions ¶

func CreateLockTable ¶ added in v0.7.4

func CreateLockTable(tableName 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 ¶ added in v0.7.4

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

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

func DeleteTable ¶ added in v0.7.4

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

Delete the given table in DynamoDB

func New ¶

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

New is the factory function for DynamoDbLock

Types ¶

type AcquireLockRetriesExceeded ¶

type AcquireLockRetriesExceeded struct {
	ItemId  string
	Retries int
}

func (AcquireLockRetriesExceeded) Error ¶

func (err AcquireLockRetriesExceeded) Error() string

type AttributeMissing ¶

type AttributeMissing struct {
	AttributeName string
}

func (AttributeMissing) Error ¶

func (err AttributeMissing) Error() string

type CountingSemaphore ¶ added in v0.7.4

type CountingSemaphore chan empty

func NewCountingSemaphore ¶ added in v0.7.4

func NewCountingSemaphore(size int) CountingSemaphore

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

func (CountingSemaphore) Acquire ¶ added in v0.7.4

func (semaphore CountingSemaphore) Acquire()

func (CountingSemaphore) Release ¶ added in v0.7.4

func (semaphore CountingSemaphore) Release()

type DynamoDbLock ¶

type DynamoDbLock struct {
	StateFileId    string
	AwsRegion      string
	AwsProfile     string
	TableName      string
	MaxLockRetries int
}

A lock that uses AWS's DynamoDB to acquire and release locks

func (DynamoDbLock) AcquireLock ¶

func (dynamoDbLock DynamoDbLock) AcquireLock(terragruntOptions *options.TerragruntOptions) error

Acquire a lock by writing an entry to DynamoDB. If that write fails, it means someone else already has the lock, so retry until they release the lock.

func (DynamoDbLock) ReleaseLock ¶

func (dynamoDbLock DynamoDbLock) ReleaseLock(terragruntOptions *options.TerragruntOptions) error

Release a lock by deleting an entry from DynamoDB.

func (DynamoDbLock) String ¶

func (dynamoLock DynamoDbLock) String() string

Print a string representation of this lock

type InvalidDateFormat ¶

type InvalidDateFormat struct {
	Date          string
	UnderlyingErr error
}

func (InvalidDateFormat) Error ¶

func (err InvalidDateFormat) Error() string

type InvalidMaxLockRetriesValue ¶

type InvalidMaxLockRetriesValue struct {
	ValidationErr error
}

func (*InvalidMaxLockRetriesValue) Error ¶

func (err *InvalidMaxLockRetriesValue) Error() string

type ItemDoesNotExist ¶ added in v0.9.3

type ItemDoesNotExist struct {
	ItemId     string
	TableName  string
	Underlying error
}

func (ItemDoesNotExist) Error ¶ added in v0.9.3

func (err ItemDoesNotExist) Error() string

type TableActiveRetriesExceeded ¶

type TableActiveRetriesExceeded struct {
	TableName string
	Retries   int
}

func (TableActiveRetriesExceeded) Error ¶

func (err TableActiveRetriesExceeded) Error() string

type TableDoesNotExist ¶ added in v0.9.3

type TableDoesNotExist struct {
	TableName  string
	Underlying error
}

func (TableDoesNotExist) Error ¶ added in v0.9.3

func (err TableDoesNotExist) Error() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL