dynamodb

Documentation

Index

• func MarshallDynamodbItem(record interface{}) map[string]*dynamodb.AttributeValue
• func NewDefaultDynamodbEventStore(sessionFactory session.Factory) model.AwsEventStore
• func NewDefaultDynamodbStateStore(sessionFactory session.Factory) 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(sessionFactory session.Factory) model.AwsEventStore

func NewDefaultDynamodbStateStore

func NewDefaultDynamodbStateStore(sessionFactory session.Factory) 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{})