dynamodb

Documentation

Index

• Constants
• func FixPaginationLimit(limit *int64) *int64
• func MarshallDynamodbAttribute(attribute interface{}) *dynamodb.AttributeValue
• func MarshallDynamodbItem(record interface{}) map[string]*dynamodb.AttributeValue
• func NewDefaultDynamodbCounterStore(awsFactory factory.AwsFactory) model.AwsCounterStore
• func NewDefaultDynamodbEventStore(awsFactory factory.AwsFactory) model.AwsEventStore
• func NewDefaultDynamodbStateStore(awsFactory factory.AwsFactory) model.AwsStateStore
• func NewDynamodbCounterStore(counterStoreTableName string, dynamodbClient dynamodbiface.DynamoDBAPI) model.AwsCounterStore
• func NewDynamodbEventStore(eventStoreTable string, eventStoreIndexByTime string, ...) model.AwsEventStore
• func NewDynamodbStateStore(eventStoreTableName string, stateStoreTableName string, ...) model.AwsStateStore
• func UnmarshallDynamodbItem(item map[string]*dynamodb.AttributeValue, record interface{})
• func UnmarshallDynamodbItemList(items []map[string]*dynamodb.AttributeValue, records interface{})
• func UnmarshallDynamodbStreamItem(item map[string]events.DynamoDBAttributeValue, record interface{})

Constants

const DefaultPaginationLimit = 20

const MaxPaginationLimit = 100

const MinPaginationLimit = 1

Functions

func FixPaginationLimit

func FixPaginationLimit(limit *int64) *int64

func MarshallDynamodbAttribute

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

func MarshallDynamodbItem

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

func NewDefaultDynamodbCounterStore

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

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{})