dynamodb

Documentation

Index

• func DynamoDB(region, endpoint string) (*dynamodb.DynamoDB, error)
• func New(dynamodb *d.DynamoDB, tableName string, options ...StoreOption) eventing.Store
• type StoreOption
  • func WithHashKey(hashKey string) StoreOption
  • func WithRangeKey(rangeKey string) StoreOption
  • func WithRecordsPerPartition(records int) StoreOption

Functions

func DynamoDB

func DynamoDB(region, endpoint string) (*dynamodb.DynamoDB, error)

func New

func New(dynamodb *d.DynamoDB, tableName string, options ...StoreOption) eventing.Store

New returns a new event store

Types

type StoreOption

type StoreOption func(s *store)

StoreOption applies an optional configuration to the Store

func WithHashKey

func WithHashKey(hashKey string) StoreOption

WithHashKey sets the hash key

func WithRangeKey

func WithRangeKey(rangeKey string) StoreOption

WithRangeKey sets the range key

func WithRecordsPerPartition

func WithRecordsPerPartition(records int) StoreOption

WithRecordsPerPartition sets the number of records in a partition