syntax = "proto3";

package dfs.db;
option go_package = "cnlab.net/csst/proto/db";
import "common/error.proto";

service DBSrv {
	rpc Find(FindReq) returns (stream FindResp) {}
	rpc Get(GetReq) returns (GetResp) {}
	rpc Write(WriteReq) returns (WriteResp) {}
	rpc WriteStream(stream WriteStreamReq) returns (WriteResp) {}
	rpc Update(UpdateReq) returns (UpdateResp) {}	
}

message FindReq {
	map<string,string> conditions = 1;
}

message FindResp {
	bool success = 1;
	int32 totalCount = 2;
	common.Error error = 3;
	bytes records = 4;
}
message GetReq {
	map<string,string> conditions = 1;	
}
message GetResp {
	repeated string columns = 1;
	bytes record = 2;
}
message WriteReq {
	map<string,string> conditions = 1;
}
message WriteStreamReq {
	map<string,string> conditions = 1;
	bytes data = 2;
}

message WriteResp {
	bool success = 1;
	common.Error error = 2;
	repeated string columns = 3;
	bytes record = 4;
}
message UpdateReq {
	map<string,string> conditions = 1;
}
message UpdateResp {
	bool success = 1;
	common.Error error = 2;
}