dynamolayer

Documentation

Index

• Constants
• func NewDynamoDBLayerByRegion(region string) (persistence.DatabaseHandler, error)
• func NewDynamoDBLayerBySession(sess *session.Session) persistence.DatabaseHandler
• type DynamoDBLayer
  • func (dynamoLayer *DynamoDBLayer) AddEvent(event persistence.Event) ([]byte, error)
  • func (dynamoLayer *DynamoDBLayer) FindAllAvailableEvents() ([]persistence.Event, error)
  • func (dynamoLayer *DynamoDBLayer) FindEvent(id []byte) (persistence.Event, error)
  • func (dynamoLayer *DynamoDBLayer) FindEventByName(name string) (persistence.Event, error)

Constants

const (
	EVENTS = "events"
)

Functions

func NewDynamoDBLayerByRegion

func NewDynamoDBLayerByRegion(region string) (persistence.DatabaseHandler, error)

func NewDynamoDBLayerBySession

func NewDynamoDBLayerBySession(sess *session.Session) persistence.DatabaseHandler

Types

type DynamoDBLayer

type DynamoDBLayer struct {
	// contains filtered or unexported fields
}

func (*DynamoDBLayer) AddEvent

func (dynamoLayer *DynamoDBLayer) AddEvent(event persistence.Event) ([]byte, error)

func (*DynamoDBLayer) FindAllAvailableEvents

func (dynamoLayer *DynamoDBLayer) FindAllAvailableEvents() ([]persistence.Event, error)

func (*DynamoDBLayer) FindEvent

func (dynamoLayer *DynamoDBLayer) FindEvent(id []byte) (persistence.Event, error)

func (*DynamoDBLayer) FindEventByName

func (dynamoLayer *DynamoDBLayer) FindEventByName(name string) (persistence.Event, error)