dynamodb

package
v1.19.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 18, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

Package dynamodb implements the messaging.Store interface on top of DynamoDB.

Each account is a bin (partition); each message is one item within it:

pk = "<account>"   sk = "<message-id>"   message = <bytes>

Insert is a conditional Put (so a duplicate message ID in the bin fails), Delete is an idempotent DeleteItem, and Get is a single Query over the bin's partition.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateTables

func CreateTables(ctx context.Context, client *dynamodb.Client, table string) error

CreateTables provisions the messaging table with on-demand billing, keyed by (pk, sk) with no secondary indexes. It is idempotent: a table that already exists is left as-is. The call blocks until the table is ACTIVE.

func New

func New(client *dynamodb.Client, table string) messaging.Store

New returns a messaging.Store backed by the given DynamoDB table. Use CreateTables to provision it.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL