diff --git a/pkg/coprocessor/coprocessor.pb.go b/pkg/coprocessor/coprocessor.pb.go index 7e0b877ed..510cc83a7 100644 --- a/pkg/coprocessor/coprocessor.pb.go +++ b/pkg/coprocessor/coprocessor.pb.go @@ -47,7 +47,7 @@ func (m *KeyRange) Reset() { *m = KeyRange{} } func (m *KeyRange) String() string { return proto.CompactTextString(m) } func (*KeyRange) ProtoMessage() {} func (*KeyRange) Descriptor() ([]byte, []int) { - return fileDescriptor_coprocessor_5bbbaa90d99dd4df, []int{0} + return fileDescriptor_coprocessor_bb050dd0a1f23255, []int{0} } func (m *KeyRange) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -101,8 +101,10 @@ type Request struct { IsCacheEnabled bool `protobuf:"varint,5,opt,name=is_cache_enabled,json=isCacheEnabled,proto3" json:"is_cache_enabled,omitempty"` CacheIfMatchVersion uint64 `protobuf:"varint,6,opt,name=cache_if_match_version,json=cacheIfMatchVersion,proto3" json:"cache_if_match_version,omitempty"` // Any schema-ful storage to validate schema correctness if necessary. - SchemaVer int64 `protobuf:"varint,8,opt,name=schema_ver,json=schemaVer,proto3" json:"schema_ver,omitempty"` - IsTraceEnabled bool `protobuf:"varint,9,opt,name=is_trace_enabled,json=isTraceEnabled,proto3" json:"is_trace_enabled,omitempty"` + SchemaVer int64 `protobuf:"varint,8,opt,name=schema_ver,json=schemaVer,proto3" json:"schema_ver,omitempty"` + IsTraceEnabled bool `protobuf:"varint,9,opt,name=is_trace_enabled,json=isTraceEnabled,proto3" json:"is_trace_enabled,omitempty"` + // paging_size is 0 when it's disabled, otherwise, it should be a positive number. + PagingSize uint64 `protobuf:"varint,10,opt,name=paging_size,json=pagingSize,proto3" json:"paging_size,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` @@ -112,7 +114,7 @@ func (m *Request) Reset() { *m = Request{} } func (m *Request) String() string { return proto.CompactTextString(m) } func (*Request) ProtoMessage() {} func (*Request) Descriptor() ([]byte, []int) { - return fileDescriptor_coprocessor_5bbbaa90d99dd4df, []int{1} + return fileDescriptor_coprocessor_bb050dd0a1f23255, []int{1} } func (m *Request) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -204,6 +206,13 @@ func (m *Request) GetIsTraceEnabled() bool { return false } +func (m *Request) GetPagingSize() uint64 { + if m != nil { + return m.PagingSize + } + return 0 +} + type Response struct { Data github_com_pingcap_kvproto_pkg_sharedbytes.SharedBytes `protobuf:"bytes,1,opt,name=data,proto3,customtype=github.com/pingcap/kvproto/pkg/sharedbytes.SharedBytes" json:"data"` RegionError *errorpb.Error `protobuf:"bytes,2,opt,name=region_error,json=regionError" json:"region_error,omitempty"` @@ -229,7 +238,7 @@ func (m *Response) Reset() { *m = Response{} } func (m *Response) String() string { return proto.CompactTextString(m) } func (*Response) ProtoMessage() {} func (*Response) Descriptor() ([]byte, []int) { - return fileDescriptor_coprocessor_5bbbaa90d99dd4df, []int{2} + return fileDescriptor_coprocessor_bb050dd0a1f23255, []int{2} } func (m *Response) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -341,7 +350,7 @@ func (m *RegionInfo) Reset() { *m = RegionInfo{} } func (m *RegionInfo) String() string { return proto.CompactTextString(m) } func (*RegionInfo) ProtoMessage() {} func (*RegionInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_coprocessor_5bbbaa90d99dd4df, []int{3} + return fileDescriptor_coprocessor_bb050dd0a1f23255, []int{3} } func (m *RegionInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -408,7 +417,7 @@ func (m *BatchRequest) Reset() { *m = BatchRequest{} } func (m *BatchRequest) String() string { return proto.CompactTextString(m) } func (*BatchRequest) ProtoMessage() {} func (*BatchRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_coprocessor_5bbbaa90d99dd4df, []int{4} + return fileDescriptor_coprocessor_bb050dd0a1f23255, []int{4} } func (m *BatchRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -493,7 +502,7 @@ func (m *BatchResponse) Reset() { *m = BatchResponse{} } func (m *BatchResponse) String() string { return proto.CompactTextString(m) } func (*BatchResponse) ProtoMessage() {} func (*BatchResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_coprocessor_5bbbaa90d99dd4df, []int{5} + return fileDescriptor_coprocessor_bb050dd0a1f23255, []int{5} } func (m *BatchResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -667,6 +676,11 @@ func (m *Request) MarshalTo(dAtA []byte) (int, error) { } i++ } + if m.PagingSize != 0 { + dAtA[i] = 0x50 + i++ + i = encodeVarintCoprocessor(dAtA, i, uint64(m.PagingSize)) + } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } @@ -1025,6 +1039,9 @@ func (m *Request) Size() (n int) { if m.IsTraceEnabled { n += 2 } + if m.PagingSize != 0 { + n += 1 + sovCoprocessor(uint64(m.PagingSize)) + } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } @@ -1526,6 +1543,25 @@ func (m *Request) Unmarshal(dAtA []byte) error { } } m.IsTraceEnabled = bool(v != 0) + case 10: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field PagingSize", wireType) + } + m.PagingSize = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowCoprocessor + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.PagingSize |= (uint64(b) & 0x7F) << shift + if b < 0x80 { + break + } + } default: iNdEx = preIndex skippy, err := skipCoprocessor(dAtA[iNdEx:]) @@ -2529,58 +2565,59 @@ var ( ErrIntOverflowCoprocessor = fmt.Errorf("proto: integer overflow") ) -func init() { proto.RegisterFile("coprocessor.proto", fileDescriptor_coprocessor_5bbbaa90d99dd4df) } +func init() { proto.RegisterFile("coprocessor.proto", fileDescriptor_coprocessor_bb050dd0a1f23255) } -var fileDescriptor_coprocessor_5bbbaa90d99dd4df = []byte{ - // 788 bytes of a gzipped FileDescriptorProto +var fileDescriptor_coprocessor_bb050dd0a1f23255 = []byte{ + // 808 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x54, 0xcd, 0x6e, 0xdb, 0x46, 0x10, 0x0e, 0xf5, 0x4b, 0x0f, 0x25, 0x47, 0xd9, 0xb8, 0x29, 0x9b, 0xa2, 0xb6, 0xa0, 0x02, 0x85, 0xfa, 0x47, 0x23, 0x32, 0x90, 0xde, 0x72, 0x50, 0x6a, 0xa0, 0x46, 0xd3, 0xcb, 0x3a, 0xf0, 0x95, - 0x58, 0x2d, 0xc7, 0x24, 0x21, 0x9b, 0xcb, 0xee, 0xae, 0x05, 0xfb, 0x2d, 0x7a, 0xec, 0xa1, 0x0f, - 0xd0, 0x47, 0x09, 0x90, 0x4b, 0x8f, 0x45, 0x0f, 0x41, 0xe1, 0xbe, 0x41, 0x9f, 0xa0, 0xe0, 0x2c, - 0x29, 0xcb, 0x6e, 0x1b, 0xe4, 0x92, 0x13, 0x67, 0xbe, 0x19, 0x0e, 0x67, 0xe6, 0x9b, 0x8f, 0xf0, - 0x40, 0xaa, 0x52, 0x2b, 0x89, 0xc6, 0x28, 0x1d, 0x95, 0x5a, 0x59, 0xc5, 0x82, 0x0d, 0xe8, 0xf1, - 0x10, 0xb5, 0x56, 0xba, 0x5c, 0xb8, 0xd8, 0xe3, 0xe1, 0x72, 0xa5, 0x4b, 0xb9, 0x76, 0x77, 0x52, - 0x95, 0x2a, 0x32, 0xf7, 0x2b, 0xab, 0x46, 0xef, 0xeb, 0x0b, 0x63, 0xc9, 0xac, 0x81, 0xc1, 0x39, - 0x5a, 0xb1, 0x7e, 0x09, 0x4c, 0x29, 0x0a, 0x67, 0x4f, 0x66, 0xe0, 0x7f, 0x8f, 0x57, 0x5c, 0x14, - 0x29, 0xb2, 0x1d, 0xe8, 0x1a, 0x2b, 0xb4, 0x0d, 0xbd, 0xb1, 0x37, 0x1d, 0x70, 0xe7, 0xb0, 0x11, - 0xb4, 0xb1, 0x48, 0xc2, 0x16, 0x61, 0x95, 0x39, 0x79, 0xdd, 0x82, 0x3e, 0xc7, 0x1f, 0x2f, 0xd0, - 0x58, 0xf6, 0x05, 0xf4, 0xa5, 0x2a, 0x2c, 0x5e, 0xba, 0xb7, 0x82, 0xd9, 0x28, 0x6a, 0x3a, 0x7c, - 0xee, 0x70, 0xde, 0x24, 0xb0, 0x6d, 0x68, 0xd9, 0x92, 0x0a, 0xb5, 0x79, 0xcb, 0x96, 0x8c, 0x41, - 0x27, 0x11, 0x56, 0x84, 0x6d, 0x2a, 0x4d, 0x36, 0xfb, 0x1a, 0x7a, 0xba, 0x6a, 0xc6, 0x84, 0x9d, - 0x71, 0x7b, 0x1a, 0xcc, 0x3e, 0x88, 0x36, 0xf7, 0xd3, 0xb4, 0xca, 0xeb, 0x24, 0x36, 0x85, 0x51, - 0x6e, 0x62, 0x29, 0x64, 0x86, 0x31, 0x16, 0x62, 0x71, 0x86, 0x49, 0xd8, 0x1d, 0x7b, 0x53, 0x9f, - 0x6f, 0xe7, 0xe6, 0x79, 0x05, 0x1f, 0x3a, 0x94, 0x1d, 0xc0, 0x23, 0x97, 0x96, 0x9f, 0xc6, 0xe7, - 0xc2, 0xca, 0x2c, 0x5e, 0xa1, 0x36, 0xb9, 0x2a, 0xc2, 0xde, 0xd8, 0x9b, 0x76, 0xf8, 0x43, 0x8a, - 0x1e, 0x9d, 0xfe, 0x50, 0xc5, 0x4e, 0x5c, 0x88, 0x7d, 0x04, 0x3e, 0x2d, 0x21, 0xb6, 0x26, 0xec, - 0x53, 0x5a, 0x9f, 0xfc, 0x97, 0x86, 0x7d, 0x02, 0x60, 0x64, 0x86, 0xe7, 0xa2, 0xaa, 0x13, 0xfa, - 0x34, 0xd4, 0x96, 0x43, 0x4e, 0x50, 0xd7, 0x8d, 0x59, 0x2d, 0xe4, 0x4d, 0x63, 0x5b, 0x4d, 0x63, - 0x2f, 0x2b, 0xb8, 0x6e, 0x6c, 0xf2, 0x4b, 0x07, 0x7c, 0x8e, 0xa6, 0x54, 0x85, 0x41, 0xc6, 0xeb, - 0x95, 0x10, 0x03, 0xf3, 0x67, 0xaf, 0xde, 0xec, 0xdd, 0xfb, 0xe3, 0xcd, 0xde, 0xd3, 0x34, 0xb7, - 0xd9, 0xc5, 0x22, 0x92, 0xea, 0x7c, 0xbf, 0xcc, 0x8b, 0x54, 0x8a, 0x72, 0x7f, 0xb9, 0x72, 0xb4, - 0x97, 0xcb, 0x74, 0xdf, 0x64, 0x42, 0x63, 0xb2, 0xb8, 0xb2, 0x68, 0xa2, 0x63, 0xb2, 0xe7, 0x95, - 0x5d, 0xaf, 0xf4, 0x09, 0x0c, 0x34, 0xa6, 0xb9, 0x2a, 0x62, 0x3a, 0x25, 0x22, 0x20, 0x98, 0x6d, - 0x47, 0xcd, 0x61, 0x1d, 0x56, 0x4f, 0x1e, 0xb8, 0x1c, 0x72, 0xd8, 0xe7, 0xd0, 0x3b, 0x53, 0x72, - 0x89, 0x09, 0x71, 0x13, 0xcc, 0x1e, 0xac, 0x49, 0x7d, 0xa1, 0xe4, 0xf2, 0xa8, 0x38, 0x55, 0xbc, - 0x4e, 0x60, 0x7b, 0x10, 0x28, 0x9b, 0xa1, 0xae, 0x8b, 0x77, 0xc6, 0xde, 0x74, 0x8b, 0x03, 0x41, - 0xae, 0xd6, 0x97, 0xd0, 0x25, 0xb2, 0x88, 0x97, 0xff, 0x25, 0xd4, 0xe5, 0xb0, 0x6f, 0x60, 0x80, - 0x97, 0x28, 0xe3, 0x04, 0xad, 0xc8, 0xcf, 0x0c, 0x71, 0x13, 0xcc, 0x76, 0xd6, 0x9f, 0x3f, 0xbc, - 0x44, 0xf9, 0xad, 0x8b, 0xf1, 0x00, 0x6f, 0x1c, 0x36, 0x86, 0xc1, 0xfa, 0x10, 0xb2, 0xdc, 0x12, - 0x5b, 0x3e, 0x87, 0xfa, 0x08, 0xbe, 0xcb, 0x2d, 0xfb, 0x0a, 0x98, 0x0b, 0x9f, 0x09, 0x63, 0xd7, - 0xe4, 0xfb, 0xc4, 0xea, 0x88, 0x22, 0x2f, 0x84, 0xb1, 0x0d, 0xf3, 0x13, 0x18, 0x4a, 0x51, 0xc4, - 0x0b, 0x74, 0x35, 0x1b, 0xf2, 0x02, 0x29, 0x8a, 0x39, 0x52, 0xcd, 0x84, 0x7d, 0x0a, 0xdd, 0x4a, - 0x49, 0x26, 0x04, 0x3a, 0xd5, 0x61, 0x44, 0xba, 0x3a, 0x2e, 0x45, 0x71, 0x8c, 0x96, 0xbb, 0x18, - 0x7b, 0x06, 0xf7, 0x37, 0x27, 0x8a, 0x57, 0xb3, 0x30, 0xa0, 0xa1, 0x1e, 0xfd, 0xd7, 0x50, 0x27, - 0x33, 0x3e, 0xc4, 0x4d, 0x77, 0xf2, 0x93, 0x07, 0xc0, 0x89, 0x9a, 0x6a, 0xed, 0xec, 0x63, 0xd8, - 0xaa, 0xc9, 0xcc, 0x13, 0xba, 0x92, 0x0e, 0xf7, 0x1d, 0x70, 0x94, 0xb0, 0xa7, 0x37, 0x4c, 0x97, - 0x4a, 0x66, 0x35, 0xd3, 0x0f, 0xa3, 0x5a, 0xfd, 0xae, 0xcc, 0x61, 0x15, 0x5a, 0xd3, 0x5d, 0x39, - 0x1b, 0xa2, 0x6b, 0xbf, 0x83, 0xe8, 0x26, 0xaf, 0x3d, 0x18, 0xcc, 0x2b, 0x99, 0xbc, 0xaf, 0x9f, - 0xc0, 0x13, 0xe8, 0xbb, 0xf6, 0x9a, 0xbf, 0xc0, 0x87, 0xb7, 0x1a, 0xba, 0x59, 0x07, 0x6f, 0xf2, - 0x6e, 0x29, 0xb5, 0xfb, 0x36, 0xa5, 0xf6, 0xee, 0x28, 0x75, 0xf2, 0xb7, 0x07, 0xc3, 0x7a, 0x9a, - 0xf7, 0x28, 0xc2, 0x3b, 0x32, 0x69, 0xfd, 0x4b, 0x26, 0x77, 0x2f, 0xbf, 0xfd, 0xae, 0x97, 0x7f, - 0x00, 0x43, 0x8d, 0x56, 0x5f, 0xc5, 0xb7, 0x57, 0xb6, 0x7d, 0x9b, 0x75, 0x3e, 0xa0, 0x24, 0xe7, - 0x98, 0xf9, 0x67, 0xbf, 0xff, 0xea, 0x7b, 0xaf, 0xae, 0x77, 0xbd, 0xdf, 0xae, 0x77, 0xbd, 0x3f, - 0xaf, 0x77, 0xbd, 0x9f, 0xff, 0xda, 0xbd, 0x07, 0x23, 0xa5, 0xd3, 0xc8, 0xe6, 0xcb, 0x55, 0x54, - 0x0f, 0xb6, 0xe8, 0xd1, 0xe3, 0xe0, 0x9f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x0f, 0xad, 0xaa, 0x2a, - 0xa6, 0x06, 0x00, 0x00, + 0x58, 0x2d, 0xc7, 0x14, 0x21, 0x9b, 0xcb, 0xee, 0xae, 0x05, 0x3b, 0x4f, 0xd1, 0x63, 0x0f, 0x7d, + 0x80, 0x3e, 0x4a, 0x80, 0x5e, 0x7a, 0x2c, 0x7a, 0x08, 0x0a, 0xf7, 0xda, 0x53, 0x9f, 0xa0, 0xe0, + 0x2c, 0x29, 0x4b, 0x6e, 0x1b, 0xe4, 0xe2, 0x13, 0x67, 0xbe, 0x19, 0x0e, 0x67, 0xe6, 0x9b, 0x8f, + 0xf0, 0x40, 0xaa, 0x42, 0x2b, 0x89, 0xc6, 0x28, 0x1d, 0x15, 0x5a, 0x59, 0xc5, 0x82, 0x35, 0xe8, + 0x71, 0x1f, 0xb5, 0x56, 0xba, 0x98, 0xb9, 0xd8, 0xe3, 0xfe, 0x62, 0xa9, 0x0b, 0xb9, 0x72, 0x77, + 0x52, 0x95, 0x2a, 0x32, 0xf7, 0x4b, 0xab, 0x42, 0xef, 0xeb, 0x0b, 0x63, 0xc9, 0xac, 0x80, 0xde, + 0x39, 0x5a, 0xb1, 0x7a, 0x09, 0x4c, 0x21, 0x72, 0x67, 0x8f, 0x26, 0xe0, 0x7f, 0x8b, 0x57, 0x5c, + 0xe4, 0x29, 0xb2, 0x1d, 0x68, 0x1b, 0x2b, 0xb4, 0x0d, 0xbd, 0xa1, 0x37, 0xee, 0x71, 0xe7, 0xb0, + 0x01, 0x34, 0x31, 0x4f, 0xc2, 0x06, 0x61, 0xa5, 0x39, 0xfa, 0xab, 0x01, 0x5d, 0x8e, 0xdf, 0x5f, + 0xa0, 0xb1, 0xec, 0x33, 0xe8, 0x4a, 0x95, 0x5b, 0xbc, 0x74, 0x6f, 0x05, 0x93, 0x41, 0x54, 0x77, + 0xf8, 0xdc, 0xe1, 0xbc, 0x4e, 0x60, 0xdb, 0xd0, 0xb0, 0x05, 0x15, 0x6a, 0xf2, 0x86, 0x2d, 0x18, + 0x83, 0x56, 0x22, 0xac, 0x08, 0x9b, 0x54, 0x9a, 0x6c, 0xf6, 0x25, 0x74, 0x74, 0xd9, 0x8c, 0x09, + 0x5b, 0xc3, 0xe6, 0x38, 0x98, 0xbc, 0x17, 0xad, 0xef, 0xa7, 0x6e, 0x95, 0x57, 0x49, 0x6c, 0x0c, + 0x83, 0xcc, 0xc4, 0x52, 0xc8, 0x39, 0xc6, 0x98, 0x8b, 0xd9, 0x19, 0x26, 0x61, 0x7b, 0xe8, 0x8d, + 0x7d, 0xbe, 0x9d, 0x99, 0xe7, 0x25, 0x7c, 0xe8, 0x50, 0x76, 0x00, 0x8f, 0x5c, 0x5a, 0x76, 0x1a, + 0x9f, 0x0b, 0x2b, 0xe7, 0xf1, 0x12, 0xb5, 0xc9, 0x54, 0x1e, 0x76, 0x86, 0xde, 0xb8, 0xc5, 0x1f, + 0x52, 0xf4, 0xe8, 0xf4, 0xbb, 0x32, 0x76, 0xe2, 0x42, 0xec, 0x03, 0xf0, 0x69, 0x09, 0xb1, 0x35, + 0x61, 0x97, 0xd2, 0xba, 0xe4, 0xbf, 0x34, 0xec, 0x23, 0x00, 0x23, 0xe7, 0x78, 0x2e, 0xca, 0x3a, + 0xa1, 0x4f, 0x43, 0x6d, 0x39, 0xe4, 0x04, 0x75, 0xd5, 0x98, 0xd5, 0x42, 0xde, 0x34, 0xb6, 0x55, + 0x37, 0xf6, 0xb2, 0x84, 0xeb, 0xc6, 0xf6, 0x20, 0x28, 0x44, 0x9a, 0xe5, 0x69, 0x6c, 0xb2, 0x57, + 0x18, 0x02, 0x7d, 0x06, 0x1c, 0x74, 0x9c, 0xbd, 0xc2, 0xd1, 0x4f, 0x2d, 0xf0, 0x39, 0x9a, 0x42, + 0xe5, 0x06, 0x19, 0xaf, 0x76, 0x46, 0x14, 0x4d, 0x9f, 0xbd, 0x7e, 0xb3, 0x77, 0xef, 0xf7, 0x37, + 0x7b, 0x4f, 0xd3, 0xcc, 0xce, 0x2f, 0x66, 0x91, 0x54, 0xe7, 0xfb, 0x45, 0x96, 0xa7, 0x52, 0x14, + 0xfb, 0x8b, 0xa5, 0xbb, 0x8b, 0x62, 0x91, 0xee, 0x9b, 0xb9, 0xd0, 0x98, 0xcc, 0xae, 0x2c, 0x9a, + 0xe8, 0x98, 0xec, 0x69, 0x69, 0x57, 0x3b, 0x7f, 0x02, 0x3d, 0x8d, 0x69, 0xa6, 0xf2, 0x98, 0x6e, + 0x8d, 0x18, 0x0a, 0x26, 0xdb, 0x51, 0x7d, 0x79, 0x87, 0xe5, 0x93, 0x07, 0x2e, 0x87, 0x1c, 0xf6, + 0x29, 0x74, 0xce, 0x94, 0x5c, 0x60, 0x42, 0xe4, 0x05, 0x93, 0x07, 0x2b, 0xd6, 0x5f, 0x28, 0xb9, + 0x38, 0xca, 0x4f, 0x15, 0xaf, 0x12, 0xca, 0xf9, 0x94, 0x9d, 0xa3, 0xae, 0x8a, 0xb7, 0x86, 0xde, + 0x78, 0x8b, 0x03, 0x41, 0xae, 0xd6, 0xe7, 0xd0, 0x26, 0x36, 0x89, 0xb8, 0xff, 0x65, 0xdc, 0xe5, + 0xb0, 0xaf, 0xa0, 0x87, 0x97, 0x28, 0xe3, 0x04, 0xad, 0xc8, 0xce, 0x0c, 0x91, 0x17, 0x4c, 0x76, + 0x56, 0x9f, 0x3f, 0xbc, 0x44, 0xf9, 0xb5, 0x8b, 0xf1, 0x00, 0x6f, 0x1c, 0x36, 0x84, 0xde, 0xea, + 0x52, 0xe6, 0x99, 0x25, 0x3a, 0x7d, 0x0e, 0xd5, 0x95, 0x7c, 0x93, 0x59, 0xf6, 0x05, 0x30, 0x17, + 0x3e, 0x13, 0xc6, 0xae, 0xae, 0xc3, 0x27, 0x3e, 0x06, 0x14, 0x79, 0x21, 0x8c, 0xad, 0x4f, 0x63, + 0x04, 0x7d, 0x29, 0xf2, 0x78, 0x86, 0xae, 0x66, 0xcd, 0x6e, 0x20, 0x45, 0x3e, 0x45, 0xaa, 0x99, + 0xb0, 0x8f, 0xa1, 0x5d, 0x4a, 0xcd, 0x84, 0x40, 0xb7, 0xdc, 0x8f, 0x48, 0x78, 0xc7, 0x85, 0xc8, + 0x8f, 0xd1, 0x72, 0x17, 0x63, 0xcf, 0xe0, 0xfe, 0xfa, 0x44, 0xf1, 0x72, 0x12, 0x06, 0x34, 0xd4, + 0xa3, 0xff, 0x1a, 0xea, 0x64, 0xc2, 0xfb, 0xb8, 0xee, 0x8e, 0x7e, 0xf0, 0x00, 0x38, 0x51, 0x53, + 0xae, 0x9d, 0x7d, 0x08, 0x5b, 0x15, 0x99, 0x59, 0x42, 0x57, 0xd2, 0xe2, 0xbe, 0x03, 0x8e, 0x12, + 0xf6, 0xf4, 0x86, 0xe9, 0x42, 0xc9, 0x79, 0xc5, 0xf4, 0xc3, 0xa8, 0xfa, 0x3d, 0xb8, 0x32, 0x87, + 0x65, 0x68, 0x45, 0x77, 0xe9, 0xac, 0xa9, 0xb2, 0xf9, 0x0e, 0xaa, 0x1c, 0xfd, 0xe2, 0x41, 0x6f, + 0x5a, 0xea, 0xe8, 0xae, 0xfe, 0x12, 0x4f, 0xa0, 0xeb, 0xda, 0xab, 0x7f, 0x13, 0xef, 0x6f, 0x34, + 0x74, 0xb3, 0x0e, 0x5e, 0xe7, 0x6d, 0x48, 0xb9, 0xfd, 0x36, 0x29, 0x77, 0x6e, 0x49, 0x79, 0xf4, + 0xb7, 0x07, 0xfd, 0x6a, 0x9a, 0x3b, 0x14, 0xe1, 0x2d, 0x99, 0x34, 0xfe, 0x25, 0x93, 0xdb, 0x97, + 0xdf, 0x7c, 0xd7, 0xcb, 0x3f, 0x80, 0xbe, 0x46, 0xab, 0xaf, 0xe2, 0xcd, 0x95, 0x6d, 0x6f, 0xb2, + 0xce, 0x7b, 0x94, 0xe4, 0x1c, 0x33, 0xfd, 0xe4, 0xb7, 0x9f, 0x7d, 0xef, 0xf5, 0xf5, 0xae, 0xf7, + 0xeb, 0xf5, 0xae, 0xf7, 0xc7, 0xf5, 0xae, 0xf7, 0xe3, 0x9f, 0xbb, 0xf7, 0x60, 0xa0, 0x74, 0x1a, + 0xd9, 0x6c, 0xb1, 0x8c, 0xaa, 0xc1, 0x66, 0x1d, 0x7a, 0x1c, 0xfc, 0x13, 0x00, 0x00, 0xff, 0xff, + 0xea, 0xc6, 0x8d, 0x64, 0xc7, 0x06, 0x00, 0x00, } diff --git a/proto/coprocessor.proto b/proto/coprocessor.proto index 28d02f861..4078f23ed 100644 --- a/proto/coprocessor.proto +++ b/proto/coprocessor.proto @@ -36,6 +36,8 @@ message Request { // Any schema-ful storage to validate schema correctness if necessary. int64 schema_ver = 8; bool is_trace_enabled = 9; + // paging_size is 0 when it's disabled, otherwise, it should be a positive number. + uint64 paging_size = 10; } message Response {