dynamodb

package
v0.16.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 8, 2022 License: MIT Imports: 19 Imported by: 2

Documentation

Index

Constants

View Source
const DefaultPaginationLimit = 20
View Source
const MaxPaginationLimit = 100
View Source
const MinPaginationLimit = 1

Variables

This section is empty.

Functions

func FixPaginationLimit added in v0.9.0

func FixPaginationLimit(limit *int64) *int64

func MarshallDynamodbAttribute added in v0.9.0

func MarshallDynamodbAttribute(attribute interface{}) *dynamodb.AttributeValue

func MarshallDynamodbItem

func MarshallDynamodbItem(record interface{}) map[string]*dynamodb.AttributeValue

func NewDefaultDynamodbCounterStore added in v0.12.0

func NewDefaultDynamodbCounterStore(awsFactory factory.AwsFactory) model.AwsCounterStore

func NewDefaultDynamodbEventStore

func NewDefaultDynamodbEventStore(awsFactory factory.AwsFactory) model.AwsEventStore

func NewDefaultDynamodbStateStore

func NewDefaultDynamodbStateStore(awsFactory factory.AwsFactory) model.AwsStateStore

func NewDynamodbCounterStore added in v0.12.0

func NewDynamodbCounterStore(
	counterStoreTableName string,
	dynamodbClient dynamodbiface.DynamoDBAPI) model.AwsCounterStore

func NewDynamodbEventStore

func NewDynamodbEventStore(
	eventStoreTable string,
	eventStoreIndexByTime string,
	eventStoreIndexByDay string,
	eventStoreIndexByType string,
	eventStoreIndexByAuthor string,
	eventStoreIndexByTransaction string,
	controlStoreTable string,
	dynamodbClient dynamodbiface.DynamoDBAPI) model.AwsEventStore

func NewDynamodbStateStore

func NewDynamodbStateStore(
	eventStoreTableName string,
	stateStoreTableName string,
	stateStoreIndexByTime string,
	dynamodbClient dynamodbiface.DynamoDBAPI) model.AwsStateStore

func UnmarshallDynamodbItem

func UnmarshallDynamodbItem(item map[string]*dynamodb.AttributeValue, record interface{})

func UnmarshallDynamodbItemList

func UnmarshallDynamodbItemList(items []map[string]*dynamodb.AttributeValue, records interface{})

func UnmarshallDynamodbStreamItem

func UnmarshallDynamodbStreamItem(item map[string]events.DynamoDBAttributeValue, record interface{})

Types

This section is empty.

Jump to

Keyboard shortcuts

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