theorydb

func AtVersion ¶

func AtVersion(version int64) core.TransactCondition

AtVersion enforces an optimistic locking check on the model's version field.

func Condition ¶

func Condition(field, operator string, value any) core.TransactCondition

Condition creates a simple field comparison condition for transactional writes.

func ConditionExpression ¶

func ConditionExpression(expression string, values map[string]any) core.TransactCondition

ConditionExpression registers a raw condition expression for transactional writes.

func ConditionVersion ¶

func ConditionVersion(version int64) core.TransactCondition

ConditionVersion is an alias for AtVersion for API parity with UpdateBuilder helpers.

func DefaultBatchGetOptions ¶

func DefaultBatchGetOptions() *core.BatchGetOptions

DefaultBatchGetOptions returns the library defaults for BatchGet operations.

func EnableXRayTracing ¶

func EnableXRayTracing() bool

EnableXRayTracing enables AWS X-Ray tracing for DynamoDB calls

func GetLambdaMemoryMB ¶

func GetLambdaMemoryMB() int

GetLambdaMemoryMB returns the allocated memory in MB

func GetPartnerFromContext ¶

func GetPartnerFromContext(ctx context.Context) string

GetPartnerFromContext retrieves partner ID from context

func GetRemainingTimeMillis ¶

func GetRemainingTimeMillis(ctx context.Context) int64

GetRemainingTimeMillis returns milliseconds until Lambda timeout

func IfExists ¶

func IfExists() core.TransactCondition

IfExists guards a write with attribute_exists on the item's primary key.

func IfNotExists ¶

func IfNotExists() core.TransactCondition

IfNotExists guards a write with attribute_not_exists on the item's primary key.

func IsLambdaEnvironment ¶

func IsLambdaEnvironment() bool

IsLambdaEnvironment detects if running in AWS Lambda

func New ¶

func New(config session.Config) (core.ExtendedDB, error)

New creates a new TableTheory instance with the given configuration

func NewBasic ¶

func NewBasic(config session.Config) (core.DB, error)

NewBasic creates a new TableTheory instance that returns the basic DB interface Use this when you only need core functionality and want easier mocking

func NewKeyPair ¶

func NewKeyPair(partitionKey any, sortKey ...any) core.KeyPair

NewKeyPair constructs a composite key helper for BatchGet operations.

func PartnerContext ¶

func PartnerContext(ctx context.Context, partnerID string) context.Context

PartnerContext adds partner information to context for tracing

func UnmarshalItem ¶

func UnmarshalItem(item map[string]types.AttributeValue, dest interface{}) error

UnmarshalItem unmarshals a DynamoDB AttributeValue map into a Go struct. This is the recommended way to unmarshal DynamoDB stream records or any DynamoDB items when using TableTheory.

The function respects TableTheory struct tags (theorydb:"pk", theorydb:"attr:name", etc.) and handles all DynamoDB attribute types correctly.

Example usage with DynamoDB Streams:

func processDynamoDBStream(record events.DynamoDBEventRecord) (*MyModel, error) {
    image := record.Change.NewImage
    if image == nil {
        return nil, nil
    }

    var model MyModel
    if err := theorydb.UnmarshalItem(image, &model); err != nil {
        return nil, fmt.Errorf("failed to unmarshal: %w", err)
    }

    return &model, nil
}

func UnmarshalItems ¶

func UnmarshalItems(items []map[string]types.AttributeValue, dest interface{}) error

UnmarshalItems unmarshals a slice of DynamoDB AttributeValue maps into a slice of Go structs. This is useful for batch operations or when processing multiple items from a query result.

func UnmarshalStreamImage ¶

func UnmarshalStreamImage(streamImage map[string]events.DynamoDBAttributeValue, dest interface{}) error

UnmarshalStreamImage unmarshals a DynamoDB stream image (from Lambda events) into a Go struct. This function handles the conversion from Lambda's events.DynamoDBAttributeValue to the standard types.AttributeValue and then unmarshals into your TableTheory model.

Example usage:

func handleStream(record events.DynamoDBEventRecord) error {
    var order Order
    if err := theorydb.UnmarshalStreamImage(record.Change.NewImage, &order); err != nil {
        return err
    }
    // Process order...
}