dynamo

Documentation

Index

• func BySequenceID(value string) eventsource.QueryOption
• func ByTimestamp(value string) eventsource.QueryOption
• func ByType(value string) eventsource.QueryOption
• func New(db *dynamodb.Client, tableName string) eventsource.Store
• func WithIndex(indexName string) eventsource.QueryOption
• func WithLimit(limit int32) eventsource.QueryOption

Functions

func BySequenceID

func BySequenceID(value string) eventsource.QueryOption

BySequenceID will set filter to only return records with sequence id greater than value

func ByTimestamp

func ByTimestamp(value string) eventsource.QueryOption

ByTimestamp will set filter to only return records with timestamp greater than value

func ByType

func ByType(value string) eventsource.QueryOption

ByType will set filter to only return records with type equal to value

func New

func New(db *dynamodb.Client, tableName string) eventsource.Store

New creates a new event source store

func WithIndex

func WithIndex(indexName string) eventsource.QueryOption

WithIndex will query on an index instead of primarykey

func WithLimit

func WithLimit(limit int32) eventsource.QueryOption

WithLimit will limit the result