Add a little sketch of how BatchTransformationFunction fits in

snowplow · May 24, 2024 · a2789b0 · a2789b0
1 parent b41c83f
commit a2789b0
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/cmd/cli/cli.go b/cmd/cli/cli.go
@@ -241,7 +241,15 @@ func sourceWriteFunc(t targetiface.Target, ft failureiface.Failure, tr transform
 		messageBatches := []*models.TargetBatch{
 			&models.TargetBatch{
 				OriginalMessages: messagesToSend,
-				HTTPRequestBody:  nil}}
+				HTTPRequestBody:  nil},
+		}
+
+		BatchTransformationFunction := func(b []*models.TargetBatch) []*models.TargetBatch {
+
+			// imaine this is composable like transformaion functions, and does something :D
+			return b
+		}
+		messageBatches = BatchTransformationFunction(messageBatches)
 
 		res, err := retry.ExponentialWithInterface(5, time.Second, "target.Write", func() (interface{}, error) {
 			res, err := t.Write(messageBatches)