syntax = "proto3";
|
|
import "datarequest.proto";
|
import "dataresult.proto";
|
import "sqlwhere.proto";
|
@3@
|
|
package @0@;
|
|
message @1@ {
|
@2@
|
}
|
|
message @1@Table {
|
int32 ErrNo = 1;
|
string ErrData = 2;
|
string Name = 3;
|
int32 UpdateType = 4; //0.なし 1.Insert 2.Update
|
string Tag = 5;
|
bytes BeforeUpdate = 6;
|
bytes AfterUpdate = 7;
|
repeated @1@ Rows = 8;
|
}
|
|
service @1@Core {
|
rpc GetData (stream Pms.Data.DataRequest) returns (stream @1@Table);
|
rpc SetData (stream @1@Table) returns (stream Pms.Data.DataResult);
|
rpc Add (stream @1@) returns (stream Pms.Data.DataResult);
|
rpc Update (stream @1@) returns (stream Pms.Data.DataResult);
|
rpc Remove (stream Pms.Data.SqlWhere) returns (stream Pms.Data.DataResult);
|
}
|
