Skip to content

gRPC method for proton ingest api #941

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
rauanmayemir opened this issue May 6, 2025 · 0 comments
Open

gRPC method for proton ingest api #941

rauanmayemir opened this issue May 6, 2025 · 0 comments
Assignees
Labels

Comments

@rauanmayemir
Copy link

Use case

Proton ingesting is built as http rest api, implementing a grpc endpoint would help somewhat safely lift data type limitations.
Even though proton has grpc protocol, it's tuned for querying the data, but not for ingesting.

Describe the solution you'd like

Extra method definition in proton.grpc.Proton service, something like:

// Based on WKT's google.protobuf.Struct
enum NullValue {
  // Null value.
  NULL_VALUE = 0;
}

message ArrayValue {
  repeated DataType values = 1;
}

message MapValue {
  map<string, DataType> values = 1;
}

message DataType {
  oneof kind {
    NullValue null_value = 1;
    // Automatic cast to smaller sizes
    int64 int_value = 2;
    // Automatic cast to smaller sizes
    uint64 uint_value = 3;
    // For decimal and float
    double double_value = 4;
    bool bool_value = 5;
    string string_value = 6;
    // Cast to string on the ingest side
    bytes bytes_value = 7;
    ArrayValue array_value = 8;
    MapValue map_value = 9;
  }
}

message IngestInfo {
  repeated string columns = 1;
  repeated ArrayValue data = 2;
}

service Proton {
  // ...
  rpc ExecuteIngest(IngestInfo) returns (Result) {}
  rpc ExecuteIngestWithStreamIO(stream IngestInfo) returns (stream Result) {}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants