From 38661cde644ee1e6f92ba34de34515266a90d533 Mon Sep 17 00:00:00 2001
From: Mariano Gappa <spinetta@gmail.com>
Date: Tue, 30 Jul 2024 15:10:12 +0100
Subject: [PATCH] feat: Add TransformSchema message. (#24)

---
 plugin/v3/plugin.proto | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/plugin/v3/plugin.proto b/plugin/v3/plugin.proto
index 55484a8..8cbddcf 100644
--- a/plugin/v3/plugin.proto
+++ b/plugin/v3/plugin.proto
@@ -29,6 +29,8 @@ service Plugin {
   rpc Write(stream Write.Request) returns (Write.Response);
   // Transform resources.
   rpc Transform(stream Transform.Request) returns (stream Transform.Response);
+  // Transform schemas.
+  rpc TransformSchema(stream TransformSchema.Request) returns (stream TransformSchema.Response);
   // Send signal to flush and close open connections
   rpc Close(Close.Request) returns (Close.Response);
   // Validate and test the connections used by the plugin
@@ -203,6 +205,17 @@ message Transform {
   }
 }
 
+message TransformSchema {
+  message Request {
+    // marshalled arrow.Schema
+    bytes schema = 1;
+  }
+  message Response {
+    // marshalled arrow.Schema
+    bytes schema = 1;
+  }
+}
+
 message Close {
   message Request {}
   message Response {}