Adding split_column to vtgate API.

This commit is contained in:
Alain Jobart 2015-07-20 10:24:31 -07:00
Родитель 7755349b47
Коммит b7eac53a03
3 изменённых файлов: 26 добавлений и 17 удалений

Просмотреть файл

@ -986,10 +986,11 @@ func (m *RollbackResponse) GetError() *vtrpc.RPCError {
// SplitQueryRequest is the payload to SplitQuery // SplitQueryRequest is the payload to SplitQuery
type SplitQueryRequest struct { type SplitQueryRequest struct {
CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"`
Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"` Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"` Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
SplitCount int64 `protobuf:"varint,4,opt,name=split_count" json:"split_count,omitempty"` SplitColumn string `protobuf:"bytes,4,opt,name=split_column" json:"split_column,omitempty"`
SplitCount int64 `protobuf:"varint,5,opt,name=split_count" json:"split_count,omitempty"`
} }
func (m *SplitQueryRequest) Reset() { *m = SplitQueryRequest{} } func (m *SplitQueryRequest) Reset() { *m = SplitQueryRequest{} }

Просмотреть файл

@ -271,7 +271,8 @@ message SplitQueryRequest {
vtrpc.CallerID caller_id = 1; vtrpc.CallerID caller_id = 1;
string keyspace = 2; string keyspace = 2;
query.BoundQuery query = 3; query.BoundQuery query = 3;
int64 split_count = 4; string split_column = 4;
int64 split_count = 5;
} }
// SplitQueryResponse is the returned value from SplitQuery // SplitQueryResponse is the returned value from SplitQuery

Различия файлов скрыты, потому что одна или несколько строк слишком длинны