Add B and BS.

artie-labs · Aug 6, 2024 · 10de05c · 10de05c
1 parent 11f54f9
commit 10de05c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/dynamo/snapshot_message.go b/lib/dynamo/snapshot_message.go
@@ -11,6 +11,10 @@ func convertSnapshotToStreamingAttribute(attr ddbTypes.AttributeValue) types.Att
 		return &types.AttributeValueMemberS{Value: v.Value}
 	case *ddbTypes.AttributeValueMemberN:
 		return &types.AttributeValueMemberN{Value: v.Value}
+	case *ddbTypes.AttributeValueMemberB:
+		return &types.AttributeValueMemberB{Value: v.Value}
+	case *ddbTypes.AttributeValueMemberBS:
+		return &types.AttributeValueMemberBS{Value: v.Value}
 	case *ddbTypes.AttributeValueMemberBOOL:
 		return &types.AttributeValueMemberBOOL{Value: v.Value}
 	case *ddbTypes.AttributeValueMemberM: