dynamodb

Documentation

Index

• type DeleteItemAPI
• type DynamoDBClient
  • func GetClient(inputTableName string, region string) DynamoDBClient
  • func GetClientWithTimeout(inputTableName string, region string, timeout time.Duration) DynamoDBClient
• type GetItemAPI
• type PrimaryKey
• type PutItemAPI
• type QueryAPI
• type ScanAPI
• type TransactWriteItemsAPI
• type UpdateItemAPI

Types

type DeleteItemAPI

type DeleteItemAPI interface {
	DeleteItem(key PrimaryKey) (*dynamodb.DeleteItemOutput, error)
}

type DynamoDBClient

type DynamoDBClient interface {
	DeleteItemAPI
	GetItemAPI
	PutItemAPI
	UpdateItemAPI
	QueryAPI
	TransactWriteItemsAPI
	ScanAPI
}

func GetClient

func GetClient(inputTableName string, region string) DynamoDBClient

func GetClientWithTimeout

func GetClientWithTimeout(inputTableName string, region string, timeout time.Duration) DynamoDBClient

type GetItemAPI

type GetItemAPI interface {
	GetItem(key PrimaryKey, consistentRead bool) (*dynamodb.GetItemOutput, error)
}

type PrimaryKey

type PrimaryKey struct {
	PartitionKey string `dynamodbav:"PK"`
	SortKey      string `dynamodbav:"SK"`
}

type PutItemAPI

type PutItemAPI interface {
	PutItem(item interface{}) (*dynamodb.PutItemOutput, error)
}

type QueryAPI

type QueryAPI interface {
	Query(input *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)
}

type ScanAPI

type ScanAPI interface {
	Scan(in *dynamodb.ScanInput) (*dynamodb.ScanOutput, error)
}

type TransactWriteItemsAPI

type TransactWriteItemsAPI interface {
	TransactWriteItems(items []types.TransactWriteItem, idempotencyToken *string) (*dynamodb.TransactWriteItemsOutput, error)
	CreateTransactPutItem(item interface{}) (*types.TransactWriteItem, error)
	CreateTransactUpdateItem(key PrimaryKey, item interface{}) (*types.TransactWriteItem, error)
	CreateTransactDeleteItem(key PrimaryKey) (*types.TransactWriteItem, error)
}

type UpdateItemAPI

type UpdateItemAPI interface {
	UpdateItem(key PrimaryKey, item interface{}) (*dynamodb.UpdateItemOutput, error)
}