batch

type BatchDeleteResult struct {
	TotalItems     int
	ProcessedItems int
	FailedItems    int
	Errors         []BatchError
	Duration       time.Duration
	ConsumedWCU    int64
}

type BatchDeleter struct {
	*Processor
}

type BatchDeleterConfig struct {
	BatchSize int
	Logger    *zap.Logger
	Tracker   CostTracker
}

type BatchError struct {
	Index int
	Item  any
	Error error
}

type BatchMessage struct {
	Operation string         `json:"operation"` // "create", "update", "delete"
	Items     []any          `json:"items"`
	TableName string         `json:"table_name,omitempty"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type BatchReadResult struct {
	TotalKeys      int
	RetrievedItems int
	NotFoundItems  int
	Errors         []BatchError
	Duration       time.Duration
	ConsumedRCU    int64
}

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

type BatchReaderConfig struct {
	BatchSize int
	Logger    *zap.Logger
	Tracker   CostTracker
}

type BatchWriteResult struct {
	TotalItems     int
	ProcessedItems int
	FailedItems    int
	Errors         []BatchError
	Duration       time.Duration
	ConsumedWCU    int64
}

type BatchWriter struct {
	*Processor
}

type BatchWriterConfig struct {
	BatchSize int
	Logger    *zap.Logger
	Tracker   CostTracker
}

type BatchWriterWithProgress struct {
	*BatchWriter
	// contains filtered or unexported fields
}

type CostMetrics struct {
	DynamoDBReads  int64
	DynamoDBWrites int64
}

type CostTracker interface {
	// CalculateCost returns the current cost metrics
	CalculateCost() CostMetrics
	// TrackDynamoWrite tracks DynamoDB write operations
	TrackDynamoWrite(items int)
	// TrackDynamoRead tracks DynamoDB read operations
	TrackDynamoRead(items int)
}

type Operation int

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

type ProcessorConfig struct {
	BatchSize int
	Logger    *zap.Logger
	Tracker   CostTracker
	Operation Operation
}

type ProgressCallback func(total, processed, failed int64)

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

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

type SQSBatchProcessorConfig struct {
	Logger       *zap.Logger
	Tracker      CostTracker
	MaxBatchSize int // Maximum items to process in a single batch (default: 25)
}