awsdynamodb

Documentation

Index

• func NewClient(useTracing bool) *dynamodb.Client
• func QueryTable[T any](ctx context.Context, tablename string, client DynamoDBQueryTableApi, ...) []T
• func ReadAllTableData[T any](ctx context.Context, tablename string, client DynamoDBScanTableAPI) []T
• func UpdateTableItem(ctx context.Context, tablename string, client DynamoDBUpdateItemApi, ...) (*dynamodb.UpdateItemOutput, error)
• type DynamoDBDescribeTableAPI
• type DynamoDBQueryTableApi
• type DynamoDBScanTableAPI
• type DynamoDBUpdateItemApi

Functions

func NewClient

func NewClient(useTracing bool) *dynamodb.Client

func QueryTable

func QueryTable[T any](ctx context.Context, tablename string, client DynamoDBQueryTableApi, keys map[string]any) []T

func ReadAllTableData

func ReadAllTableData[T any](ctx context.Context, tablename string, client DynamoDBScanTableAPI) []T

func UpdateTableItem

func UpdateTableItem(ctx context.Context, tablename string, client DynamoDBUpdateItemApi, key map[string]any, values map[string]any) (*dynamodb.UpdateItemOutput, error)

Types

type DynamoDBDescribeTableAPI

type DynamoDBDescribeTableAPI interface {
	DescribeTable(ctx context.Context,
		params *dynamodb.DescribeTableInput,
		optFns ...func(*dynamodb.Options)) (*dynamodb.DescribeTableOutput, error)
}

type DynamoDBQueryTableApi

type DynamoDBQueryTableApi interface {
	Query(ctx context.Context,
		params *dynamodb.QueryInput,
		optFns ...func(*dynamodb.Options)) (*dynamodb.QueryOutput, error)
}

type DynamoDBScanTableAPI

type DynamoDBScanTableAPI interface {
	Scan(ctx context.Context,
		params *dynamodb.ScanInput,
		optFns ...func(*dynamodb.Options)) (*dynamodb.ScanOutput, error)
}

type DynamoDBUpdateItemApi

type DynamoDBUpdateItemApi interface {
	UpdateItem(ctx context.Context,
		params *dynamodb.UpdateItemInput,
		optFns ...func(*dynamodb.Options)) (*dynamodb.UpdateItemOutput, error)
}