You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@calcite.apache.org by fr...@apache.org on 2019/04/29 08:59:16 UTC
[calcite-avatica-go] branch master updated: [CALCITE-3035] Test
against Avatica 1.14.0
This is an automated email from the ASF dual-hosted git repository.
francischuang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/calcite-avatica-go.git
The following commit(s) were added to refs/heads/master by this push:
new 661221b [CALCITE-3035] Test against Avatica 1.14.0
661221b is described below
commit 661221b0931b343c06f784d9fa5557ca5f536fb3
Author: Francis Chuang <fr...@apache.org>
AuthorDate: Mon Apr 29 17:00:00 2019 +1000
[CALCITE-3035] Test against Avatica 1.14.0
---
.travis.yml | 3 +-
docker-compose.yml | 4 +-
message/common.pb.go | 161 +++++++++++++++++++++++++++-------------------
message/requests.pb.go | 168 +++++++++++++++++++++++++++---------------------
message/responses.pb.go | 133 ++++++++++++++++++++++----------------
5 files changed, 272 insertions(+), 197 deletions(-)
diff --git a/.travis.yml b/.travis.yml
index e694d56..ee041a1 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -45,7 +45,8 @@ env:
- AVATICA_FLAVOR=HSQLDB IMAGE=f21global/calcite-avatica:1.11.0-hypersql GO111MODULE=on
- AVATICA_FLAVOR=HSQLDB IMAGE=f21global/calcite-avatica:1.12.0-hypersql GO111MODULE=on
- AVATICA_FLAVOR=HSQLDB IMAGE=apache/calcite-avatica-hypersql:1.13.0 GO111MODULE=on
- - AVATICA_FLAVOR=HSQLDB IMAGE=apache/calcite-avatica-hypersql:1.13.0 GO111MODULE=off
+ - AVATICA_FLAVOR=HSQLDB IMAGE=apache/calcite-avatica-hypersql:1.14.0 GO111MODULE=on
+ - AVATICA_FLAVOR=HSQLDB IMAGE=apache/calcite-avatica-hypersql:1.14.0 GO111MODULE=off
before_install:
- if [ $GO111MODULE == "off" ]; then
diff --git a/docker-compose.yml b/docker-compose.yml
index 91a89f1..7b38f4c 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -19,7 +19,7 @@ services:
image: boostport/hbase-phoenix-all-in-one:2.0-5.0
hsqldb:
- image: apache/calcite-avatica-hypersql:1.13.0
+ image: apache/calcite-avatica-hypersql:1.14.0
command: -u jdbc:hsqldb:mem:public
test:
@@ -91,7 +91,7 @@ services:
working_dir: /source
command: sh -c "apk --no-cache --no-progress add bash; ./docker.sh compile-protobuf"
environment:
- AVATICA_VERSION: 1.13.0
+ AVATICA_VERSION: 1.14.0
PROTOBUF_VERSION: 3.7.1
volumes:
- .:/source
diff --git a/message/common.pb.go b/message/common.pb.go
index 6e93358..9cfcc66 100644
--- a/message/common.pb.go
+++ b/message/common.pb.go
@@ -3,9 +3,11 @@
package message
-import proto "github.com/golang/protobuf/proto"
-import fmt "fmt"
-import math "math"
+import (
+ fmt "fmt"
+ proto "github.com/golang/protobuf/proto"
+ math "math"
+)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
@@ -16,7 +18,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
+const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
// Has to be consistent with Meta.StatementType
type StatementType int32
@@ -50,6 +52,7 @@ var StatementType_name = map[int32]string{
10: "OTHER_DDL",
11: "CALL",
}
+
var StatementType_value = map[string]int32{
"SELECT": 0,
"INSERT": 1,
@@ -68,8 +71,9 @@ var StatementType_value = map[string]int32{
func (x StatementType) String() string {
return proto.EnumName(StatementType_name, int32(x))
}
+
func (StatementType) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{0}
+ return fileDescriptor_555bd8c177793206, []int{0}
}
type Rep int32
@@ -139,6 +143,7 @@ var Rep_name = map[int32]string{
28: "STRUCT",
29: "MULTISET",
}
+
var Rep_value = map[string]int32{
"PRIMITIVE_BOOLEAN": 0,
"PRIMITIVE_BYTE": 1,
@@ -175,8 +180,9 @@ var Rep_value = map[string]int32{
func (x Rep) String() string {
return proto.EnumName(Rep_name, int32(x))
}
+
func (Rep) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{1}
+ return fileDescriptor_555bd8c177793206, []int{1}
}
// The severity of some unexpected outcome to an operation.
@@ -196,6 +202,7 @@ var Severity_name = map[int32]string{
2: "ERROR_SEVERITY",
3: "WARNING_SEVERITY",
}
+
var Severity_value = map[string]int32{
"UNKNOWN_SEVERITY": 0,
"FATAL_SEVERITY": 1,
@@ -206,8 +213,9 @@ var Severity_value = map[string]int32{
func (x Severity) String() string {
return proto.EnumName(Severity_name, int32(x))
}
+
func (Severity) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{2}
+ return fileDescriptor_555bd8c177793206, []int{2}
}
// Enumeration corresponding to DatabaseMetaData operations
@@ -270,6 +278,7 @@ var MetaDataOperation_name = map[int32]string{
24: "GET_UDTS",
25: "GET_VERSION_COLUMNS",
}
+
var MetaDataOperation_value = map[string]int32{
"GET_ATTRIBUTES": 0,
"GET_BEST_ROW_IDENTIFIER": 1,
@@ -302,8 +311,9 @@ var MetaDataOperation_value = map[string]int32{
func (x MetaDataOperation) String() string {
return proto.EnumName(MetaDataOperation_name, int32(x))
}
+
func (MetaDataOperation) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{3}
+ return fileDescriptor_555bd8c177793206, []int{3}
}
type StateType int32
@@ -317,6 +327,7 @@ var StateType_name = map[int32]string{
0: "SQL",
1: "METADATA",
}
+
var StateType_value = map[string]int32{
"SQL": 0,
"METADATA": 1,
@@ -325,8 +336,9 @@ var StateType_value = map[string]int32{
func (x StateType) String() string {
return proto.EnumName(StateType_name, int32(x))
}
+
func (StateType) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{4}
+ return fileDescriptor_555bd8c177793206, []int{4}
}
type CursorFactory_Style int32
@@ -348,6 +360,7 @@ var CursorFactory_Style_name = map[int32]string{
4: "LIST",
5: "MAP",
}
+
var CursorFactory_Style_value = map[string]int32{
"OBJECT": 0,
"RECORD": 1,
@@ -360,8 +373,9 @@ var CursorFactory_Style_value = map[string]int32{
func (x CursorFactory_Style) String() string {
return proto.EnumName(CursorFactory_Style_name, int32(x))
}
+
func (CursorFactory_Style) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{6, 0}
+ return fileDescriptor_555bd8c177793206, []int{6, 0}
}
type MetaDataOperationArgument_ArgumentType int32
@@ -383,6 +397,7 @@ var MetaDataOperationArgument_ArgumentType_name = map[int32]string{
4: "REPEATED_INT",
5: "NULL",
}
+
var MetaDataOperationArgument_ArgumentType_value = map[string]int32{
"STRING": 0,
"BOOL": 1,
@@ -395,8 +410,9 @@ var MetaDataOperationArgument_ArgumentType_value = map[string]int32{
func (x MetaDataOperationArgument_ArgumentType) String() string {
return proto.EnumName(MetaDataOperationArgument_ArgumentType_name, int32(x))
}
+
func (MetaDataOperationArgument_ArgumentType) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{13, 0}
+ return fileDescriptor_555bd8c177793206, []int{13, 0}
}
// Details about a connection
@@ -418,16 +434,17 @@ func (m *ConnectionProperties) Reset() { *m = ConnectionProperties{} }
func (m *ConnectionProperties) String() string { return proto.CompactTextString(m) }
func (*ConnectionProperties) ProtoMessage() {}
func (*ConnectionProperties) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{0}
+ return fileDescriptor_555bd8c177793206, []int{0}
}
+
func (m *ConnectionProperties) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ConnectionProperties.Unmarshal(m, b)
}
func (m *ConnectionProperties) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ConnectionProperties.Marshal(b, m, deterministic)
}
-func (dst *ConnectionProperties) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ConnectionProperties.Merge(dst, src)
+func (m *ConnectionProperties) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ConnectionProperties.Merge(m, src)
}
func (m *ConnectionProperties) XXX_Size() int {
return xxx_messageInfo_ConnectionProperties.Size(m)
@@ -508,16 +525,17 @@ func (m *StatementHandle) Reset() { *m = StatementHandle{} }
func (m *StatementHandle) String() string { return proto.CompactTextString(m) }
func (*StatementHandle) ProtoMessage() {}
func (*StatementHandle) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{1}
+ return fileDescriptor_555bd8c177793206, []int{1}
}
+
func (m *StatementHandle) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_StatementHandle.Unmarshal(m, b)
}
func (m *StatementHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_StatementHandle.Marshal(b, m, deterministic)
}
-func (dst *StatementHandle) XXX_Merge(src proto.Message) {
- xxx_messageInfo_StatementHandle.Merge(dst, src)
+func (m *StatementHandle) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_StatementHandle.Merge(m, src)
}
func (m *StatementHandle) XXX_Size() int {
return xxx_messageInfo_StatementHandle.Size(m)
@@ -565,16 +583,17 @@ func (m *Signature) Reset() { *m = Signature{} }
func (m *Signature) String() string { return proto.CompactTextString(m) }
func (*Signature) ProtoMessage() {}
func (*Signature) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{2}
+ return fileDescriptor_555bd8c177793206, []int{2}
}
+
func (m *Signature) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Signature.Unmarshal(m, b)
}
func (m *Signature) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Signature.Marshal(b, m, deterministic)
}
-func (dst *Signature) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Signature.Merge(dst, src)
+func (m *Signature) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_Signature.Merge(m, src)
}
func (m *Signature) XXX_Size() int {
return xxx_messageInfo_Signature.Size(m)
@@ -650,16 +669,17 @@ func (m *ColumnMetaData) Reset() { *m = ColumnMetaData{} }
func (m *ColumnMetaData) String() string { return proto.CompactTextString(m) }
func (*ColumnMetaData) ProtoMessage() {}
func (*ColumnMetaData) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{3}
+ return fileDescriptor_555bd8c177793206, []int{3}
}
+
func (m *ColumnMetaData) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ColumnMetaData.Unmarshal(m, b)
}
func (m *ColumnMetaData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ColumnMetaData.Marshal(b, m, deterministic)
}
-func (dst *ColumnMetaData) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ColumnMetaData.Merge(dst, src)
+func (m *ColumnMetaData) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ColumnMetaData.Merge(m, src)
}
func (m *ColumnMetaData) XXX_Size() int {
return xxx_messageInfo_ColumnMetaData.Size(m)
@@ -826,16 +846,17 @@ func (m *AvaticaType) Reset() { *m = AvaticaType{} }
func (m *AvaticaType) String() string { return proto.CompactTextString(m) }
func (*AvaticaType) ProtoMessage() {}
func (*AvaticaType) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{4}
+ return fileDescriptor_555bd8c177793206, []int{4}
}
+
func (m *AvaticaType) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AvaticaType.Unmarshal(m, b)
}
func (m *AvaticaType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AvaticaType.Marshal(b, m, deterministic)
}
-func (dst *AvaticaType) XXX_Merge(src proto.Message) {
- xxx_messageInfo_AvaticaType.Merge(dst, src)
+func (m *AvaticaType) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_AvaticaType.Merge(m, src)
}
func (m *AvaticaType) XXX_Size() int {
return xxx_messageInfo_AvaticaType.Size(m)
@@ -899,16 +920,17 @@ func (m *AvaticaParameter) Reset() { *m = AvaticaParameter{} }
func (m *AvaticaParameter) String() string { return proto.CompactTextString(m) }
func (*AvaticaParameter) ProtoMessage() {}
func (*AvaticaParameter) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{5}
+ return fileDescriptor_555bd8c177793206, []int{5}
}
+
func (m *AvaticaParameter) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AvaticaParameter.Unmarshal(m, b)
}
func (m *AvaticaParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AvaticaParameter.Marshal(b, m, deterministic)
}
-func (dst *AvaticaParameter) XXX_Merge(src proto.Message) {
- xxx_messageInfo_AvaticaParameter.Merge(dst, src)
+func (m *AvaticaParameter) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_AvaticaParameter.Merge(m, src)
}
func (m *AvaticaParameter) XXX_Size() int {
return xxx_messageInfo_AvaticaParameter.Size(m)
@@ -982,16 +1004,17 @@ func (m *CursorFactory) Reset() { *m = CursorFactory{} }
func (m *CursorFactory) String() string { return proto.CompactTextString(m) }
func (*CursorFactory) ProtoMessage() {}
func (*CursorFactory) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{6}
+ return fileDescriptor_555bd8c177793206, []int{6}
}
+
func (m *CursorFactory) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CursorFactory.Unmarshal(m, b)
}
func (m *CursorFactory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CursorFactory.Marshal(b, m, deterministic)
}
-func (dst *CursorFactory) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CursorFactory.Merge(dst, src)
+func (m *CursorFactory) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CursorFactory.Merge(m, src)
}
func (m *CursorFactory) XXX_Size() int {
return xxx_messageInfo_CursorFactory.Size(m)
@@ -1037,16 +1060,17 @@ func (m *Frame) Reset() { *m = Frame{} }
func (m *Frame) String() string { return proto.CompactTextString(m) }
func (*Frame) ProtoMessage() {}
func (*Frame) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{7}
+ return fileDescriptor_555bd8c177793206, []int{7}
}
+
func (m *Frame) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Frame.Unmarshal(m, b)
}
func (m *Frame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Frame.Marshal(b, m, deterministic)
}
-func (dst *Frame) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Frame.Merge(dst, src)
+func (m *Frame) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_Frame.Merge(m, src)
}
func (m *Frame) XXX_Size() int {
return xxx_messageInfo_Frame.Size(m)
@@ -1090,16 +1114,17 @@ func (m *Row) Reset() { *m = Row{} }
func (m *Row) String() string { return proto.CompactTextString(m) }
func (*Row) ProtoMessage() {}
func (*Row) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{8}
+ return fileDescriptor_555bd8c177793206, []int{8}
}
+
func (m *Row) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Row.Unmarshal(m, b)
}
func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Row.Marshal(b, m, deterministic)
}
-func (dst *Row) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Row.Merge(dst, src)
+func (m *Row) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_Row.Merge(m, src)
}
func (m *Row) XXX_Size() int {
return xxx_messageInfo_Row.Size(m)
@@ -1130,16 +1155,17 @@ func (m *DatabaseProperty) Reset() { *m = DatabaseProperty{} }
func (m *DatabaseProperty) String() string { return proto.CompactTextString(m) }
func (*DatabaseProperty) ProtoMessage() {}
func (*DatabaseProperty) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{9}
+ return fileDescriptor_555bd8c177793206, []int{9}
}
+
func (m *DatabaseProperty) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DatabaseProperty.Unmarshal(m, b)
}
func (m *DatabaseProperty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DatabaseProperty.Marshal(b, m, deterministic)
}
-func (dst *DatabaseProperty) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DatabaseProperty.Merge(dst, src)
+func (m *DatabaseProperty) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_DatabaseProperty.Merge(m, src)
}
func (m *DatabaseProperty) XXX_Size() int {
return xxx_messageInfo_DatabaseProperty.Size(m)
@@ -1177,16 +1203,17 @@ func (m *WireMessage) Reset() { *m = WireMessage{} }
func (m *WireMessage) String() string { return proto.CompactTextString(m) }
func (*WireMessage) ProtoMessage() {}
func (*WireMessage) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{10}
+ return fileDescriptor_555bd8c177793206, []int{10}
}
+
func (m *WireMessage) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_WireMessage.Unmarshal(m, b)
}
func (m *WireMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_WireMessage.Marshal(b, m, deterministic)
}
-func (dst *WireMessage) XXX_Merge(src proto.Message) {
- xxx_messageInfo_WireMessage.Merge(dst, src)
+func (m *WireMessage) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_WireMessage.Merge(m, src)
}
func (m *WireMessage) XXX_Size() int {
return xxx_messageInfo_WireMessage.Size(m)
@@ -1226,16 +1253,17 @@ func (m *ColumnValue) Reset() { *m = ColumnValue{} }
func (m *ColumnValue) String() string { return proto.CompactTextString(m) }
func (*ColumnValue) ProtoMessage() {}
func (*ColumnValue) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{11}
+ return fileDescriptor_555bd8c177793206, []int{11}
}
+
func (m *ColumnValue) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ColumnValue.Unmarshal(m, b)
}
func (m *ColumnValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ColumnValue.Marshal(b, m, deterministic)
}
-func (dst *ColumnValue) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ColumnValue.Merge(dst, src)
+func (m *ColumnValue) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ColumnValue.Merge(m, src)
}
func (m *ColumnValue) XXX_Size() int {
return xxx_messageInfo_ColumnValue.Size(m)
@@ -1296,16 +1324,17 @@ func (m *TypedValue) Reset() { *m = TypedValue{} }
func (m *TypedValue) String() string { return proto.CompactTextString(m) }
func (*TypedValue) ProtoMessage() {}
func (*TypedValue) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{12}
+ return fileDescriptor_555bd8c177793206, []int{12}
}
+
func (m *TypedValue) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TypedValue.Unmarshal(m, b)
}
func (m *TypedValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TypedValue.Marshal(b, m, deterministic)
}
-func (dst *TypedValue) XXX_Merge(src proto.Message) {
- xxx_messageInfo_TypedValue.Merge(dst, src)
+func (m *TypedValue) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_TypedValue.Merge(m, src)
}
func (m *TypedValue) XXX_Size() int {
return xxx_messageInfo_TypedValue.Size(m)
@@ -1403,16 +1432,17 @@ func (m *MetaDataOperationArgument) Reset() { *m = MetaDataOperationArgu
func (m *MetaDataOperationArgument) String() string { return proto.CompactTextString(m) }
func (*MetaDataOperationArgument) ProtoMessage() {}
func (*MetaDataOperationArgument) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{13}
+ return fileDescriptor_555bd8c177793206, []int{13}
}
+
func (m *MetaDataOperationArgument) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MetaDataOperationArgument.Unmarshal(m, b)
}
func (m *MetaDataOperationArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MetaDataOperationArgument.Marshal(b, m, deterministic)
}
-func (dst *MetaDataOperationArgument) XXX_Merge(src proto.Message) {
- xxx_messageInfo_MetaDataOperationArgument.Merge(dst, src)
+func (m *MetaDataOperationArgument) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_MetaDataOperationArgument.Merge(m, src)
}
func (m *MetaDataOperationArgument) XXX_Size() int {
return xxx_messageInfo_MetaDataOperationArgument.Size(m)
@@ -1482,16 +1512,17 @@ func (m *QueryState) Reset() { *m = QueryState{} }
func (m *QueryState) String() string { return proto.CompactTextString(m) }
func (*QueryState) ProtoMessage() {}
func (*QueryState) Descriptor() ([]byte, []int) {
- return fileDescriptor_common_84e383fbabed0a31, []int{14}
+ return fileDescriptor_555bd8c177793206, []int{14}
}
+
func (m *QueryState) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_QueryState.Unmarshal(m, b)
}
func (m *QueryState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_QueryState.Marshal(b, m, deterministic)
}
-func (dst *QueryState) XXX_Merge(src proto.Message) {
- xxx_messageInfo_QueryState.Merge(dst, src)
+func (m *QueryState) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_QueryState.Merge(m, src)
}
func (m *QueryState) XXX_Size() int {
return xxx_messageInfo_QueryState.Size(m)
@@ -1552,6 +1583,13 @@ func (m *QueryState) GetHasOp() bool {
}
func init() {
+ proto.RegisterEnum("StatementType", StatementType_name, StatementType_value)
+ proto.RegisterEnum("Rep", Rep_name, Rep_value)
+ proto.RegisterEnum("Severity", Severity_name, Severity_value)
+ proto.RegisterEnum("MetaDataOperation", MetaDataOperation_name, MetaDataOperation_value)
+ proto.RegisterEnum("StateType", StateType_name, StateType_value)
+ proto.RegisterEnum("CursorFactory_Style", CursorFactory_Style_name, CursorFactory_Style_value)
+ proto.RegisterEnum("MetaDataOperationArgument_ArgumentType", MetaDataOperationArgument_ArgumentType_name, MetaDataOperationArgument_ArgumentType_value)
proto.RegisterType((*ConnectionProperties)(nil), "ConnectionProperties")
proto.RegisterType((*StatementHandle)(nil), "StatementHandle")
proto.RegisterType((*Signature)(nil), "Signature")
@@ -1567,18 +1605,11 @@ func init() {
proto.RegisterType((*TypedValue)(nil), "TypedValue")
proto.RegisterType((*MetaDataOperationArgument)(nil), "MetaDataOperationArgument")
proto.RegisterType((*QueryState)(nil), "QueryState")
- proto.RegisterEnum("StatementType", StatementType_name, StatementType_value)
- proto.RegisterEnum("Rep", Rep_name, Rep_value)
- proto.RegisterEnum("Severity", Severity_name, Severity_value)
- proto.RegisterEnum("MetaDataOperation", MetaDataOperation_name, MetaDataOperation_value)
- proto.RegisterEnum("StateType", StateType_name, StateType_value)
- proto.RegisterEnum("CursorFactory_Style", CursorFactory_Style_name, CursorFactory_Style_value)
- proto.RegisterEnum("MetaDataOperationArgument_ArgumentType", MetaDataOperationArgument_ArgumentType_name, MetaDataOperationArgument_ArgumentType_value)
}
-func init() { proto.RegisterFile("common.proto", fileDescriptor_common_84e383fbabed0a31) }
+func init() { proto.RegisterFile("common.proto", fileDescriptor_555bd8c177793206) }
-var fileDescriptor_common_84e383fbabed0a31 = []byte{
+var fileDescriptor_555bd8c177793206 = []byte{
// 2227 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x58, 0xcb, 0x72, 0xe3, 0xc6,
0x15, 0x1d, 0xf0, 0x21, 0x11, 0x17, 0x24, 0xd5, 0x6a, 0x49, 0x33, 0x9c, 0x19, 0x3f, 0x64, 0xa6,
diff --git a/message/requests.pb.go b/message/requests.pb.go
index e844f77..dfa3db1 100644
--- a/message/requests.pb.go
+++ b/message/requests.pb.go
@@ -3,9 +3,11 @@
package message
-import proto "github.com/golang/protobuf/proto"
-import fmt "fmt"
-import math "math"
+import (
+ fmt "fmt"
+ proto "github.com/golang/protobuf/proto"
+ math "math"
+)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
@@ -16,7 +18,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
+const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
// Request for Meta#getCatalogs()
type CatalogsRequest struct {
@@ -30,16 +32,17 @@ func (m *CatalogsRequest) Reset() { *m = CatalogsRequest{} }
func (m *CatalogsRequest) String() string { return proto.CompactTextString(m) }
func (*CatalogsRequest) ProtoMessage() {}
func (*CatalogsRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{0}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{0}
}
+
func (m *CatalogsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CatalogsRequest.Unmarshal(m, b)
}
func (m *CatalogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CatalogsRequest.Marshal(b, m, deterministic)
}
-func (dst *CatalogsRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CatalogsRequest.Merge(dst, src)
+func (m *CatalogsRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CatalogsRequest.Merge(m, src)
}
func (m *CatalogsRequest) XXX_Size() int {
return xxx_messageInfo_CatalogsRequest.Size(m)
@@ -69,16 +72,17 @@ func (m *DatabasePropertyRequest) Reset() { *m = DatabasePropertyRequest
func (m *DatabasePropertyRequest) String() string { return proto.CompactTextString(m) }
func (*DatabasePropertyRequest) ProtoMessage() {}
func (*DatabasePropertyRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{1}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{1}
}
+
func (m *DatabasePropertyRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DatabasePropertyRequest.Unmarshal(m, b)
}
func (m *DatabasePropertyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DatabasePropertyRequest.Marshal(b, m, deterministic)
}
-func (dst *DatabasePropertyRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DatabasePropertyRequest.Merge(dst, src)
+func (m *DatabasePropertyRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_DatabasePropertyRequest.Merge(m, src)
}
func (m *DatabasePropertyRequest) XXX_Size() int {
return xxx_messageInfo_DatabasePropertyRequest.Size(m)
@@ -110,16 +114,17 @@ func (m *SchemasRequest) Reset() { *m = SchemasRequest{} }
func (m *SchemasRequest) String() string { return proto.CompactTextString(m) }
func (*SchemasRequest) ProtoMessage() {}
func (*SchemasRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{2}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{2}
}
+
func (m *SchemasRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SchemasRequest.Unmarshal(m, b)
}
func (m *SchemasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SchemasRequest.Marshal(b, m, deterministic)
}
-func (dst *SchemasRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_SchemasRequest.Merge(dst, src)
+func (m *SchemasRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_SchemasRequest.Merge(m, src)
}
func (m *SchemasRequest) XXX_Size() int {
return xxx_messageInfo_SchemasRequest.Size(m)
@@ -169,16 +174,17 @@ func (m *TablesRequest) Reset() { *m = TablesRequest{} }
func (m *TablesRequest) String() string { return proto.CompactTextString(m) }
func (*TablesRequest) ProtoMessage() {}
func (*TablesRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{3}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{3}
}
+
func (m *TablesRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TablesRequest.Unmarshal(m, b)
}
func (m *TablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TablesRequest.Marshal(b, m, deterministic)
}
-func (dst *TablesRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_TablesRequest.Merge(dst, src)
+func (m *TablesRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_TablesRequest.Merge(m, src)
}
func (m *TablesRequest) XXX_Size() int {
return xxx_messageInfo_TablesRequest.Size(m)
@@ -243,16 +249,17 @@ func (m *TableTypesRequest) Reset() { *m = TableTypesRequest{} }
func (m *TableTypesRequest) String() string { return proto.CompactTextString(m) }
func (*TableTypesRequest) ProtoMessage() {}
func (*TableTypesRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{4}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{4}
}
+
func (m *TableTypesRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TableTypesRequest.Unmarshal(m, b)
}
func (m *TableTypesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TableTypesRequest.Marshal(b, m, deterministic)
}
-func (dst *TableTypesRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_TableTypesRequest.Merge(dst, src)
+func (m *TableTypesRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_TableTypesRequest.Merge(m, src)
}
func (m *TableTypesRequest) XXX_Size() int {
return xxx_messageInfo_TableTypesRequest.Size(m)
@@ -287,16 +294,17 @@ func (m *ColumnsRequest) Reset() { *m = ColumnsRequest{} }
func (m *ColumnsRequest) String() string { return proto.CompactTextString(m) }
func (*ColumnsRequest) ProtoMessage() {}
func (*ColumnsRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{5}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{5}
}
+
func (m *ColumnsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ColumnsRequest.Unmarshal(m, b)
}
func (m *ColumnsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ColumnsRequest.Marshal(b, m, deterministic)
}
-func (dst *ColumnsRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ColumnsRequest.Merge(dst, src)
+func (m *ColumnsRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ColumnsRequest.Merge(m, src)
}
func (m *ColumnsRequest) XXX_Size() int {
return xxx_messageInfo_ColumnsRequest.Size(m)
@@ -354,16 +362,17 @@ func (m *TypeInfoRequest) Reset() { *m = TypeInfoRequest{} }
func (m *TypeInfoRequest) String() string { return proto.CompactTextString(m) }
func (*TypeInfoRequest) ProtoMessage() {}
func (*TypeInfoRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{6}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{6}
}
+
func (m *TypeInfoRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TypeInfoRequest.Unmarshal(m, b)
}
func (m *TypeInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TypeInfoRequest.Marshal(b, m, deterministic)
}
-func (dst *TypeInfoRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_TypeInfoRequest.Merge(dst, src)
+func (m *TypeInfoRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_TypeInfoRequest.Merge(m, src)
}
func (m *TypeInfoRequest) XXX_Size() int {
return xxx_messageInfo_TypeInfoRequest.Size(m)
@@ -398,16 +407,17 @@ func (m *PrepareAndExecuteRequest) Reset() { *m = PrepareAndExecuteReque
func (m *PrepareAndExecuteRequest) String() string { return proto.CompactTextString(m) }
func (*PrepareAndExecuteRequest) ProtoMessage() {}
func (*PrepareAndExecuteRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{7}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{7}
}
+
func (m *PrepareAndExecuteRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PrepareAndExecuteRequest.Unmarshal(m, b)
}
func (m *PrepareAndExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PrepareAndExecuteRequest.Marshal(b, m, deterministic)
}
-func (dst *PrepareAndExecuteRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_PrepareAndExecuteRequest.Merge(dst, src)
+func (m *PrepareAndExecuteRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_PrepareAndExecuteRequest.Merge(m, src)
}
func (m *PrepareAndExecuteRequest) XXX_Size() int {
return xxx_messageInfo_PrepareAndExecuteRequest.Size(m)
@@ -475,16 +485,17 @@ func (m *PrepareRequest) Reset() { *m = PrepareRequest{} }
func (m *PrepareRequest) String() string { return proto.CompactTextString(m) }
func (*PrepareRequest) ProtoMessage() {}
func (*PrepareRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{8}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{8}
}
+
func (m *PrepareRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PrepareRequest.Unmarshal(m, b)
}
func (m *PrepareRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PrepareRequest.Marshal(b, m, deterministic)
}
-func (dst *PrepareRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_PrepareRequest.Merge(dst, src)
+func (m *PrepareRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_PrepareRequest.Merge(m, src)
}
func (m *PrepareRequest) XXX_Size() int {
return xxx_messageInfo_PrepareRequest.Size(m)
@@ -539,16 +550,17 @@ func (m *FetchRequest) Reset() { *m = FetchRequest{} }
func (m *FetchRequest) String() string { return proto.CompactTextString(m) }
func (*FetchRequest) ProtoMessage() {}
func (*FetchRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{9}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{9}
}
+
func (m *FetchRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FetchRequest.Unmarshal(m, b)
}
func (m *FetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FetchRequest.Marshal(b, m, deterministic)
}
-func (dst *FetchRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_FetchRequest.Merge(dst, src)
+func (m *FetchRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_FetchRequest.Merge(m, src)
}
func (m *FetchRequest) XXX_Size() int {
return xxx_messageInfo_FetchRequest.Size(m)
@@ -606,16 +618,17 @@ func (m *CreateStatementRequest) Reset() { *m = CreateStatementRequest{}
func (m *CreateStatementRequest) String() string { return proto.CompactTextString(m) }
func (*CreateStatementRequest) ProtoMessage() {}
func (*CreateStatementRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{10}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{10}
}
+
func (m *CreateStatementRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CreateStatementRequest.Unmarshal(m, b)
}
func (m *CreateStatementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CreateStatementRequest.Marshal(b, m, deterministic)
}
-func (dst *CreateStatementRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CreateStatementRequest.Merge(dst, src)
+func (m *CreateStatementRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CreateStatementRequest.Merge(m, src)
}
func (m *CreateStatementRequest) XXX_Size() int {
return xxx_messageInfo_CreateStatementRequest.Size(m)
@@ -646,16 +659,17 @@ func (m *CloseStatementRequest) Reset() { *m = CloseStatementRequest{} }
func (m *CloseStatementRequest) String() string { return proto.CompactTextString(m) }
func (*CloseStatementRequest) ProtoMessage() {}
func (*CloseStatementRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{11}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{11}
}
+
func (m *CloseStatementRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CloseStatementRequest.Unmarshal(m, b)
}
func (m *CloseStatementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CloseStatementRequest.Marshal(b, m, deterministic)
}
-func (dst *CloseStatementRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CloseStatementRequest.Merge(dst, src)
+func (m *CloseStatementRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CloseStatementRequest.Merge(m, src)
}
func (m *CloseStatementRequest) XXX_Size() int {
return xxx_messageInfo_CloseStatementRequest.Size(m)
@@ -693,16 +707,17 @@ func (m *OpenConnectionRequest) Reset() { *m = OpenConnectionRequest{} }
func (m *OpenConnectionRequest) String() string { return proto.CompactTextString(m) }
func (*OpenConnectionRequest) ProtoMessage() {}
func (*OpenConnectionRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{12}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{12}
}
+
func (m *OpenConnectionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OpenConnectionRequest.Unmarshal(m, b)
}
func (m *OpenConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_OpenConnectionRequest.Marshal(b, m, deterministic)
}
-func (dst *OpenConnectionRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OpenConnectionRequest.Merge(dst, src)
+func (m *OpenConnectionRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_OpenConnectionRequest.Merge(m, src)
}
func (m *OpenConnectionRequest) XXX_Size() int {
return xxx_messageInfo_OpenConnectionRequest.Size(m)
@@ -739,16 +754,17 @@ func (m *CloseConnectionRequest) Reset() { *m = CloseConnectionRequest{}
func (m *CloseConnectionRequest) String() string { return proto.CompactTextString(m) }
func (*CloseConnectionRequest) ProtoMessage() {}
func (*CloseConnectionRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{13}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{13}
}
+
func (m *CloseConnectionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CloseConnectionRequest.Unmarshal(m, b)
}
func (m *CloseConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CloseConnectionRequest.Marshal(b, m, deterministic)
}
-func (dst *CloseConnectionRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CloseConnectionRequest.Merge(dst, src)
+func (m *CloseConnectionRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CloseConnectionRequest.Merge(m, src)
}
func (m *CloseConnectionRequest) XXX_Size() int {
return xxx_messageInfo_CloseConnectionRequest.Size(m)
@@ -778,16 +794,17 @@ func (m *ConnectionSyncRequest) Reset() { *m = ConnectionSyncRequest{} }
func (m *ConnectionSyncRequest) String() string { return proto.CompactTextString(m) }
func (*ConnectionSyncRequest) ProtoMessage() {}
func (*ConnectionSyncRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{14}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{14}
}
+
func (m *ConnectionSyncRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ConnectionSyncRequest.Unmarshal(m, b)
}
func (m *ConnectionSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ConnectionSyncRequest.Marshal(b, m, deterministic)
}
-func (dst *ConnectionSyncRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ConnectionSyncRequest.Merge(dst, src)
+func (m *ConnectionSyncRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ConnectionSyncRequest.Merge(m, src)
}
func (m *ConnectionSyncRequest) XXX_Size() int {
return xxx_messageInfo_ConnectionSyncRequest.Size(m)
@@ -828,16 +845,17 @@ func (m *ExecuteRequest) Reset() { *m = ExecuteRequest{} }
func (m *ExecuteRequest) String() string { return proto.CompactTextString(m) }
func (*ExecuteRequest) ProtoMessage() {}
func (*ExecuteRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{15}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{15}
}
+
func (m *ExecuteRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ExecuteRequest.Unmarshal(m, b)
}
func (m *ExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ExecuteRequest.Marshal(b, m, deterministic)
}
-func (dst *ExecuteRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ExecuteRequest.Merge(dst, src)
+func (m *ExecuteRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ExecuteRequest.Merge(m, src)
}
func (m *ExecuteRequest) XXX_Size() int {
return xxx_messageInfo_ExecuteRequest.Size(m)
@@ -897,16 +915,17 @@ func (m *SyncResultsRequest) Reset() { *m = SyncResultsRequest{} }
func (m *SyncResultsRequest) String() string { return proto.CompactTextString(m) }
func (*SyncResultsRequest) ProtoMessage() {}
func (*SyncResultsRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{16}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{16}
}
+
func (m *SyncResultsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SyncResultsRequest.Unmarshal(m, b)
}
func (m *SyncResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SyncResultsRequest.Marshal(b, m, deterministic)
}
-func (dst *SyncResultsRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_SyncResultsRequest.Merge(dst, src)
+func (m *SyncResultsRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_SyncResultsRequest.Merge(m, src)
}
func (m *SyncResultsRequest) XXX_Size() int {
return xxx_messageInfo_SyncResultsRequest.Size(m)
@@ -957,16 +976,17 @@ func (m *CommitRequest) Reset() { *m = CommitRequest{} }
func (m *CommitRequest) String() string { return proto.CompactTextString(m) }
func (*CommitRequest) ProtoMessage() {}
func (*CommitRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{17}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{17}
}
+
func (m *CommitRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CommitRequest.Unmarshal(m, b)
}
func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CommitRequest.Marshal(b, m, deterministic)
}
-func (dst *CommitRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CommitRequest.Merge(dst, src)
+func (m *CommitRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CommitRequest.Merge(m, src)
}
func (m *CommitRequest) XXX_Size() int {
return xxx_messageInfo_CommitRequest.Size(m)
@@ -996,16 +1016,17 @@ func (m *RollbackRequest) Reset() { *m = RollbackRequest{} }
func (m *RollbackRequest) String() string { return proto.CompactTextString(m) }
func (*RollbackRequest) ProtoMessage() {}
func (*RollbackRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{18}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{18}
}
+
func (m *RollbackRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RollbackRequest.Unmarshal(m, b)
}
func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RollbackRequest.Marshal(b, m, deterministic)
}
-func (dst *RollbackRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_RollbackRequest.Merge(dst, src)
+func (m *RollbackRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_RollbackRequest.Merge(m, src)
}
func (m *RollbackRequest) XXX_Size() int {
return xxx_messageInfo_RollbackRequest.Size(m)
@@ -1037,16 +1058,17 @@ func (m *PrepareAndExecuteBatchRequest) Reset() { *m = PrepareAndExecute
func (m *PrepareAndExecuteBatchRequest) String() string { return proto.CompactTextString(m) }
func (*PrepareAndExecuteBatchRequest) ProtoMessage() {}
func (*PrepareAndExecuteBatchRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{19}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{19}
}
+
func (m *PrepareAndExecuteBatchRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PrepareAndExecuteBatchRequest.Unmarshal(m, b)
}
func (m *PrepareAndExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PrepareAndExecuteBatchRequest.Marshal(b, m, deterministic)
}
-func (dst *PrepareAndExecuteBatchRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_PrepareAndExecuteBatchRequest.Merge(dst, src)
+func (m *PrepareAndExecuteBatchRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_PrepareAndExecuteBatchRequest.Merge(m, src)
}
func (m *PrepareAndExecuteBatchRequest) XXX_Size() int {
return xxx_messageInfo_PrepareAndExecuteBatchRequest.Size(m)
@@ -1090,16 +1112,17 @@ func (m *UpdateBatch) Reset() { *m = UpdateBatch{} }
func (m *UpdateBatch) String() string { return proto.CompactTextString(m) }
func (*UpdateBatch) ProtoMessage() {}
func (*UpdateBatch) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{20}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{20}
}
+
func (m *UpdateBatch) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdateBatch.Unmarshal(m, b)
}
func (m *UpdateBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UpdateBatch.Marshal(b, m, deterministic)
}
-func (dst *UpdateBatch) XXX_Merge(src proto.Message) {
- xxx_messageInfo_UpdateBatch.Merge(dst, src)
+func (m *UpdateBatch) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_UpdateBatch.Merge(m, src)
}
func (m *UpdateBatch) XXX_Size() int {
return xxx_messageInfo_UpdateBatch.Size(m)
@@ -1130,16 +1153,17 @@ func (m *ExecuteBatchRequest) Reset() { *m = ExecuteBatchRequest{} }
func (m *ExecuteBatchRequest) String() string { return proto.CompactTextString(m) }
func (*ExecuteBatchRequest) ProtoMessage() {}
func (*ExecuteBatchRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_requests_f149f33d924311f5, []int{21}
+ return fileDescriptor_9c9ccec99da7c9b4, []int{21}
}
+
func (m *ExecuteBatchRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ExecuteBatchRequest.Unmarshal(m, b)
}
func (m *ExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ExecuteBatchRequest.Marshal(b, m, deterministic)
}
-func (dst *ExecuteBatchRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ExecuteBatchRequest.Merge(dst, src)
+func (m *ExecuteBatchRequest) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ExecuteBatchRequest.Merge(m, src)
}
func (m *ExecuteBatchRequest) XXX_Size() int {
return xxx_messageInfo_ExecuteBatchRequest.Size(m)
@@ -1197,9 +1221,9 @@ func init() {
proto.RegisterType((*ExecuteBatchRequest)(nil), "ExecuteBatchRequest")
}
-func init() { proto.RegisterFile("requests.proto", fileDescriptor_requests_f149f33d924311f5) }
+func init() { proto.RegisterFile("requests.proto", fileDescriptor_9c9ccec99da7c9b4) }
-var fileDescriptor_requests_f149f33d924311f5 = []byte{
+var fileDescriptor_9c9ccec99da7c9b4 = []byte{
// 904 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x56, 0xdd, 0x6e, 0x1b, 0x45,
0x14, 0xd6, 0xfa, 0x27, 0xa9, 0xcf, 0xfa, 0x2f, 0x9b, 0xa4, 0x58, 0xad, 0x10, 0xee, 0xf2, 0xa3,
diff --git a/message/responses.pb.go b/message/responses.pb.go
index c2e77f6..55525be 100644
--- a/message/responses.pb.go
+++ b/message/responses.pb.go
@@ -3,9 +3,11 @@
package message
-import proto "github.com/golang/protobuf/proto"
-import fmt "fmt"
-import math "math"
+import (
+ fmt "fmt"
+ proto "github.com/golang/protobuf/proto"
+ math "math"
+)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
@@ -16,7 +18,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
+const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
// Response that contains a result set.
type ResultSetResponse struct {
@@ -37,16 +39,17 @@ func (m *ResultSetResponse) Reset() { *m = ResultSetResponse{} }
func (m *ResultSetResponse) String() string { return proto.CompactTextString(m) }
func (*ResultSetResponse) ProtoMessage() {}
func (*ResultSetResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{0}
+ return fileDescriptor_2f8192a35440e287, []int{0}
}
+
func (m *ResultSetResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ResultSetResponse.Unmarshal(m, b)
}
func (m *ResultSetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ResultSetResponse.Marshal(b, m, deterministic)
}
-func (dst *ResultSetResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ResultSetResponse.Merge(dst, src)
+func (m *ResultSetResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ResultSetResponse.Merge(m, src)
}
func (m *ResultSetResponse) XXX_Size() int {
return xxx_messageInfo_ResultSetResponse.Size(m)
@@ -120,16 +123,17 @@ func (m *ExecuteResponse) Reset() { *m = ExecuteResponse{} }
func (m *ExecuteResponse) String() string { return proto.CompactTextString(m) }
func (*ExecuteResponse) ProtoMessage() {}
func (*ExecuteResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{1}
+ return fileDescriptor_2f8192a35440e287, []int{1}
}
+
func (m *ExecuteResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ExecuteResponse.Unmarshal(m, b)
}
func (m *ExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ExecuteResponse.Marshal(b, m, deterministic)
}
-func (dst *ExecuteResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ExecuteResponse.Merge(dst, src)
+func (m *ExecuteResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ExecuteResponse.Merge(m, src)
}
func (m *ExecuteResponse) XXX_Size() int {
return xxx_messageInfo_ExecuteResponse.Size(m)
@@ -174,16 +178,17 @@ func (m *PrepareResponse) Reset() { *m = PrepareResponse{} }
func (m *PrepareResponse) String() string { return proto.CompactTextString(m) }
func (*PrepareResponse) ProtoMessage() {}
func (*PrepareResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{2}
+ return fileDescriptor_2f8192a35440e287, []int{2}
}
+
func (m *PrepareResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PrepareResponse.Unmarshal(m, b)
}
func (m *PrepareResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PrepareResponse.Marshal(b, m, deterministic)
}
-func (dst *PrepareResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_PrepareResponse.Merge(dst, src)
+func (m *PrepareResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_PrepareResponse.Merge(m, src)
}
func (m *PrepareResponse) XXX_Size() int {
return xxx_messageInfo_PrepareResponse.Size(m)
@@ -223,16 +228,17 @@ func (m *FetchResponse) Reset() { *m = FetchResponse{} }
func (m *FetchResponse) String() string { return proto.CompactTextString(m) }
func (*FetchResponse) ProtoMessage() {}
func (*FetchResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{3}
+ return fileDescriptor_2f8192a35440e287, []int{3}
}
+
func (m *FetchResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FetchResponse.Unmarshal(m, b)
}
func (m *FetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FetchResponse.Marshal(b, m, deterministic)
}
-func (dst *FetchResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_FetchResponse.Merge(dst, src)
+func (m *FetchResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_FetchResponse.Merge(m, src)
}
func (m *FetchResponse) XXX_Size() int {
return xxx_messageInfo_FetchResponse.Size(m)
@@ -285,16 +291,17 @@ func (m *CreateStatementResponse) Reset() { *m = CreateStatementResponse
func (m *CreateStatementResponse) String() string { return proto.CompactTextString(m) }
func (*CreateStatementResponse) ProtoMessage() {}
func (*CreateStatementResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{4}
+ return fileDescriptor_2f8192a35440e287, []int{4}
}
+
func (m *CreateStatementResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CreateStatementResponse.Unmarshal(m, b)
}
func (m *CreateStatementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CreateStatementResponse.Marshal(b, m, deterministic)
}
-func (dst *CreateStatementResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CreateStatementResponse.Merge(dst, src)
+func (m *CreateStatementResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CreateStatementResponse.Merge(m, src)
}
func (m *CreateStatementResponse) XXX_Size() int {
return xxx_messageInfo_CreateStatementResponse.Size(m)
@@ -338,16 +345,17 @@ func (m *CloseStatementResponse) Reset() { *m = CloseStatementResponse{}
func (m *CloseStatementResponse) String() string { return proto.CompactTextString(m) }
func (*CloseStatementResponse) ProtoMessage() {}
func (*CloseStatementResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{5}
+ return fileDescriptor_2f8192a35440e287, []int{5}
}
+
func (m *CloseStatementResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CloseStatementResponse.Unmarshal(m, b)
}
func (m *CloseStatementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CloseStatementResponse.Marshal(b, m, deterministic)
}
-func (dst *CloseStatementResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CloseStatementResponse.Merge(dst, src)
+func (m *CloseStatementResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CloseStatementResponse.Merge(m, src)
}
func (m *CloseStatementResponse) XXX_Size() int {
return xxx_messageInfo_CloseStatementResponse.Size(m)
@@ -377,16 +385,17 @@ func (m *OpenConnectionResponse) Reset() { *m = OpenConnectionResponse{}
func (m *OpenConnectionResponse) String() string { return proto.CompactTextString(m) }
func (*OpenConnectionResponse) ProtoMessage() {}
func (*OpenConnectionResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{6}
+ return fileDescriptor_2f8192a35440e287, []int{6}
}
+
func (m *OpenConnectionResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OpenConnectionResponse.Unmarshal(m, b)
}
func (m *OpenConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_OpenConnectionResponse.Marshal(b, m, deterministic)
}
-func (dst *OpenConnectionResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_OpenConnectionResponse.Merge(dst, src)
+func (m *OpenConnectionResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_OpenConnectionResponse.Merge(m, src)
}
func (m *OpenConnectionResponse) XXX_Size() int {
return xxx_messageInfo_OpenConnectionResponse.Size(m)
@@ -416,16 +425,17 @@ func (m *CloseConnectionResponse) Reset() { *m = CloseConnectionResponse
func (m *CloseConnectionResponse) String() string { return proto.CompactTextString(m) }
func (*CloseConnectionResponse) ProtoMessage() {}
func (*CloseConnectionResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{7}
+ return fileDescriptor_2f8192a35440e287, []int{7}
}
+
func (m *CloseConnectionResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CloseConnectionResponse.Unmarshal(m, b)
}
func (m *CloseConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CloseConnectionResponse.Marshal(b, m, deterministic)
}
-func (dst *CloseConnectionResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CloseConnectionResponse.Merge(dst, src)
+func (m *CloseConnectionResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CloseConnectionResponse.Merge(m, src)
}
func (m *CloseConnectionResponse) XXX_Size() int {
return xxx_messageInfo_CloseConnectionResponse.Size(m)
@@ -456,16 +466,17 @@ func (m *ConnectionSyncResponse) Reset() { *m = ConnectionSyncResponse{}
func (m *ConnectionSyncResponse) String() string { return proto.CompactTextString(m) }
func (*ConnectionSyncResponse) ProtoMessage() {}
func (*ConnectionSyncResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{8}
+ return fileDescriptor_2f8192a35440e287, []int{8}
}
+
func (m *ConnectionSyncResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ConnectionSyncResponse.Unmarshal(m, b)
}
func (m *ConnectionSyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ConnectionSyncResponse.Marshal(b, m, deterministic)
}
-func (dst *ConnectionSyncResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ConnectionSyncResponse.Merge(dst, src)
+func (m *ConnectionSyncResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ConnectionSyncResponse.Merge(m, src)
}
func (m *ConnectionSyncResponse) XXX_Size() int {
return xxx_messageInfo_ConnectionSyncResponse.Size(m)
@@ -503,16 +514,17 @@ func (m *DatabasePropertyElement) Reset() { *m = DatabasePropertyElement
func (m *DatabasePropertyElement) String() string { return proto.CompactTextString(m) }
func (*DatabasePropertyElement) ProtoMessage() {}
func (*DatabasePropertyElement) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{9}
+ return fileDescriptor_2f8192a35440e287, []int{9}
}
+
func (m *DatabasePropertyElement) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DatabasePropertyElement.Unmarshal(m, b)
}
func (m *DatabasePropertyElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DatabasePropertyElement.Marshal(b, m, deterministic)
}
-func (dst *DatabasePropertyElement) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DatabasePropertyElement.Merge(dst, src)
+func (m *DatabasePropertyElement) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_DatabasePropertyElement.Merge(m, src)
}
func (m *DatabasePropertyElement) XXX_Size() int {
return xxx_messageInfo_DatabasePropertyElement.Size(m)
@@ -557,16 +569,17 @@ func (m *DatabasePropertyResponse) Reset() { *m = DatabasePropertyRespon
func (m *DatabasePropertyResponse) String() string { return proto.CompactTextString(m) }
func (*DatabasePropertyResponse) ProtoMessage() {}
func (*DatabasePropertyResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{10}
+ return fileDescriptor_2f8192a35440e287, []int{10}
}
+
func (m *DatabasePropertyResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DatabasePropertyResponse.Unmarshal(m, b)
}
func (m *DatabasePropertyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DatabasePropertyResponse.Marshal(b, m, deterministic)
}
-func (dst *DatabasePropertyResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_DatabasePropertyResponse.Merge(dst, src)
+func (m *DatabasePropertyResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_DatabasePropertyResponse.Merge(m, src)
}
func (m *DatabasePropertyResponse) XXX_Size() int {
return xxx_messageInfo_DatabasePropertyResponse.Size(m)
@@ -609,16 +622,17 @@ func (m *ErrorResponse) Reset() { *m = ErrorResponse{} }
func (m *ErrorResponse) String() string { return proto.CompactTextString(m) }
func (*ErrorResponse) ProtoMessage() {}
func (*ErrorResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{11}
+ return fileDescriptor_2f8192a35440e287, []int{11}
}
+
func (m *ErrorResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ErrorResponse.Unmarshal(m, b)
}
func (m *ErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ErrorResponse.Marshal(b, m, deterministic)
}
-func (dst *ErrorResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ErrorResponse.Merge(dst, src)
+func (m *ErrorResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ErrorResponse.Merge(m, src)
}
func (m *ErrorResponse) XXX_Size() int {
return xxx_messageInfo_ErrorResponse.Size(m)
@@ -691,16 +705,17 @@ func (m *SyncResultsResponse) Reset() { *m = SyncResultsResponse{} }
func (m *SyncResultsResponse) String() string { return proto.CompactTextString(m) }
func (*SyncResultsResponse) ProtoMessage() {}
func (*SyncResultsResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{12}
+ return fileDescriptor_2f8192a35440e287, []int{12}
}
+
func (m *SyncResultsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SyncResultsResponse.Unmarshal(m, b)
}
func (m *SyncResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SyncResultsResponse.Marshal(b, m, deterministic)
}
-func (dst *SyncResultsResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_SyncResultsResponse.Merge(dst, src)
+func (m *SyncResultsResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_SyncResultsResponse.Merge(m, src)
}
func (m *SyncResultsResponse) XXX_Size() int {
return xxx_messageInfo_SyncResultsResponse.Size(m)
@@ -744,16 +759,17 @@ func (m *RpcMetadata) Reset() { *m = RpcMetadata{} }
func (m *RpcMetadata) String() string { return proto.CompactTextString(m) }
func (*RpcMetadata) ProtoMessage() {}
func (*RpcMetadata) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{13}
+ return fileDescriptor_2f8192a35440e287, []int{13}
}
+
func (m *RpcMetadata) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RpcMetadata.Unmarshal(m, b)
}
func (m *RpcMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RpcMetadata.Marshal(b, m, deterministic)
}
-func (dst *RpcMetadata) XXX_Merge(src proto.Message) {
- xxx_messageInfo_RpcMetadata.Merge(dst, src)
+func (m *RpcMetadata) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_RpcMetadata.Merge(m, src)
}
func (m *RpcMetadata) XXX_Size() int {
return xxx_messageInfo_RpcMetadata.Size(m)
@@ -782,16 +798,17 @@ func (m *CommitResponse) Reset() { *m = CommitResponse{} }
func (m *CommitResponse) String() string { return proto.CompactTextString(m) }
func (*CommitResponse) ProtoMessage() {}
func (*CommitResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{14}
+ return fileDescriptor_2f8192a35440e287, []int{14}
}
+
func (m *CommitResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CommitResponse.Unmarshal(m, b)
}
func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CommitResponse.Marshal(b, m, deterministic)
}
-func (dst *CommitResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_CommitResponse.Merge(dst, src)
+func (m *CommitResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_CommitResponse.Merge(m, src)
}
func (m *CommitResponse) XXX_Size() int {
return xxx_messageInfo_CommitResponse.Size(m)
@@ -813,16 +830,17 @@ func (m *RollbackResponse) Reset() { *m = RollbackResponse{} }
func (m *RollbackResponse) String() string { return proto.CompactTextString(m) }
func (*RollbackResponse) ProtoMessage() {}
func (*RollbackResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{15}
+ return fileDescriptor_2f8192a35440e287, []int{15}
}
+
func (m *RollbackResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RollbackResponse.Unmarshal(m, b)
}
func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_RollbackResponse.Marshal(b, m, deterministic)
}
-func (dst *RollbackResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_RollbackResponse.Merge(dst, src)
+func (m *RollbackResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_RollbackResponse.Merge(m, src)
}
func (m *RollbackResponse) XXX_Size() int {
return xxx_messageInfo_RollbackResponse.Size(m)
@@ -849,16 +867,17 @@ func (m *ExecuteBatchResponse) Reset() { *m = ExecuteBatchResponse{} }
func (m *ExecuteBatchResponse) String() string { return proto.CompactTextString(m) }
func (*ExecuteBatchResponse) ProtoMessage() {}
func (*ExecuteBatchResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_responses_d38978c60cf7d175, []int{16}
+ return fileDescriptor_2f8192a35440e287, []int{16}
}
+
func (m *ExecuteBatchResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ExecuteBatchResponse.Unmarshal(m, b)
}
func (m *ExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ExecuteBatchResponse.Marshal(b, m, deterministic)
}
-func (dst *ExecuteBatchResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ExecuteBatchResponse.Merge(dst, src)
+func (m *ExecuteBatchResponse) XXX_Merge(src proto.Message) {
+ xxx_messageInfo_ExecuteBatchResponse.Merge(m, src)
}
func (m *ExecuteBatchResponse) XXX_Size() int {
return xxx_messageInfo_ExecuteBatchResponse.Size(m)
@@ -924,9 +943,9 @@ func init() {
proto.RegisterType((*ExecuteBatchResponse)(nil), "ExecuteBatchResponse")
}
-func init() { proto.RegisterFile("responses.proto", fileDescriptor_responses_d38978c60cf7d175) }
+func init() { proto.RegisterFile("responses.proto", fileDescriptor_2f8192a35440e287) }
-var fileDescriptor_responses_d38978c60cf7d175 = []byte{
+var fileDescriptor_2f8192a35440e287 = []byte{
// 802 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xcd, 0x6e, 0xdb, 0x46,
0x10, 0xc6, 0xea, 0xc7, 0x36, 0x87, 0xa4, 0x2d, 0xb3, 0x6d, 0x42, 0xf4, 0x0f, 0xb2, 0x8c, 0x20,