stream

package
v0.0.0-...-c8cee03 Latest Latest
Warning

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

Go to latest
Published: Dec 2, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package stream provides DynamoDB Streams handlers for cascade operations.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertStreamKey

func ConvertStreamKey(streamKey map[string]events.DynamoDBAttributeValue) store.PK

ConvertStreamKey converts a DynamoDB stream key to a store.PK. Use this when you need to convert keys from stream records to store operations.

Types

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

Handler processes DynamoDB stream events for cascade deletes.

func NewHandler

func NewHandler(s *store.Store, logger *slog.Logger) *Handler

NewHandler creates a new stream handler.

func (*Handler) HandleCascadeDelete

func (h *Handler) HandleCascadeDelete(ctx context.Context, event events.DynamoDBEvent) error

HandleCascadeDelete processes DynamoDB stream events to propagate TTL to children. This function is designed to be used as an AWS Lambda handler.

Jump to

Keyboard shortcuts

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