syntax = "proto3";

package bilibili.vega.deneb.v1;

option java_multiple_files = true;

import "google/protobuf/any.proto";

//
service VegaDenebRPC {
  //
  rpc MessagePulls (MessagePullsReq) returns (MessagePullsReply);
}

//
message MessagePullsReply {
  //
  repeated google.protobuf.Any data = 1;
  //
  int32 pn = 2;
  //
  int32 ps = 3;
  //
  int64 count = 4;
  //
  bool has_next = 5;
}

//
message MessagePullsReq {
  //
  int64 start_seq_id = 1;
  //
  int64 end_seq_id = 2;
  //
  int32 pn = 3;
  //
  int32 ps = 4;
}

