aws

Documentation

Index

• Constants
• type DynamoDBClient
• type DynamoDbLock
  • func (dynamoDbLock *DynamoDbLock) GetLock(lockId string) (*int, error)
  • func (dynamoDbLock *DynamoDbLock) Lock(transactionId int, resource string) (bool, error)
  • func (dynamoDbLock *DynamoDbLock) Unlock(resource string) (bool, error)

Constants

const (
	TABLE_NAME              = "DiggerDynamoDBLockTable"
	TableCreationInterval   = 1 * time.Second
	TableCreationRetryCount = 10
	TableLockTimeout        = 60 * 60 * 24 * 90 * time.Second
)

Types

type DynamoDBClient

type DynamoDBClient interface {
	DescribeTable(ctx context.Context, params *dynamodb.DescribeTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeTableOutput, error)
	CreateTable(ctx context.Context, params *dynamodb.CreateTableInput, optFns ...func(*dynamodb.Options)) (*dynamodb.CreateTableOutput, error)
	UpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateItemOutput, error)
	DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteItemOutput, error)
	GetItem(ctx context.Context, params *dynamodb.GetItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.GetItemOutput, error)
}

type DynamoDbLock

type DynamoDbLock struct {
	DynamoDb DynamoDBClient
}

func (*DynamoDbLock) GetLock

func (dynamoDbLock *DynamoDbLock) GetLock(lockId string) (*int, error)

func (*DynamoDbLock) Lock

func (dynamoDbLock *DynamoDbLock) Lock(transactionId int, resource string) (bool, error)

func (*DynamoDbLock) Unlock

func (dynamoDbLock *DynamoDbLock) Unlock(resource string) (bool, error)