dynamodb

Documentation

Index

• func MarshallDynamodbItem(record interface{}) map[string]*dynamodb.AttributeValue
• func NewDefaultDynamodbEventStore(awsFactory factory.AwsFactory) model.AwsEventStore
• func NewDefaultDynamodbStateStore(awsFactory factory.AwsFactory) model.AwsStateStore
• func NewDynamodbEventStore(eventStoreTable string, controlStoreTable string, ...) model.AwsEventStore
• func NewDynamodbStateStore(stateStoreTable string, dynamodbClient dynamodbiface.DynamoDBAPI) 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{})

Functions

func MarshallDynamodbItem

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

func NewDefaultDynamodbEventStore

func NewDefaultDynamodbEventStore(awsFactory factory.AwsFactory) model.AwsEventStore

func NewDefaultDynamodbStateStore

func NewDefaultDynamodbStateStore(awsFactory factory.AwsFactory) model.AwsStateStore

func NewDynamodbEventStore

func NewDynamodbEventStore(
	eventStoreTable string,
	controlStoreTable string,
	dynamodbClient dynamodbiface.DynamoDBAPI) model.AwsEventStore

func NewDynamodbStateStore

func NewDynamodbStateStore(
	stateStoreTable 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{})