task-processor/proto/taskTransport.proto

syntax = "proto3";
import "google/protobuf/empty.proto";

package taskTransport;
option go_package = "/pkg/taskTransport/v1;taskTransportV1";


message Task{
  string merch_uuid = 1;
  map<string, string> origins = 2;
}

message Result{
  string merch_uuid = 1;
  string origin_name = 2;
  int32 price = 3;
}

service TaskProcessor {
  rpc RequestTasks(google.protobuf.Empty) returns (stream Task);
  rpc SendResults(stream Result) returns (google.protobuf.Empty);
}