Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dynamodb

package

Go to main page

Versions in this module

v0

v0.0.3

Mar 4, 2024

v0.0.2

Feb 6, 2024

Changes in this version

+ const GIDAttribute

+ const TraceIDAttribute

+ const VerAttribute

+ var ErrTxInvalidItemType = errors.New("invalid transaction item type")

+ func IsConditionCheckFailureWithItem(err error, hashKey, rangeKey string) (bool, bool)

+ func UnpackRecord(ctx context.Context, r Record, serializer event.Serializer) ([]event.Envelope, error)

type Item

+ TraceID string

type Record

+ func (rec Record) Keys() map[string]string

type Session

+ func (s *Session) AddToTx(ctx context.Context, ops []any) error

+ func (s *Session) ConsumedCapacity() *consumedCapacity

type StoreConfig

+ AppendEventOptions []func(*event.AppendConfig)

+ RecordSizeLimit int

v0.0.1

Dec 18, 2023

Changes in this version

+ const EventSizeLimit

+ const GVerAttribute

+ const HashKey

+ const LocalIndex

+ const LocalIndexRangeKey

+ const RangeKey

+ const TTLAttribute

+ var ErrIndexingRecordFailed = errors.New("indexing record failed")

+ var ErrTxAlreadyStarted = errors.New("transaction already started")

+ func ContextWithSession(ctx context.Context, s Session) context.Context

+ func CreateTable(ctx context.Context, svc AdminAPI, table string) error

+ func DeleteTable(ctx context.Context, svc AdminAPI, table string) error

+ func IsConditionCheckFailure(err error) bool

+ func NewIndexer(dbsvc ClientAPI, table string, opts ...func(cfg *IndexerConfig)) *indexer

+ func UnmarshalRecord(ctx context.Context, r Record, serializer event.Serializer) ([]event.Envelope, error)

+ type AdminAPI interface

+ CreateTable func(ctx context.Context, params *dynamodb.CreateTableInput, ...) (*dynamodb.CreateTableOutput, error)

+ DeleteTable func(ctx context.Context, params *dynamodb.DeleteTableInput, ...) (*dynamodb.DeleteTableOutput, error)

+ UpdateTimeToLive func(ctx context.Context, params *dynamodb.UpdateTimeToLiveInput, ...) (*dynamodb.UpdateTimeToLiveOutput, error)

+ type ClientAPI interface

+ DeleteItem func(ctx context.Context, params *dynamodb.DeleteItemInput, ...) (*dynamodb.DeleteItemOutput, error)

+ GetItem func(ctx context.Context, params *dynamodb.GetItemInput, ...) (*dynamodb.GetItemOutput, error)

+ PutItem func(ctx context.Context, params *dynamodb.PutItemInput, ...) (*dynamodb.PutItemOutput, error)

+ TransactWriteItems func(ctx context.Context, params *dynamodb.TransactWriteItemsInput, ...) (*dynamodb.TransactWriteItemsOutput, error)

+ UpdateItem func(ctx context.Context, params *dynamodb.UpdateItemInput, ...) (*dynamodb.UpdateItemOutput, error)

+ func NewClient(cfg aws.Config) ClientAPI

+ type ContextKey string

+ type Indexer interface

+ Index func(ctx context.Context, rec Record) (err error)

+ type IndexerConfig struct

+ type Item struct

+ HashKey string

+ LSIRangeKey string

+ RangeKey string

+ TTL int64

+ type Record struct

+ Events []byte

+ GID string

+ GVersion string

+ Since int64

+ Until int64

+ Version string

+ type Session interface

+ Check func(ctx context.Context, c *types.ConditionCheck) error

+ CloseTx func() error

+ CommitTx func(ctx context.Context) error

+ Delete func(ctx context.Context, d *dynamodb.DeleteItemInput) error

+ HasTx func() bool

+ Put func(ctx context.Context, p *dynamodb.PutItemInput) error

+ StartTx func() error

+ Update func(ctx context.Context, u *dynamodb.UpdateItemInput) error

+ func NewSession(db ClientAPI) Session

+ func SessionFrom(ctx context.Context) (Session, bool)

+ type Store struct

+ func NewEventStore(svc ClientAPI, table string, opts ...func(*StoreConfig)) *Store

+ func (s *Store) Append(ctx context.Context, id event.StreamID, events []event.Envelope, ...) error

+ func (s *Store) AppendToStream(ctx context.Context, stm sourcing.Stream, ...) (err error)

+ func (s *Store) Load(ctx context.Context, id event.StreamID, trange ...time.Time) ([]event.Envelope, error)

+ func (s *Store) LoadStream(ctx context.Context, id event.StreamID, vrange ...event.Version) (stm *sourcing.Stream, err error)

+ func (s *Store) Replay(ctx context.Context, id event.StreamID, q event.StreamerQuery, ...) error

+ type StoreConfig struct

+ Serializer event.Serializer