Revert "Changes to interfaces (#32)"

This reverts commit 0a8c978.

common.proto

@@ -53,6 +53,7 @@ message TestResponse {
   oneof response {
     bool success = 1;
     string failure = 2;
+    // potential future warning
   }
 }
 
@@ -78,13 +79,14 @@ enum DataType {
   DECIMAL = 5;
   FLOAT = 6;
   DOUBLE = 7;
-  NAIVE_DATE = 8;
-  NAIVE_DATETIME = 9;
-  UTC_DATETIME = 10;
-  BINARY = 11;
-  XML = 12;
-  STRING = 13;
-  JSON = 14;
+  NAIVE_TIME = 8;
+  NAIVE_DATE = 9;
+  NAIVE_DATETIME = 10;
+  UTC_DATETIME = 11;
+  BINARY = 12;
+  XML = 13;
+  STRING = 14;
+  JSON = 15;
 }
 
 message DecimalParams {
@@ -108,14 +110,15 @@ message ValueType {
     int64 long = 5;
     float float = 6;
     double double = 7;
-    google.protobuf.Timestamp naive_date = 8;
-    google.protobuf.Timestamp naive_datetime = 9;
-    google.protobuf.Timestamp utc_datetime = 10;
-    string decimal = 11;
-    bytes binary = 12;
-    string string = 13;
-    string json = 14;
-    string xml = 15;
+    google.protobuf.Timestamp naive_time = 8;
+    google.protobuf.Timestamp naive_date = 9;
+    google.protobuf.Timestamp naive_datetime = 10;
+    google.protobuf.Timestamp utc_datetime = 11;
+    string decimal = 12;
+    bytes binary = 13;
+    string string = 14;
+    string json = 15;
+    string xml = 16;
   }
 }
 

connector_sdk.proto

@@ -106,4 +106,4 @@ message Record {
 
 message Checkpoint {
     string state_json = 1;
-}
+}

destination_sdk.proto

@@ -10,7 +10,6 @@ import "common.proto";
 // Fivetran (grpc client) <> Destination (grpc server)
 service Destination {
     rpc ConfigurationForm (ConfigurationFormRequest) returns (ConfigurationFormResponse) {}
-    rpc Capabilities (CapabilitiesRequest) returns (CapabilitiesResponse) {}
     rpc Test (TestRequest) returns (TestResponse) {}
     rpc DescribeTable (DescribeTableRequest) returns (DescribeTableResponse) {}
     rpc CreateTable(CreateTableRequest) returns (CreateTableResponse) {}
@@ -19,12 +18,6 @@ service Destination {
     rpc WriteBatch (WriteBatchRequest) returns (WriteBatchResponse) {}
 }
 
-message CapabilitiesRequest {}
-
-message CapabilitiesResponse {
-    BatchFileFormat batch_file_format = 1;
-}
-
 message DescribeTableRequest {
     map<string, string> configuration = 1;
     string schema_name = 2;
@@ -95,7 +88,6 @@ message WriteBatchRequest {
     repeated string delete_files = 7;
     oneof file_params {
         CsvFileParams csv = 8;
-        ParquetFileParams parquet = 9;
     }
 }
 
@@ -106,20 +98,11 @@ message CsvFileParams {
     string unmodified_string = 4;
 }
 
-message ParquetFileParams {
-    Encryption encryption = 1;
-}
-
 enum Encryption {
     NONE = 0;
     AES = 1;
 }
 
-enum BatchFileFormat {
-    CSV = 0;
-    PARQUET = 1;
-}
-
 enum Compression {
     OFF = 0;
     ZSTD = 1;
@@ -131,4 +114,4 @@ message WriteBatchResponse {
         bool success = 1;
         string failure = 2;
     }
-}
+}