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 2018/08/29 04:22:25 UTC
[1/4] calcite-avatica-go git commit: [CALCITE-2500] Test against
Avatica 1.12.0 and Phoenix 5.0.0
Repository: calcite-avatica-go
Updated Branches:
refs/heads/master f5495e1de -> 5d398eec9
[CALCITE-2500] Test against Avatica 1.12.0 and Phoenix 5.0.0
Project: http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/repo
Commit: http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/commit/49fd3a4c
Tree: http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/tree/49fd3a4c
Diff: http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/diff/49fd3a4c
Branch: refs/heads/master
Commit: 49fd3a4c5908ef5151406166de1faadc92ad820f
Parents: f5495e1
Author: Francis Chuang <fr...@apache.org>
Authored: Wed Aug 29 14:01:05 2018 +1000
Committer: Francis Chuang <fr...@apache.org>
Committed: Wed Aug 29 14:01:05 2018 +1000
----------------------------------------------------------------------
.travis.yml | 3 +++
docker-compose.yml | 4 ++--
moby.yml | 4 ++--
3 files changed, 7 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/blob/49fd3a4c/.travis.yml
----------------------------------------------------------------------
diff --git a/.travis.yml b/.travis.yml
index 37d8327..94198f4 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -29,6 +29,7 @@ go:
- "1.10.x"
sudo: required
+
services:
- docker
@@ -40,7 +41,9 @@ env:
matrix:
- AVATICA_FLAVOR=PHOENIX IMAGE=boostport/hbase-phoenix-all-in-one:1.3-4.13
- AVATICA_FLAVOR=PHOENIX IMAGE=boostport/hbase-phoenix-all-in-one:1.4-4.14
+ - AVATICA_FLAVOR=PHOENIX IMAGE=boostport/hbase-phoenix-all-in-one:2.0-5.0
- AVATICA_FLAVOR=HSQLDB IMAGE=f21global/calcite-avatica:1.11.0-hypersql
+ - AVATICA_FLAVOR=HSQLDB IMAGE=f21global/calcite-avatica:1.12.0-hypersql
before_install:
- if [ $TRAVIS_GO_VERSION == "1.10.x" ]; then
http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/blob/49fd3a4c/docker-compose.yml
----------------------------------------------------------------------
diff --git a/docker-compose.yml b/docker-compose.yml
index 4f07931..4eb45f1 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -22,7 +22,7 @@ services:
HSQLDB_HOST: http://hsqldb:8765
command: sh -c "export AVATICA_FLAVOR=HSQLDB && go test -v ./...; export AVATICA_FLAVOR=PHOENIX && go test -v ./..."
phoenix:
- image: boostport/hbase-phoenix-all-in-one:1.4-4.14
+ image: boostport/hbase-phoenix-all-in-one:2.0-5.0
hsqldb:
- image: f21global/calcite-avatica:1.11.0-hypersql
+ image: f21global/calcite-avatica:1.12.0-hypersql
command: -u jdbc:hsqldb:mem:public
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/blob/49fd3a4c/moby.yml
----------------------------------------------------------------------
diff --git a/moby.yml b/moby.yml
index 62b4452..f85c051 100644
--- a/moby.yml
+++ b/moby.yml
@@ -15,10 +15,10 @@
#
services:
- id: phoenix
- image: boostport/hbase-phoenix-all-in-one:1.4-4.14
+ image: boostport/hbase-phoenix-all-in-one:2.0-5.0
- id: hsqldb
- image: f21global/calcite-avatica:1.11.0-hypersql
+ image: f21global/calcite-avatica:1.12.0-hypersql
command: -u jdbc:hsqldb:mem:public
ports:
- "8765"
[2/4] calcite-avatica-go git commit: [CALCITE-2500] Regenerate and
update protobufs to Avatica 1.12.0
Posted by fr...@apache.org.
http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/blob/5d398eec/message/responses.pb.go
----------------------------------------------------------------------
diff --git a/message/responses.pb.go b/message/responses.pb.go
index fd461f8..c2e77f6 100644
--- a/message/responses.pb.go
+++ b/message/responses.pb.go
@@ -12,22 +12,50 @@ var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
+// This is a compile-time assertion to ensure that this generated file
+// 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
+
// Response that contains a result set.
type ResultSetResponse struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
- OwnStatement bool `protobuf:"varint,3,opt,name=own_statement,json=ownStatement" json:"own_statement,omitempty"`
- Signature *Signature `protobuf:"bytes,4,opt,name=signature" json:"signature,omitempty"`
- FirstFrame *Frame `protobuf:"bytes,5,opt,name=first_frame,json=firstFrame" json:"first_frame,omitempty"`
- UpdateCount uint64 `protobuf:"varint,6,opt,name=update_count,json=updateCount" json:"update_count,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ OwnStatement bool `protobuf:"varint,3,opt,name=own_statement,json=ownStatement,proto3" json:"own_statement,omitempty"`
+ Signature *Signature `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
+ FirstFrame *Frame `protobuf:"bytes,5,opt,name=first_frame,json=firstFrame,proto3" json:"first_frame,omitempty"`
+ UpdateCount uint64 `protobuf:"varint,6,opt,name=update_count,json=updateCount,proto3" json:"update_count,omitempty"`
// with no signature nor other data.
- Metadata *RpcMetadata `protobuf:"bytes,7,opt,name=metadata" json:"metadata,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ResultSetResponse.Size(m)
+}
+func (m *ResultSetResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_ResultSetResponse.DiscardUnknown(m)
}
-func (m *ResultSetResponse) Reset() { *m = ResultSetResponse{} }
-func (m *ResultSetResponse) String() string { return proto.CompactTextString(m) }
-func (*ResultSetResponse) ProtoMessage() {}
-func (*ResultSetResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{0} }
+var xxx_messageInfo_ResultSetResponse proto.InternalMessageInfo
func (m *ResultSetResponse) GetConnectionId() string {
if m != nil {
@@ -80,15 +108,37 @@ func (m *ResultSetResponse) GetMetadata() *RpcMetadata {
// Response to PrepareAndExecuteRequest
type ExecuteResponse struct {
- Results []*ResultSetResponse `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
- MissingStatement bool `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement" json:"missing_statement,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata" json:"metadata,omitempty"`
+ Results []*ResultSetResponse `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
+ MissingStatement bool `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ExecuteResponse.Size(m)
+}
+func (m *ExecuteResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_ExecuteResponse.DiscardUnknown(m)
}
-func (m *ExecuteResponse) Reset() { *m = ExecuteResponse{} }
-func (m *ExecuteResponse) String() string { return proto.CompactTextString(m) }
-func (*ExecuteResponse) ProtoMessage() {}
-func (*ExecuteResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{1} }
+var xxx_messageInfo_ExecuteResponse proto.InternalMessageInfo
func (m *ExecuteResponse) GetResults() []*ResultSetResponse {
if m != nil {
@@ -113,14 +163,36 @@ func (m *ExecuteResponse) GetMetadata() *RpcMetadata {
// Response to PrepareRequest
type PrepareResponse struct {
- Statement *StatementHandle `protobuf:"bytes,1,opt,name=statement" json:"statement,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata" json:"metadata,omitempty"`
+ Statement *StatementHandle `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *PrepareResponse) Reset() { *m = PrepareResponse{} }
-func (m *PrepareResponse) String() string { return proto.CompactTextString(m) }
-func (*PrepareResponse) ProtoMessage() {}
-func (*PrepareResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{2} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_PrepareResponse.Size(m)
+}
+func (m *PrepareResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_PrepareResponse.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_PrepareResponse proto.InternalMessageInfo
func (m *PrepareResponse) GetStatement() *StatementHandle {
if m != nil {
@@ -138,16 +210,38 @@ func (m *PrepareResponse) GetMetadata() *RpcMetadata {
// Response to FetchRequest
type FetchResponse struct {
- Frame *Frame `protobuf:"bytes,1,opt,name=frame" json:"frame,omitempty"`
- MissingStatement bool `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement" json:"missing_statement,omitempty"`
- MissingResults bool `protobuf:"varint,3,opt,name=missing_results,json=missingResults" json:"missing_results,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,4,opt,name=metadata" json:"metadata,omitempty"`
+ Frame *Frame `protobuf:"bytes,1,opt,name=frame,proto3" json:"frame,omitempty"`
+ MissingStatement bool `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"`
+ MissingResults bool `protobuf:"varint,3,opt,name=missing_results,json=missingResults,proto3" json:"missing_results,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *FetchResponse) Reset() { *m = FetchResponse{} }
-func (m *FetchResponse) String() string { return proto.CompactTextString(m) }
-func (*FetchResponse) ProtoMessage() {}
-func (*FetchResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{3} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_FetchResponse.Size(m)
+}
+func (m *FetchResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_FetchResponse.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_FetchResponse proto.InternalMessageInfo
func (m *FetchResponse) GetFrame() *Frame {
if m != nil {
@@ -179,15 +273,37 @@ func (m *FetchResponse) GetMetadata() *RpcMetadata {
// Response to CreateStatementRequest
type CreateStatementResponse struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata" json:"metadata,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CreateStatementResponse.Size(m)
+}
+func (m *CreateStatementResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_CreateStatementResponse.DiscardUnknown(m)
}
-func (m *CreateStatementResponse) Reset() { *m = CreateStatementResponse{} }
-func (m *CreateStatementResponse) String() string { return proto.CompactTextString(m) }
-func (*CreateStatementResponse) ProtoMessage() {}
-func (*CreateStatementResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{4} }
+var xxx_messageInfo_CreateStatementResponse proto.InternalMessageInfo
func (m *CreateStatementResponse) GetConnectionId() string {
if m != nil {
@@ -212,13 +328,35 @@ func (m *CreateStatementResponse) GetMetadata() *RpcMetadata {
// Response to CloseStatementRequest
type CloseStatementResponse struct {
- Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *CloseStatementResponse) Reset() { *m = CloseStatementResponse{} }
-func (m *CloseStatementResponse) String() string { return proto.CompactTextString(m) }
-func (*CloseStatementResponse) ProtoMessage() {}
-func (*CloseStatementResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{5} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CloseStatementResponse.Size(m)
+}
+func (m *CloseStatementResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_CloseStatementResponse.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_CloseStatementResponse proto.InternalMessageInfo
func (m *CloseStatementResponse) GetMetadata() *RpcMetadata {
if m != nil {
@@ -229,13 +367,35 @@ func (m *CloseStatementResponse) GetMetadata() *RpcMetadata {
// Response to OpenConnectionRequest {
type OpenConnectionResponse struct {
- Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_OpenConnectionResponse.Size(m)
+}
+func (m *OpenConnectionResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_OpenConnectionResponse.DiscardUnknown(m)
}
-func (m *OpenConnectionResponse) Reset() { *m = OpenConnectionResponse{} }
-func (m *OpenConnectionResponse) String() string { return proto.CompactTextString(m) }
-func (*OpenConnectionResponse) ProtoMessage() {}
-func (*OpenConnectionResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{6} }
+var xxx_messageInfo_OpenConnectionResponse proto.InternalMessageInfo
func (m *OpenConnectionResponse) GetMetadata() *RpcMetadata {
if m != nil {
@@ -246,13 +406,35 @@ func (m *OpenConnectionResponse) GetMetadata() *RpcMetadata {
// Response to CloseConnectionRequest {
type CloseConnectionResponse struct {
- Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *CloseConnectionResponse) Reset() { *m = CloseConnectionResponse{} }
-func (m *CloseConnectionResponse) String() string { return proto.CompactTextString(m) }
-func (*CloseConnectionResponse) ProtoMessage() {}
-func (*CloseConnectionResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{7} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CloseConnectionResponse.Size(m)
+}
+func (m *CloseConnectionResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_CloseConnectionResponse.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_CloseConnectionResponse proto.InternalMessageInfo
func (m *CloseConnectionResponse) GetMetadata() *RpcMetadata {
if m != nil {
@@ -263,14 +445,36 @@ func (m *CloseConnectionResponse) GetMetadata() *RpcMetadata {
// Response to ConnectionSyncRequest
type ConnectionSyncResponse struct {
- ConnProps *ConnectionProperties `protobuf:"bytes,1,opt,name=conn_props,json=connProps" json:"conn_props,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata" json:"metadata,omitempty"`
+ ConnProps *ConnectionProperties `protobuf:"bytes,1,opt,name=conn_props,json=connProps,proto3" json:"conn_props,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ConnectionSyncResponse.Size(m)
+}
+func (m *ConnectionSyncResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_ConnectionSyncResponse.DiscardUnknown(m)
}
-func (m *ConnectionSyncResponse) Reset() { *m = ConnectionSyncResponse{} }
-func (m *ConnectionSyncResponse) String() string { return proto.CompactTextString(m) }
-func (*ConnectionSyncResponse) ProtoMessage() {}
-func (*ConnectionSyncResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{8} }
+var xxx_messageInfo_ConnectionSyncResponse proto.InternalMessageInfo
func (m *ConnectionSyncResponse) GetConnProps() *ConnectionProperties {
if m != nil {
@@ -287,15 +491,37 @@ func (m *ConnectionSyncResponse) GetMetadata() *RpcMetadata {
}
type DatabasePropertyElement struct {
- Key *DatabaseProperty `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
- Value *TypedValue `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata" json:"metadata,omitempty"`
+ Key *DatabaseProperty `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
+ Value *TypedValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *DatabasePropertyElement) Reset() { *m = DatabasePropertyElement{} }
-func (m *DatabasePropertyElement) String() string { return proto.CompactTextString(m) }
-func (*DatabasePropertyElement) ProtoMessage() {}
-func (*DatabasePropertyElement) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{9} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_DatabasePropertyElement.Size(m)
+}
+func (m *DatabasePropertyElement) XXX_DiscardUnknown() {
+ xxx_messageInfo_DatabasePropertyElement.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_DatabasePropertyElement proto.InternalMessageInfo
func (m *DatabasePropertyElement) GetKey() *DatabaseProperty {
if m != nil {
@@ -320,14 +546,36 @@ func (m *DatabasePropertyElement) GetMetadata() *RpcMetadata {
// Response for Meta#getDatabaseProperties()
type DatabasePropertyResponse struct {
- Props []*DatabasePropertyElement `protobuf:"bytes,1,rep,name=props" json:"props,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata" json:"metadata,omitempty"`
+ Props []*DatabasePropertyElement `protobuf:"bytes,1,rep,name=props,proto3" json:"props,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+func (m *DatabasePropertyResponse) Reset() { *m = DatabasePropertyResponse{} }
+func (m *DatabasePropertyResponse) String() string { return proto.CompactTextString(m) }
+func (*DatabasePropertyResponse) ProtoMessage() {}
+func (*DatabasePropertyResponse) Descriptor() ([]byte, []int) {
+ return fileDescriptor_responses_d38978c60cf7d175, []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_Size() int {
+ return xxx_messageInfo_DatabasePropertyResponse.Size(m)
+}
+func (m *DatabasePropertyResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_DatabasePropertyResponse.DiscardUnknown(m)
}
-func (m *DatabasePropertyResponse) Reset() { *m = DatabasePropertyResponse{} }
-func (m *DatabasePropertyResponse) String() string { return proto.CompactTextString(m) }
-func (*DatabasePropertyResponse) ProtoMessage() {}
-func (*DatabasePropertyResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{10} }
+var xxx_messageInfo_DatabasePropertyResponse proto.InternalMessageInfo
func (m *DatabasePropertyResponse) GetProps() []*DatabasePropertyElement {
if m != nil {
@@ -345,19 +593,41 @@ func (m *DatabasePropertyResponse) GetMetadata() *RpcMetadata {
// Send contextual information about some error over the wire from the server.
type ErrorResponse struct {
- Exceptions []string `protobuf:"bytes,1,rep,name=exceptions" json:"exceptions,omitempty"`
- HasExceptions bool `protobuf:"varint,7,opt,name=has_exceptions,json=hasExceptions" json:"has_exceptions,omitempty"`
- ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage" json:"error_message,omitempty"`
- Severity Severity `protobuf:"varint,3,opt,name=severity,enum=Severity" json:"severity,omitempty"`
- ErrorCode uint32 `protobuf:"varint,4,opt,name=error_code,json=errorCode" json:"error_code,omitempty"`
- SqlState string `protobuf:"bytes,5,opt,name=sql_state,json=sqlState" json:"sql_state,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,6,opt,name=metadata" json:"metadata,omitempty"`
+ Exceptions []string `protobuf:"bytes,1,rep,name=exceptions,proto3" json:"exceptions,omitempty"`
+ HasExceptions bool `protobuf:"varint,7,opt,name=has_exceptions,json=hasExceptions,proto3" json:"has_exceptions,omitempty"`
+ ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
+ Severity Severity `protobuf:"varint,3,opt,name=severity,proto3,enum=Severity" json:"severity,omitempty"`
+ ErrorCode uint32 `protobuf:"varint,4,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
+ SqlState string `protobuf:"bytes,5,opt,name=sql_state,json=sqlState,proto3" json:"sql_state,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *ErrorResponse) Reset() { *m = ErrorResponse{} }
-func (m *ErrorResponse) String() string { return proto.CompactTextString(m) }
-func (*ErrorResponse) ProtoMessage() {}
-func (*ErrorResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{11} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ErrorResponse.Size(m)
+}
+func (m *ErrorResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_ErrorResponse.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_ErrorResponse proto.InternalMessageInfo
func (m *ErrorResponse) GetExceptions() []string {
if m != nil {
@@ -409,15 +679,37 @@ func (m *ErrorResponse) GetMetadata() *RpcMetadata {
}
type SyncResultsResponse struct {
- MissingStatement bool `protobuf:"varint,1,opt,name=missing_statement,json=missingStatement" json:"missing_statement,omitempty"`
- MoreResults bool `protobuf:"varint,2,opt,name=more_results,json=moreResults" json:"more_results,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata" json:"metadata,omitempty"`
+ MissingStatement bool `protobuf:"varint,1,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"`
+ MoreResults bool `protobuf:"varint,2,opt,name=more_results,json=moreResults,proto3" json:"more_results,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_SyncResultsResponse.Size(m)
+}
+func (m *SyncResultsResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_SyncResultsResponse.DiscardUnknown(m)
}
-func (m *SyncResultsResponse) Reset() { *m = SyncResultsResponse{} }
-func (m *SyncResultsResponse) String() string { return proto.CompactTextString(m) }
-func (*SyncResultsResponse) ProtoMessage() {}
-func (*SyncResultsResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{12} }
+var xxx_messageInfo_SyncResultsResponse proto.InternalMessageInfo
func (m *SyncResultsResponse) GetMissingStatement() bool {
if m != nil {
@@ -442,13 +734,35 @@ func (m *SyncResultsResponse) GetMetadata() *RpcMetadata {
// Generic metadata for the server to return with each response.
type RpcMetadata struct {
- ServerAddress string `protobuf:"bytes,1,opt,name=server_address,json=serverAddress" json:"server_address,omitempty"`
+ ServerAddress string `protobuf:"bytes,1,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *RpcMetadata) Reset() { *m = RpcMetadata{} }
-func (m *RpcMetadata) String() string { return proto.CompactTextString(m) }
-func (*RpcMetadata) ProtoMessage() {}
-func (*RpcMetadata) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{13} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_RpcMetadata.Size(m)
+}
+func (m *RpcMetadata) XXX_DiscardUnknown() {
+ xxx_messageInfo_RpcMetadata.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_RpcMetadata proto.InternalMessageInfo
func (m *RpcMetadata) GetServerAddress() string {
if m != nil {
@@ -459,35 +773,101 @@ func (m *RpcMetadata) GetServerAddress() string {
// Response to a commit request
type CommitResponse struct {
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CommitResponse.Size(m)
+}
+func (m *CommitResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_CommitResponse.DiscardUnknown(m)
}
-func (m *CommitResponse) Reset() { *m = CommitResponse{} }
-func (m *CommitResponse) String() string { return proto.CompactTextString(m) }
-func (*CommitResponse) ProtoMessage() {}
-func (*CommitResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{14} }
+var xxx_messageInfo_CommitResponse proto.InternalMessageInfo
// Response to a rollback request
type RollbackResponse struct {
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_RollbackResponse.Size(m)
+}
+func (m *RollbackResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_RollbackResponse.DiscardUnknown(m)
}
-func (m *RollbackResponse) Reset() { *m = RollbackResponse{} }
-func (m *RollbackResponse) String() string { return proto.CompactTextString(m) }
-func (*RollbackResponse) ProtoMessage() {}
-func (*RollbackResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{15} }
+var xxx_messageInfo_RollbackResponse proto.InternalMessageInfo
// Response to a batch update request
type ExecuteBatchResponse struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
- UpdateCounts []uint64 `protobuf:"varint,3,rep,packed,name=update_counts,json=updateCounts" json:"update_counts,omitempty"`
- MissingStatement bool `protobuf:"varint,4,opt,name=missing_statement,json=missingStatement" json:"missing_statement,omitempty"`
- Metadata *RpcMetadata `protobuf:"bytes,5,opt,name=metadata" json:"metadata,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ UpdateCounts []uint64 `protobuf:"varint,3,rep,packed,name=update_counts,json=updateCounts,proto3" json:"update_counts,omitempty"`
+ MissingStatement bool `protobuf:"varint,4,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"`
+ Metadata *RpcMetadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ExecuteBatchResponse.Size(m)
+}
+func (m *ExecuteBatchResponse) XXX_DiscardUnknown() {
+ xxx_messageInfo_ExecuteBatchResponse.DiscardUnknown(m)
}
-func (m *ExecuteBatchResponse) Reset() { *m = ExecuteBatchResponse{} }
-func (m *ExecuteBatchResponse) String() string { return proto.CompactTextString(m) }
-func (*ExecuteBatchResponse) ProtoMessage() {}
-func (*ExecuteBatchResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{16} }
+var xxx_messageInfo_ExecuteBatchResponse proto.InternalMessageInfo
func (m *ExecuteBatchResponse) GetConnectionId() string {
if m != nil {
@@ -544,9 +924,9 @@ func init() {
proto.RegisterType((*ExecuteBatchResponse)(nil), "ExecuteBatchResponse")
}
-func init() { proto.RegisterFile("responses.proto", fileDescriptor2) }
+func init() { proto.RegisterFile("responses.proto", fileDescriptor_responses_d38978c60cf7d175) }
-var fileDescriptor2 = []byte{
+var fileDescriptor_responses_d38978c60cf7d175 = []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,
[3/4] calcite-avatica-go git commit: [CALCITE-2500] Regenerate and
update protobufs to Avatica 1.12.0
Posted by fr...@apache.org.
http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/blob/5d398eec/message/requests.pb.go
----------------------------------------------------------------------
diff --git a/message/requests.pb.go b/message/requests.pb.go
index 64b7332..e844f77 100644
--- a/message/requests.pb.go
+++ b/message/requests.pb.go
@@ -12,15 +12,43 @@ var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
+// This is a compile-time assertion to ensure that this generated file
+// 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
+
// Request for Meta#getCatalogs()
type CatalogsRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CatalogsRequest.Size(m)
+}
+func (m *CatalogsRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_CatalogsRequest.DiscardUnknown(m)
}
-func (m *CatalogsRequest) Reset() { *m = CatalogsRequest{} }
-func (m *CatalogsRequest) String() string { return proto.CompactTextString(m) }
-func (*CatalogsRequest) ProtoMessage() {}
-func (*CatalogsRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{0} }
+var xxx_messageInfo_CatalogsRequest proto.InternalMessageInfo
func (m *CatalogsRequest) GetConnectionId() string {
if m != nil {
@@ -31,13 +59,35 @@ func (m *CatalogsRequest) GetConnectionId() string {
// Request for Meta#getDatabaseProperties()
type DatabasePropertyRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_DatabasePropertyRequest.Size(m)
+}
+func (m *DatabasePropertyRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_DatabasePropertyRequest.DiscardUnknown(m)
}
-func (m *DatabasePropertyRequest) Reset() { *m = DatabasePropertyRequest{} }
-func (m *DatabasePropertyRequest) String() string { return proto.CompactTextString(m) }
-func (*DatabasePropertyRequest) ProtoMessage() {}
-func (*DatabasePropertyRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{1} }
+var xxx_messageInfo_DatabasePropertyRequest proto.InternalMessageInfo
func (m *DatabasePropertyRequest) GetConnectionId() string {
if m != nil {
@@ -48,15 +98,37 @@ func (m *DatabasePropertyRequest) GetConnectionId() string {
// Request for Meta#getSchemas(String, org.apache.calcite.avatica.Meta.Pat)}
type SchemasRequest struct {
- Catalog string `protobuf:"bytes,1,opt,name=catalog" json:"catalog,omitempty"`
- SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern" json:"schema_pattern,omitempty"`
- ConnectionId string `protobuf:"bytes,3,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
+ SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
+ ConnectionId string `protobuf:"bytes,3,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *SchemasRequest) Reset() { *m = SchemasRequest{} }
-func (m *SchemasRequest) String() string { return proto.CompactTextString(m) }
-func (*SchemasRequest) ProtoMessage() {}
-func (*SchemasRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{2} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_SchemasRequest.Size(m)
+}
+func (m *SchemasRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_SchemasRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_SchemasRequest proto.InternalMessageInfo
func (m *SchemasRequest) GetCatalog() string {
if m != nil {
@@ -82,18 +154,40 @@ func (m *SchemasRequest) GetConnectionId() string {
// Request for Request for Meta#getTables(String, org.apache.calcite.avatica.Meta.Pat,
// org.apache.calcite.avatica.Meta.Pat, java.util.List)
type TablesRequest struct {
- Catalog string `protobuf:"bytes,1,opt,name=catalog" json:"catalog,omitempty"`
- SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern" json:"schema_pattern,omitempty"`
- TableNamePattern string `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern" json:"table_name_pattern,omitempty"`
- TypeList []string `protobuf:"bytes,4,rep,name=type_list,json=typeList" json:"type_list,omitempty"`
- HasTypeList bool `protobuf:"varint,6,opt,name=has_type_list,json=hasTypeList" json:"has_type_list,omitempty"`
- ConnectionId string `protobuf:"bytes,7,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
+ SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
+ TableNamePattern string `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern,proto3" json:"table_name_pattern,omitempty"`
+ TypeList []string `protobuf:"bytes,4,rep,name=type_list,json=typeList,proto3" json:"type_list,omitempty"`
+ HasTypeList bool `protobuf:"varint,6,opt,name=has_type_list,json=hasTypeList,proto3" json:"has_type_list,omitempty"`
+ ConnectionId string `protobuf:"bytes,7,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_TablesRequest.Size(m)
+}
+func (m *TablesRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_TablesRequest.DiscardUnknown(m)
}
-func (m *TablesRequest) Reset() { *m = TablesRequest{} }
-func (m *TablesRequest) String() string { return proto.CompactTextString(m) }
-func (*TablesRequest) ProtoMessage() {}
-func (*TablesRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{3} }
+var xxx_messageInfo_TablesRequest proto.InternalMessageInfo
func (m *TablesRequest) GetCatalog() string {
if m != nil {
@@ -139,13 +233,35 @@ func (m *TablesRequest) GetConnectionId() string {
// Request for Meta#getTableTypes()
type TableTypesRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *TableTypesRequest) Reset() { *m = TableTypesRequest{} }
-func (m *TableTypesRequest) String() string { return proto.CompactTextString(m) }
-func (*TableTypesRequest) ProtoMessage() {}
-func (*TableTypesRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{4} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_TableTypesRequest.Size(m)
+}
+func (m *TableTypesRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_TableTypesRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_TableTypesRequest proto.InternalMessageInfo
func (m *TableTypesRequest) GetConnectionId() string {
if m != nil {
@@ -157,17 +273,39 @@ func (m *TableTypesRequest) GetConnectionId() string {
// Request for Meta#getColumns(String, org.apache.calcite.avatica.Meta.Pat,
// org.apache.calcite.avatica.Meta.Pat, org.apache.calcite.avatica.Meta.Pat).
type ColumnsRequest struct {
- Catalog string `protobuf:"bytes,1,opt,name=catalog" json:"catalog,omitempty"`
- SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern" json:"schema_pattern,omitempty"`
- TableNamePattern string `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern" json:"table_name_pattern,omitempty"`
- ColumnNamePattern string `protobuf:"bytes,4,opt,name=column_name_pattern,json=columnNamePattern" json:"column_name_pattern,omitempty"`
- ConnectionId string `protobuf:"bytes,5,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ Catalog string `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
+ SchemaPattern string `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
+ TableNamePattern string `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern,proto3" json:"table_name_pattern,omitempty"`
+ ColumnNamePattern string `protobuf:"bytes,4,opt,name=column_name_pattern,json=columnNamePattern,proto3" json:"column_name_pattern,omitempty"`
+ ConnectionId string `protobuf:"bytes,5,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ColumnsRequest.Size(m)
+}
+func (m *ColumnsRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_ColumnsRequest.DiscardUnknown(m)
}
-func (m *ColumnsRequest) Reset() { *m = ColumnsRequest{} }
-func (m *ColumnsRequest) String() string { return proto.CompactTextString(m) }
-func (*ColumnsRequest) ProtoMessage() {}
-func (*ColumnsRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{5} }
+var xxx_messageInfo_ColumnsRequest proto.InternalMessageInfo
func (m *ColumnsRequest) GetCatalog() string {
if m != nil {
@@ -206,13 +344,35 @@ func (m *ColumnsRequest) GetConnectionId() string {
// Request for Meta#getTypeInfo()
type TypeInfoRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_TypeInfoRequest.Size(m)
+}
+func (m *TypeInfoRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_TypeInfoRequest.DiscardUnknown(m)
}
-func (m *TypeInfoRequest) Reset() { *m = TypeInfoRequest{} }
-func (m *TypeInfoRequest) String() string { return proto.CompactTextString(m) }
-func (*TypeInfoRequest) ProtoMessage() {}
-func (*TypeInfoRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{6} }
+var xxx_messageInfo_TypeInfoRequest proto.InternalMessageInfo
func (m *TypeInfoRequest) GetConnectionId() string {
if m != nil {
@@ -223,18 +383,40 @@ func (m *TypeInfoRequest) GetConnectionId() string {
// Request for Meta#prepareAndExecute(Meta.StatementHandle, String, long, Meta.PrepareCallback)
type PrepareAndExecuteRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- Sql string `protobuf:"bytes,2,opt,name=sql" json:"sql,omitempty"`
- MaxRowCount uint64 `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount" json:"max_row_count,omitempty"`
- StatementId uint32 `protobuf:"varint,4,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
- MaxRowsTotal int64 `protobuf:"varint,5,opt,name=max_rows_total,json=maxRowsTotal" json:"max_rows_total,omitempty"`
- FirstFrameMaxSize int32 `protobuf:"varint,6,opt,name=first_frame_max_size,json=firstFrameMaxSize" json:"first_frame_max_size,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
+ MaxRowCount uint64 `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount,proto3" json:"max_row_count,omitempty"`
+ StatementId uint32 `protobuf:"varint,4,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ MaxRowsTotal int64 `protobuf:"varint,5,opt,name=max_rows_total,json=maxRowsTotal,proto3" json:"max_rows_total,omitempty"`
+ FirstFrameMaxSize int32 `protobuf:"varint,6,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3" json:"first_frame_max_size,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+func (m *PrepareAndExecuteRequest) Reset() { *m = PrepareAndExecuteRequest{} }
+func (m *PrepareAndExecuteRequest) String() string { return proto.CompactTextString(m) }
+func (*PrepareAndExecuteRequest) ProtoMessage() {}
+func (*PrepareAndExecuteRequest) Descriptor() ([]byte, []int) {
+ return fileDescriptor_requests_f149f33d924311f5, []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_Size() int {
+ return xxx_messageInfo_PrepareAndExecuteRequest.Size(m)
+}
+func (m *PrepareAndExecuteRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_PrepareAndExecuteRequest.DiscardUnknown(m)
}
-func (m *PrepareAndExecuteRequest) Reset() { *m = PrepareAndExecuteRequest{} }
-func (m *PrepareAndExecuteRequest) String() string { return proto.CompactTextString(m) }
-func (*PrepareAndExecuteRequest) ProtoMessage() {}
-func (*PrepareAndExecuteRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{7} }
+var xxx_messageInfo_PrepareAndExecuteRequest proto.InternalMessageInfo
func (m *PrepareAndExecuteRequest) GetConnectionId() string {
if m != nil {
@@ -280,16 +462,38 @@ func (m *PrepareAndExecuteRequest) GetFirstFrameMaxSize() int32 {
// Request for Meta.prepare(Meta.ConnectionHandle, String, long)
type PrepareRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- Sql string `protobuf:"bytes,2,opt,name=sql" json:"sql,omitempty"`
- MaxRowCount uint64 `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount" json:"max_row_count,omitempty"`
- MaxRowsTotal int64 `protobuf:"varint,4,opt,name=max_rows_total,json=maxRowsTotal" json:"max_rows_total,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
+ MaxRowCount uint64 `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount,proto3" json:"max_row_count,omitempty"`
+ MaxRowsTotal int64 `protobuf:"varint,4,opt,name=max_rows_total,json=maxRowsTotal,proto3" json:"max_rows_total,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *PrepareRequest) Reset() { *m = PrepareRequest{} }
-func (m *PrepareRequest) String() string { return proto.CompactTextString(m) }
-func (*PrepareRequest) ProtoMessage() {}
-func (*PrepareRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{8} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_PrepareRequest.Size(m)
+}
+func (m *PrepareRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_PrepareRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_PrepareRequest proto.InternalMessageInfo
func (m *PrepareRequest) GetConnectionId() string {
if m != nil {
@@ -321,17 +525,39 @@ func (m *PrepareRequest) GetMaxRowsTotal() int64 {
// Request for Meta#fetch(Meta.StatementHandle, List, long, int)
type FetchRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
- Offset uint64 `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
- FetchMaxRowCount uint32 `protobuf:"varint,4,opt,name=fetch_max_row_count,json=fetchMaxRowCount" json:"fetch_max_row_count,omitempty"`
- FrameMaxSize int32 `protobuf:"varint,5,opt,name=frame_max_size,json=frameMaxSize" json:"frame_max_size,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
+ FetchMaxRowCount uint32 `protobuf:"varint,4,opt,name=fetch_max_row_count,json=fetchMaxRowCount,proto3" json:"fetch_max_row_count,omitempty"`
+ FrameMaxSize int32 `protobuf:"varint,5,opt,name=frame_max_size,json=frameMaxSize,proto3" json:"frame_max_size,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *FetchRequest) Reset() { *m = FetchRequest{} }
-func (m *FetchRequest) String() string { return proto.CompactTextString(m) }
-func (*FetchRequest) ProtoMessage() {}
-func (*FetchRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{9} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_FetchRequest.Size(m)
+}
+func (m *FetchRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_FetchRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_FetchRequest proto.InternalMessageInfo
func (m *FetchRequest) GetConnectionId() string {
if m != nil {
@@ -370,13 +596,35 @@ func (m *FetchRequest) GetFrameMaxSize() int32 {
// Request for Meta#createStatement(Meta.ConnectionHandle)
type CreateStatementRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CreateStatementRequest.Size(m)
+}
+func (m *CreateStatementRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_CreateStatementRequest.DiscardUnknown(m)
}
-func (m *CreateStatementRequest) Reset() { *m = CreateStatementRequest{} }
-func (m *CreateStatementRequest) String() string { return proto.CompactTextString(m) }
-func (*CreateStatementRequest) ProtoMessage() {}
-func (*CreateStatementRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{10} }
+var xxx_messageInfo_CreateStatementRequest proto.InternalMessageInfo
func (m *CreateStatementRequest) GetConnectionId() string {
if m != nil {
@@ -387,14 +635,36 @@ func (m *CreateStatementRequest) GetConnectionId() string {
// Request for Meta#closeStatement(Meta.StatementHandle)
type CloseStatementRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *CloseStatementRequest) Reset() { *m = CloseStatementRequest{} }
-func (m *CloseStatementRequest) String() string { return proto.CompactTextString(m) }
-func (*CloseStatementRequest) ProtoMessage() {}
-func (*CloseStatementRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{11} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CloseStatementRequest.Size(m)
+}
+func (m *CloseStatementRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_CloseStatementRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_CloseStatementRequest proto.InternalMessageInfo
func (m *CloseStatementRequest) GetConnectionId() string {
if m != nil {
@@ -412,14 +682,36 @@ func (m *CloseStatementRequest) GetStatementId() uint32 {
// Request for Meta#openConnection(Meta.ConnectionHandle, Map<String, String>)
type OpenConnectionRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- Info map[string]string `protobuf:"bytes,2,rep,name=info" json:"info,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ Info map[string]string `protobuf:"bytes,2,rep,name=info,proto3" json:"info,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_OpenConnectionRequest.Size(m)
+}
+func (m *OpenConnectionRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_OpenConnectionRequest.DiscardUnknown(m)
}
-func (m *OpenConnectionRequest) Reset() { *m = OpenConnectionRequest{} }
-func (m *OpenConnectionRequest) String() string { return proto.CompactTextString(m) }
-func (*OpenConnectionRequest) ProtoMessage() {}
-func (*OpenConnectionRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{12} }
+var xxx_messageInfo_OpenConnectionRequest proto.InternalMessageInfo
func (m *OpenConnectionRequest) GetConnectionId() string {
if m != nil {
@@ -437,13 +729,35 @@ func (m *OpenConnectionRequest) GetInfo() map[string]string {
// Request for Meta#closeConnection(Meta.ConnectionHandle)
type CloseConnectionRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *CloseConnectionRequest) Reset() { *m = CloseConnectionRequest{} }
-func (m *CloseConnectionRequest) String() string { return proto.CompactTextString(m) }
-func (*CloseConnectionRequest) ProtoMessage() {}
-func (*CloseConnectionRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{13} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CloseConnectionRequest.Size(m)
+}
+func (m *CloseConnectionRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_CloseConnectionRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_CloseConnectionRequest proto.InternalMessageInfo
func (m *CloseConnectionRequest) GetConnectionId() string {
if m != nil {
@@ -453,14 +767,36 @@ func (m *CloseConnectionRequest) GetConnectionId() string {
}
type ConnectionSyncRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- ConnProps *ConnectionProperties `protobuf:"bytes,2,opt,name=conn_props,json=connProps" json:"conn_props,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ ConnProps *ConnectionProperties `protobuf:"bytes,2,opt,name=conn_props,json=connProps,proto3" json:"conn_props,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ConnectionSyncRequest.Size(m)
+}
+func (m *ConnectionSyncRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_ConnectionSyncRequest.DiscardUnknown(m)
}
-func (m *ConnectionSyncRequest) Reset() { *m = ConnectionSyncRequest{} }
-func (m *ConnectionSyncRequest) String() string { return proto.CompactTextString(m) }
-func (*ConnectionSyncRequest) ProtoMessage() {}
-func (*ConnectionSyncRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{14} }
+var xxx_messageInfo_ConnectionSyncRequest proto.InternalMessageInfo
func (m *ConnectionSyncRequest) GetConnectionId() string {
if m != nil {
@@ -478,17 +814,39 @@ func (m *ConnectionSyncRequest) GetConnProps() *ConnectionProperties {
// Request for Meta#execute(Meta.ConnectionHandle, list, long)
type ExecuteRequest struct {
- StatementHandle *StatementHandle `protobuf:"bytes,1,opt,name=statementHandle" json:"statementHandle,omitempty"`
- ParameterValues []*TypedValue `protobuf:"bytes,2,rep,name=parameter_values,json=parameterValues" json:"parameter_values,omitempty"`
- DeprecatedFirstFrameMaxSize uint64 `protobuf:"varint,3,opt,name=deprecated_first_frame_max_size,json=deprecatedFirstFrameMaxSize" json:"deprecated_first_frame_max_size,omitempty"`
- HasParameterValues bool `protobuf:"varint,4,opt,name=has_parameter_values,json=hasParameterValues" json:"has_parameter_values,omitempty"`
- FirstFrameMaxSize int32 `protobuf:"varint,5,opt,name=first_frame_max_size,json=firstFrameMaxSize" json:"first_frame_max_size,omitempty"`
+ StatementHandle *StatementHandle `protobuf:"bytes,1,opt,name=statementHandle,proto3" json:"statementHandle,omitempty"`
+ ParameterValues []*TypedValue `protobuf:"bytes,2,rep,name=parameter_values,json=parameterValues,proto3" json:"parameter_values,omitempty"`
+ DeprecatedFirstFrameMaxSize uint64 `protobuf:"varint,3,opt,name=deprecated_first_frame_max_size,json=deprecatedFirstFrameMaxSize,proto3" json:"deprecated_first_frame_max_size,omitempty"`
+ HasParameterValues bool `protobuf:"varint,4,opt,name=has_parameter_values,json=hasParameterValues,proto3" json:"has_parameter_values,omitempty"`
+ FirstFrameMaxSize int32 `protobuf:"varint,5,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3" json:"first_frame_max_size,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *ExecuteRequest) Reset() { *m = ExecuteRequest{} }
-func (m *ExecuteRequest) String() string { return proto.CompactTextString(m) }
-func (*ExecuteRequest) ProtoMessage() {}
-func (*ExecuteRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{15} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ExecuteRequest.Size(m)
+}
+func (m *ExecuteRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_ExecuteRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_ExecuteRequest proto.InternalMessageInfo
func (m *ExecuteRequest) GetStatementHandle() *StatementHandle {
if m != nil {
@@ -526,16 +884,38 @@ func (m *ExecuteRequest) GetFirstFrameMaxSize() int32 {
}
type SyncResultsRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
- State *QueryState `protobuf:"bytes,3,opt,name=state" json:"state,omitempty"`
- Offset uint64 `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ State *QueryState `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
+ Offset uint64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *SyncResultsRequest) Reset() { *m = SyncResultsRequest{} }
-func (m *SyncResultsRequest) String() string { return proto.CompactTextString(m) }
-func (*SyncResultsRequest) ProtoMessage() {}
-func (*SyncResultsRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{16} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_SyncResultsRequest.Size(m)
+}
+func (m *SyncResultsRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_SyncResultsRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_SyncResultsRequest proto.InternalMessageInfo
func (m *SyncResultsRequest) GetConnectionId() string {
if m != nil {
@@ -567,13 +947,35 @@ func (m *SyncResultsRequest) GetOffset() uint64 {
// Request to invoke a commit on a Connection
type CommitRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CommitRequest.Size(m)
+}
+func (m *CommitRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_CommitRequest.DiscardUnknown(m)
}
-func (m *CommitRequest) Reset() { *m = CommitRequest{} }
-func (m *CommitRequest) String() string { return proto.CompactTextString(m) }
-func (*CommitRequest) ProtoMessage() {}
-func (*CommitRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{17} }
+var xxx_messageInfo_CommitRequest proto.InternalMessageInfo
func (m *CommitRequest) GetConnectionId() string {
if m != nil {
@@ -584,13 +986,35 @@ func (m *CommitRequest) GetConnectionId() string {
// Request to invoke rollback on a Connection
type RollbackRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *RollbackRequest) Reset() { *m = RollbackRequest{} }
-func (m *RollbackRequest) String() string { return proto.CompactTextString(m) }
-func (*RollbackRequest) ProtoMessage() {}
-func (*RollbackRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{18} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_RollbackRequest.Size(m)
+}
+func (m *RollbackRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_RollbackRequest.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_RollbackRequest proto.InternalMessageInfo
func (m *RollbackRequest) GetConnectionId() string {
if m != nil {
@@ -601,15 +1025,37 @@ func (m *RollbackRequest) GetConnectionId() string {
// Request to prepare and execute a collection of sql statements.
type PrepareAndExecuteBatchRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
- SqlCommands []string `protobuf:"bytes,3,rep,name=sql_commands,json=sqlCommands" json:"sql_commands,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ SqlCommands []string `protobuf:"bytes,3,rep,name=sql_commands,json=sqlCommands,proto3" json:"sql_commands,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+func (m *PrepareAndExecuteBatchRequest) Reset() { *m = PrepareAndExecuteBatchRequest{} }
+func (m *PrepareAndExecuteBatchRequest) String() string { return proto.CompactTextString(m) }
+func (*PrepareAndExecuteBatchRequest) ProtoMessage() {}
+func (*PrepareAndExecuteBatchRequest) Descriptor() ([]byte, []int) {
+ return fileDescriptor_requests_f149f33d924311f5, []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_Size() int {
+ return xxx_messageInfo_PrepareAndExecuteBatchRequest.Size(m)
+}
+func (m *PrepareAndExecuteBatchRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_PrepareAndExecuteBatchRequest.DiscardUnknown(m)
}
-func (m *PrepareAndExecuteBatchRequest) Reset() { *m = PrepareAndExecuteBatchRequest{} }
-func (m *PrepareAndExecuteBatchRequest) String() string { return proto.CompactTextString(m) }
-func (*PrepareAndExecuteBatchRequest) ProtoMessage() {}
-func (*PrepareAndExecuteBatchRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{19} }
+var xxx_messageInfo_PrepareAndExecuteBatchRequest proto.InternalMessageInfo
func (m *PrepareAndExecuteBatchRequest) GetConnectionId() string {
if m != nil {
@@ -634,13 +1080,35 @@ func (m *PrepareAndExecuteBatchRequest) GetSqlCommands() []string {
// Each command is a list of TypedValues
type UpdateBatch struct {
- ParameterValues []*TypedValue `protobuf:"bytes,1,rep,name=parameter_values,json=parameterValues" json:"parameter_values,omitempty"`
+ ParameterValues []*TypedValue `protobuf:"bytes,1,rep,name=parameter_values,json=parameterValues,proto3" json:"parameter_values,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *UpdateBatch) Reset() { *m = UpdateBatch{} }
-func (m *UpdateBatch) String() string { return proto.CompactTextString(m) }
-func (*UpdateBatch) ProtoMessage() {}
-func (*UpdateBatch) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{20} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_UpdateBatch.Size(m)
+}
+func (m *UpdateBatch) XXX_DiscardUnknown() {
+ xxx_messageInfo_UpdateBatch.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_UpdateBatch proto.InternalMessageInfo
func (m *UpdateBatch) GetParameterValues() []*TypedValue {
if m != nil {
@@ -650,15 +1118,37 @@ func (m *UpdateBatch) GetParameterValues() []*TypedValue {
}
type ExecuteBatchRequest struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId" json:"statement_id,omitempty"`
- Updates []*UpdateBatch `protobuf:"bytes,3,rep,name=updates" json:"updates,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ StatementId uint32 `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
+ Updates []*UpdateBatch `protobuf:"bytes,3,rep,name=updates,proto3" json:"updates,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ExecuteBatchRequest.Size(m)
+}
+func (m *ExecuteBatchRequest) XXX_DiscardUnknown() {
+ xxx_messageInfo_ExecuteBatchRequest.DiscardUnknown(m)
}
-func (m *ExecuteBatchRequest) Reset() { *m = ExecuteBatchRequest{} }
-func (m *ExecuteBatchRequest) String() string { return proto.CompactTextString(m) }
-func (*ExecuteBatchRequest) ProtoMessage() {}
-func (*ExecuteBatchRequest) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{21} }
+var xxx_messageInfo_ExecuteBatchRequest proto.InternalMessageInfo
func (m *ExecuteBatchRequest) GetConnectionId() string {
if m != nil {
@@ -695,6 +1185,7 @@ func init() {
proto.RegisterType((*CreateStatementRequest)(nil), "CreateStatementRequest")
proto.RegisterType((*CloseStatementRequest)(nil), "CloseStatementRequest")
proto.RegisterType((*OpenConnectionRequest)(nil), "OpenConnectionRequest")
+ proto.RegisterMapType((map[string]string)(nil), "OpenConnectionRequest.InfoEntry")
proto.RegisterType((*CloseConnectionRequest)(nil), "CloseConnectionRequest")
proto.RegisterType((*ConnectionSyncRequest)(nil), "ConnectionSyncRequest")
proto.RegisterType((*ExecuteRequest)(nil), "ExecuteRequest")
@@ -706,9 +1197,9 @@ func init() {
proto.RegisterType((*ExecuteBatchRequest)(nil), "ExecuteBatchRequest")
}
-func init() { proto.RegisterFile("requests.proto", fileDescriptor1) }
+func init() { proto.RegisterFile("requests.proto", fileDescriptor_requests_f149f33d924311f5) }
-var fileDescriptor1 = []byte{
+var fileDescriptor_requests_f149f33d924311f5 = []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,
[4/4] calcite-avatica-go git commit: [CALCITE-2500] Regenerate and
update protobufs to Avatica 1.12.0
Posted by fr...@apache.org.
[CALCITE-2500] Regenerate and update protobufs to Avatica 1.12.0
Project: http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/repo
Commit: http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/commit/5d398eec
Tree: http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/tree/5d398eec
Diff: http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/diff/5d398eec
Branch: refs/heads/master
Commit: 5d398eec9cf761957114b162d5bbba535a125666
Parents: 49fd3a4
Author: Francis Chuang <fr...@apache.org>
Authored: Wed Aug 29 14:16:33 2018 +1000
Committer: Francis Chuang <fr...@apache.org>
Committed: Wed Aug 29 14:16:33 2018 +1000
----------------------------------------------------------------------
gen-protobuf.sh | 2 +-
message/common.pb.go | 720 +++++++++++++++++++++++++++------------
message/requests.pb.go | 789 +++++++++++++++++++++++++++++++++++--------
message/responses.pb.go | 610 ++++++++++++++++++++++++++-------
4 files changed, 1635 insertions(+), 486 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/blob/5d398eec/gen-protobuf.sh
----------------------------------------------------------------------
diff --git a/gen-protobuf.sh b/gen-protobuf.sh
index 55b236f..4029672 100644
--- a/gen-protobuf.sh
+++ b/gen-protobuf.sh
@@ -18,7 +18,7 @@ set -e
rm -rf message avatica-tmp
-export AVATICA_VER="rel/avatica-1.11.0"
+export AVATICA_VER="rel/avatica-1.12.0"s
mkdir -p avatica-tmp
pushd avatica-tmp &> /dev/null
http://git-wip-us.apache.org/repos/asf/calcite-avatica-go/blob/5d398eec/message/common.pb.go
----------------------------------------------------------------------
diff --git a/message/common.pb.go b/message/common.pb.go
index dfc3514..6e93358 100644
--- a/message/common.pb.go
+++ b/message/common.pb.go
@@ -1,70 +1,6 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: common.proto
-/*
-Package message is a generated protocol buffer package.
-
-It is generated from these files:
- common.proto
- requests.proto
- responses.proto
-
-It has these top-level messages:
- ConnectionProperties
- StatementHandle
- Signature
- ColumnMetaData
- AvaticaType
- AvaticaParameter
- CursorFactory
- Frame
- Row
- DatabaseProperty
- WireMessage
- ColumnValue
- TypedValue
- MetaDataOperationArgument
- QueryState
- CatalogsRequest
- DatabasePropertyRequest
- SchemasRequest
- TablesRequest
- TableTypesRequest
- ColumnsRequest
- TypeInfoRequest
- PrepareAndExecuteRequest
- PrepareRequest
- FetchRequest
- CreateStatementRequest
- CloseStatementRequest
- OpenConnectionRequest
- CloseConnectionRequest
- ConnectionSyncRequest
- ExecuteRequest
- SyncResultsRequest
- CommitRequest
- RollbackRequest
- PrepareAndExecuteBatchRequest
- UpdateBatch
- ExecuteBatchRequest
- ResultSetResponse
- ExecuteResponse
- PrepareResponse
- FetchResponse
- CreateStatementResponse
- CloseStatementResponse
- OpenConnectionResponse
- CloseConnectionResponse
- ConnectionSyncResponse
- DatabasePropertyElement
- DatabasePropertyResponse
- ErrorResponse
- SyncResultsResponse
- RpcMetadata
- CommitResponse
- RollbackResponse
- ExecuteBatchResponse
-*/
package message
import proto "github.com/golang/protobuf/proto"
@@ -132,7 +68,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 fileDescriptor0, []int{0} }
+func (StatementType) EnumDescriptor() ([]byte, []int) {
+ return fileDescriptor_common_84e383fbabed0a31, []int{0}
+}
type Rep int32
@@ -237,7 +175,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 fileDescriptor0, []int{1} }
+func (Rep) EnumDescriptor() ([]byte, []int) {
+ return fileDescriptor_common_84e383fbabed0a31, []int{1}
+}
// The severity of some unexpected outcome to an operation.
// Protobuf enum values must be unique across all other enums
@@ -266,7 +206,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 fileDescriptor0, []int{2} }
+func (Severity) EnumDescriptor() ([]byte, []int) {
+ return fileDescriptor_common_84e383fbabed0a31, []int{2}
+}
// Enumeration corresponding to DatabaseMetaData operations
type MetaDataOperation int32
@@ -360,7 +302,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 fileDescriptor0, []int{3} }
+func (MetaDataOperation) EnumDescriptor() ([]byte, []int) {
+ return fileDescriptor_common_84e383fbabed0a31, []int{3}
+}
type StateType int32
@@ -381,7 +325,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 fileDescriptor0, []int{4} }
+func (StateType) EnumDescriptor() ([]byte, []int) {
+ return fileDescriptor_common_84e383fbabed0a31, []int{4}
+}
type CursorFactory_Style int32
@@ -414,7 +360,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 fileDescriptor0, []int{6, 0} }
+func (CursorFactory_Style) EnumDescriptor() ([]byte, []int) {
+ return fileDescriptor_common_84e383fbabed0a31, []int{6, 0}
+}
type MetaDataOperationArgument_ArgumentType int32
@@ -448,25 +396,47 @@ func (x MetaDataOperationArgument_ArgumentType) String() string {
return proto.EnumName(MetaDataOperationArgument_ArgumentType_name, int32(x))
}
func (MetaDataOperationArgument_ArgumentType) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor0, []int{13, 0}
+ return fileDescriptor_common_84e383fbabed0a31, []int{13, 0}
}
// Details about a connection
type ConnectionProperties struct {
- IsDirty bool `protobuf:"varint,1,opt,name=is_dirty,json=isDirty" json:"is_dirty,omitempty"`
- AutoCommit bool `protobuf:"varint,2,opt,name=auto_commit,json=autoCommit" json:"auto_commit,omitempty"`
- HasAutoCommit bool `protobuf:"varint,7,opt,name=has_auto_commit,json=hasAutoCommit" json:"has_auto_commit,omitempty"`
- ReadOnly bool `protobuf:"varint,3,opt,name=read_only,json=readOnly" json:"read_only,omitempty"`
- HasReadOnly bool `protobuf:"varint,8,opt,name=has_read_only,json=hasReadOnly" json:"has_read_only,omitempty"`
- TransactionIsolation uint32 `protobuf:"varint,4,opt,name=transaction_isolation,json=transactionIsolation" json:"transaction_isolation,omitempty"`
- Catalog string `protobuf:"bytes,5,opt,name=catalog" json:"catalog,omitempty"`
- Schema string `protobuf:"bytes,6,opt,name=schema" json:"schema,omitempty"`
+ IsDirty bool `protobuf:"varint,1,opt,name=is_dirty,json=isDirty,proto3" json:"is_dirty,omitempty"`
+ AutoCommit bool `protobuf:"varint,2,opt,name=auto_commit,json=autoCommit,proto3" json:"auto_commit,omitempty"`
+ HasAutoCommit bool `protobuf:"varint,7,opt,name=has_auto_commit,json=hasAutoCommit,proto3" json:"has_auto_commit,omitempty"`
+ ReadOnly bool `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
+ HasReadOnly bool `protobuf:"varint,8,opt,name=has_read_only,json=hasReadOnly,proto3" json:"has_read_only,omitempty"`
+ TransactionIsolation uint32 `protobuf:"varint,4,opt,name=transaction_isolation,json=transactionIsolation,proto3" json:"transaction_isolation,omitempty"`
+ Catalog string `protobuf:"bytes,5,opt,name=catalog,proto3" json:"catalog,omitempty"`
+ Schema string `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ConnectionProperties.Size(m)
+}
+func (m *ConnectionProperties) XXX_DiscardUnknown() {
+ xxx_messageInfo_ConnectionProperties.DiscardUnknown(m)
}
-func (m *ConnectionProperties) Reset() { *m = ConnectionProperties{} }
-func (m *ConnectionProperties) String() string { return proto.CompactTextString(m) }
-func (*ConnectionProperties) ProtoMessage() {}
-func (*ConnectionProperties) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
+var xxx_messageInfo_ConnectionProperties proto.InternalMessageInfo
func (m *ConnectionProperties) GetIsDirty() bool {
if m != nil {
@@ -526,15 +496,37 @@ func (m *ConnectionProperties) GetSchema() string {
// Statement handle
type StatementHandle struct {
- ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
- Id uint32 `protobuf:"varint,2,opt,name=id" json:"id,omitempty"`
- Signature *Signature `protobuf:"bytes,3,opt,name=signature" json:"signature,omitempty"`
+ ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
+ Id uint32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
+ Signature *Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *StatementHandle) Reset() { *m = StatementHandle{} }
-func (m *StatementHandle) String() string { return proto.CompactTextString(m) }
-func (*StatementHandle) ProtoMessage() {}
-func (*StatementHandle) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_StatementHandle.Size(m)
+}
+func (m *StatementHandle) XXX_DiscardUnknown() {
+ xxx_messageInfo_StatementHandle.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_StatementHandle proto.InternalMessageInfo
func (m *StatementHandle) GetConnectionId() string {
if m != nil {
@@ -559,17 +551,39 @@ func (m *StatementHandle) GetSignature() *Signature {
// Results of preparing a statement
type Signature struct {
- Columns []*ColumnMetaData `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"`
- Sql string `protobuf:"bytes,2,opt,name=sql" json:"sql,omitempty"`
- Parameters []*AvaticaParameter `protobuf:"bytes,3,rep,name=parameters" json:"parameters,omitempty"`
- CursorFactory *CursorFactory `protobuf:"bytes,4,opt,name=cursor_factory,json=cursorFactory" json:"cursor_factory,omitempty"`
- StatementType StatementType `protobuf:"varint,5,opt,name=statementType,enum=StatementType" json:"statementType,omitempty"`
+ Columns []*ColumnMetaData `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
+ Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
+ Parameters []*AvaticaParameter `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"`
+ CursorFactory *CursorFactory `protobuf:"bytes,4,opt,name=cursor_factory,json=cursorFactory,proto3" json:"cursor_factory,omitempty"`
+ StatementType StatementType `protobuf:"varint,5,opt,name=statementType,proto3,enum=StatementType" json:"statementType,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_Signature.Size(m)
+}
+func (m *Signature) XXX_DiscardUnknown() {
+ xxx_messageInfo_Signature.DiscardUnknown(m)
}
-func (m *Signature) Reset() { *m = Signature{} }
-func (m *Signature) String() string { return proto.CompactTextString(m) }
-func (*Signature) ProtoMessage() {}
-func (*Signature) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
+var xxx_messageInfo_Signature proto.InternalMessageInfo
func (m *Signature) GetColumns() []*ColumnMetaData {
if m != nil {
@@ -607,32 +621,54 @@ func (m *Signature) GetStatementType() StatementType {
}
type ColumnMetaData struct {
- Ordinal uint32 `protobuf:"varint,1,opt,name=ordinal" json:"ordinal,omitempty"`
- AutoIncrement bool `protobuf:"varint,2,opt,name=auto_increment,json=autoIncrement" json:"auto_increment,omitempty"`
- CaseSensitive bool `protobuf:"varint,3,opt,name=case_sensitive,json=caseSensitive" json:"case_sensitive,omitempty"`
- Searchable bool `protobuf:"varint,4,opt,name=searchable" json:"searchable,omitempty"`
- Currency bool `protobuf:"varint,5,opt,name=currency" json:"currency,omitempty"`
- Nullable uint32 `protobuf:"varint,6,opt,name=nullable" json:"nullable,omitempty"`
- Signed bool `protobuf:"varint,7,opt,name=signed" json:"signed,omitempty"`
- DisplaySize uint32 `protobuf:"varint,8,opt,name=display_size,json=displaySize" json:"display_size,omitempty"`
- Label string `protobuf:"bytes,9,opt,name=label" json:"label,omitempty"`
- ColumnName string `protobuf:"bytes,10,opt,name=column_name,json=columnName" json:"column_name,omitempty"`
- SchemaName string `protobuf:"bytes,11,opt,name=schema_name,json=schemaName" json:"schema_name,omitempty"`
- Precision uint32 `protobuf:"varint,12,opt,name=precision" json:"precision,omitempty"`
- Scale uint32 `protobuf:"varint,13,opt,name=scale" json:"scale,omitempty"`
- TableName string `protobuf:"bytes,14,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
- CatalogName string `protobuf:"bytes,15,opt,name=catalog_name,json=catalogName" json:"catalog_name,omitempty"`
- ReadOnly bool `protobuf:"varint,16,opt,name=read_only,json=readOnly" json:"read_only,omitempty"`
- Writable bool `protobuf:"varint,17,opt,name=writable" json:"writable,omitempty"`
- DefinitelyWritable bool `protobuf:"varint,18,opt,name=definitely_writable,json=definitelyWritable" json:"definitely_writable,omitempty"`
- ColumnClassName string `protobuf:"bytes,19,opt,name=column_class_name,json=columnClassName" json:"column_class_name,omitempty"`
- Type *AvaticaType `protobuf:"bytes,20,opt,name=type" json:"type,omitempty"`
-}
-
-func (m *ColumnMetaData) Reset() { *m = ColumnMetaData{} }
-func (m *ColumnMetaData) String() string { return proto.CompactTextString(m) }
-func (*ColumnMetaData) ProtoMessage() {}
-func (*ColumnMetaData) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
+ Ordinal uint32 `protobuf:"varint,1,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
+ AutoIncrement bool `protobuf:"varint,2,opt,name=auto_increment,json=autoIncrement,proto3" json:"auto_increment,omitempty"`
+ CaseSensitive bool `protobuf:"varint,3,opt,name=case_sensitive,json=caseSensitive,proto3" json:"case_sensitive,omitempty"`
+ Searchable bool `protobuf:"varint,4,opt,name=searchable,proto3" json:"searchable,omitempty"`
+ Currency bool `protobuf:"varint,5,opt,name=currency,proto3" json:"currency,omitempty"`
+ Nullable uint32 `protobuf:"varint,6,opt,name=nullable,proto3" json:"nullable,omitempty"`
+ Signed bool `protobuf:"varint,7,opt,name=signed,proto3" json:"signed,omitempty"`
+ DisplaySize uint32 `protobuf:"varint,8,opt,name=display_size,json=displaySize,proto3" json:"display_size,omitempty"`
+ Label string `protobuf:"bytes,9,opt,name=label,proto3" json:"label,omitempty"`
+ ColumnName string `protobuf:"bytes,10,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
+ SchemaName string `protobuf:"bytes,11,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
+ Precision uint32 `protobuf:"varint,12,opt,name=precision,proto3" json:"precision,omitempty"`
+ Scale uint32 `protobuf:"varint,13,opt,name=scale,proto3" json:"scale,omitempty"`
+ TableName string `protobuf:"bytes,14,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
+ CatalogName string `protobuf:"bytes,15,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
+ ReadOnly bool `protobuf:"varint,16,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
+ Writable bool `protobuf:"varint,17,opt,name=writable,proto3" json:"writable,omitempty"`
+ DefinitelyWritable bool `protobuf:"varint,18,opt,name=definitely_writable,json=definitelyWritable,proto3" json:"definitely_writable,omitempty"`
+ ColumnClassName string `protobuf:"bytes,19,opt,name=column_class_name,json=columnClassName,proto3" json:"column_class_name,omitempty"`
+ Type *AvaticaType `protobuf:"bytes,20,opt,name=type,proto3" json:"type,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ColumnMetaData.Size(m)
+}
+func (m *ColumnMetaData) XXX_DiscardUnknown() {
+ xxx_messageInfo_ColumnMetaData.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_ColumnMetaData proto.InternalMessageInfo
func (m *ColumnMetaData) GetOrdinal() uint32 {
if m != nil {
@@ -776,17 +812,39 @@ func (m *ColumnMetaData) GetType() *AvaticaType {
// Base class for a column type
type AvaticaType struct {
- Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
- Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
- Rep Rep `protobuf:"varint,3,opt,name=rep,enum=Rep" json:"rep,omitempty"`
- Columns []*ColumnMetaData `protobuf:"bytes,4,rep,name=columns" json:"columns,omitempty"`
- Component *AvaticaType `protobuf:"bytes,5,opt,name=component" json:"component,omitempty"`
+ Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
+ Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
+ Rep Rep `protobuf:"varint,3,opt,name=rep,proto3,enum=Rep" json:"rep,omitempty"`
+ Columns []*ColumnMetaData `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"`
+ Component *AvaticaType `protobuf:"bytes,5,opt,name=component,proto3" json:"component,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *AvaticaType) Reset() { *m = AvaticaType{} }
-func (m *AvaticaType) String() string { return proto.CompactTextString(m) }
-func (*AvaticaType) ProtoMessage() {}
-func (*AvaticaType) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_AvaticaType.Size(m)
+}
+func (m *AvaticaType) XXX_DiscardUnknown() {
+ xxx_messageInfo_AvaticaType.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_AvaticaType proto.InternalMessageInfo
func (m *AvaticaType) GetId() uint32 {
if m != nil {
@@ -825,19 +883,41 @@ func (m *AvaticaType) GetComponent() *AvaticaType {
// Metadata for a parameter
type AvaticaParameter struct {
- Signed bool `protobuf:"varint,1,opt,name=signed" json:"signed,omitempty"`
- Precision uint32 `protobuf:"varint,2,opt,name=precision" json:"precision,omitempty"`
- Scale uint32 `protobuf:"varint,3,opt,name=scale" json:"scale,omitempty"`
- ParameterType uint32 `protobuf:"varint,4,opt,name=parameter_type,json=parameterType" json:"parameter_type,omitempty"`
- TypeName string `protobuf:"bytes,5,opt,name=type_name,json=typeName" json:"type_name,omitempty"`
- ClassName string `protobuf:"bytes,6,opt,name=class_name,json=className" json:"class_name,omitempty"`
- Name string `protobuf:"bytes,7,opt,name=name" json:"name,omitempty"`
+ Signed bool `protobuf:"varint,1,opt,name=signed,proto3" json:"signed,omitempty"`
+ Precision uint32 `protobuf:"varint,2,opt,name=precision,proto3" json:"precision,omitempty"`
+ Scale uint32 `protobuf:"varint,3,opt,name=scale,proto3" json:"scale,omitempty"`
+ ParameterType uint32 `protobuf:"varint,4,opt,name=parameter_type,json=parameterType,proto3" json:"parameter_type,omitempty"`
+ TypeName string `protobuf:"bytes,5,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
+ ClassName string `protobuf:"bytes,6,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"`
+ Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_AvaticaParameter.Size(m)
+}
+func (m *AvaticaParameter) XXX_DiscardUnknown() {
+ xxx_messageInfo_AvaticaParameter.DiscardUnknown(m)
}
-func (m *AvaticaParameter) Reset() { *m = AvaticaParameter{} }
-func (m *AvaticaParameter) String() string { return proto.CompactTextString(m) }
-func (*AvaticaParameter) ProtoMessage() {}
-func (*AvaticaParameter) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
+var xxx_messageInfo_AvaticaParameter proto.InternalMessageInfo
func (m *AvaticaParameter) GetSigned() bool {
if m != nil {
@@ -890,15 +970,37 @@ func (m *AvaticaParameter) GetName() string {
// Information necessary to convert an Iterable into a Calcite Cursor
type CursorFactory struct {
- Style CursorFactory_Style `protobuf:"varint,1,opt,name=style,enum=CursorFactory_Style" json:"style,omitempty"`
- ClassName string `protobuf:"bytes,2,opt,name=class_name,json=className" json:"class_name,omitempty"`
- FieldNames []string `protobuf:"bytes,3,rep,name=field_names,json=fieldNames" json:"field_names,omitempty"`
+ Style CursorFactory_Style `protobuf:"varint,1,opt,name=style,proto3,enum=CursorFactory_Style" json:"style,omitempty"`
+ ClassName string `protobuf:"bytes,2,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"`
+ FieldNames []string `protobuf:"bytes,3,rep,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *CursorFactory) Reset() { *m = CursorFactory{} }
-func (m *CursorFactory) String() string { return proto.CompactTextString(m) }
-func (*CursorFactory) ProtoMessage() {}
-func (*CursorFactory) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_CursorFactory.Size(m)
+}
+func (m *CursorFactory) XXX_DiscardUnknown() {
+ xxx_messageInfo_CursorFactory.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_CursorFactory proto.InternalMessageInfo
func (m *CursorFactory) GetStyle() CursorFactory_Style {
if m != nil {
@@ -923,15 +1025,37 @@ func (m *CursorFactory) GetFieldNames() []string {
// A collection of rows
type Frame struct {
- Offset uint64 `protobuf:"varint,1,opt,name=offset" json:"offset,omitempty"`
- Done bool `protobuf:"varint,2,opt,name=done" json:"done,omitempty"`
- Rows []*Row `protobuf:"bytes,3,rep,name=rows" json:"rows,omitempty"`
+ Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
+ Done bool `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
+ Rows []*Row `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_Frame.Size(m)
+}
+func (m *Frame) XXX_DiscardUnknown() {
+ xxx_messageInfo_Frame.DiscardUnknown(m)
}
-func (m *Frame) Reset() { *m = Frame{} }
-func (m *Frame) String() string { return proto.CompactTextString(m) }
-func (*Frame) ProtoMessage() {}
-func (*Frame) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
+var xxx_messageInfo_Frame proto.InternalMessageInfo
func (m *Frame) GetOffset() uint64 {
if m != nil {
@@ -956,13 +1080,35 @@ func (m *Frame) GetRows() []*Row {
// A row is a collection of values
type Row struct {
- Value []*ColumnValue `protobuf:"bytes,1,rep,name=value" json:"value,omitempty"`
+ Value []*ColumnValue `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *Row) Reset() { *m = Row{} }
-func (m *Row) String() string { return proto.CompactTextString(m) }
-func (*Row) ProtoMessage() {}
-func (*Row) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_Row.Size(m)
+}
+func (m *Row) XXX_DiscardUnknown() {
+ xxx_messageInfo_Row.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_Row proto.InternalMessageInfo
func (m *Row) GetValue() []*ColumnValue {
if m != nil {
@@ -973,14 +1119,36 @@ func (m *Row) GetValue() []*ColumnValue {
// Database property, list of functions the database provides for a certain operation
type DatabaseProperty struct {
- Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
- Functions []string `protobuf:"bytes,2,rep,name=functions" json:"functions,omitempty"`
+ Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
+ Functions []string `protobuf:"bytes,2,rep,name=functions,proto3" json:"functions,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_DatabaseProperty.Size(m)
+}
+func (m *DatabaseProperty) XXX_DiscardUnknown() {
+ xxx_messageInfo_DatabaseProperty.DiscardUnknown(m)
}
-func (m *DatabaseProperty) Reset() { *m = DatabaseProperty{} }
-func (m *DatabaseProperty) String() string { return proto.CompactTextString(m) }
-func (*DatabaseProperty) ProtoMessage() {}
-func (*DatabaseProperty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
+var xxx_messageInfo_DatabaseProperty proto.InternalMessageInfo
func (m *DatabaseProperty) GetName() string {
if m != nil {
@@ -998,14 +1166,36 @@ func (m *DatabaseProperty) GetFunctions() []string {
// Message which encapsulates another message to support a single RPC endpoint
type WireMessage struct {
- Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
- WrappedMessage []byte `protobuf:"bytes,2,opt,name=wrapped_message,json=wrappedMessage,proto3" json:"wrapped_message,omitempty"`
+ Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
+ WrappedMessage []byte `protobuf:"bytes,2,opt,name=wrapped_message,json=wrappedMessage,proto3" json:"wrapped_message,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *WireMessage) Reset() { *m = WireMessage{} }
-func (m *WireMessage) String() string { return proto.CompactTextString(m) }
-func (*WireMessage) ProtoMessage() {}
-func (*WireMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_WireMessage.Size(m)
+}
+func (m *WireMessage) XXX_DiscardUnknown() {
+ xxx_messageInfo_WireMessage.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_WireMessage proto.InternalMessageInfo
func (m *WireMessage) GetName() string {
if m != nil {
@@ -1023,16 +1213,38 @@ func (m *WireMessage) GetWrappedMessage() []byte {
// A value might be a TypedValue or an Array of TypedValue's
type ColumnValue struct {
- Value []*TypedValue `protobuf:"bytes,1,rep,name=value" json:"value,omitempty"`
- ArrayValue []*TypedValue `protobuf:"bytes,2,rep,name=array_value,json=arrayValue" json:"array_value,omitempty"`
- HasArrayValue bool `protobuf:"varint,3,opt,name=has_array_value,json=hasArrayValue" json:"has_array_value,omitempty"`
- ScalarValue *TypedValue `protobuf:"bytes,4,opt,name=scalar_value,json=scalarValue" json:"scalar_value,omitempty"`
+ Value []*TypedValue `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
+ ArrayValue []*TypedValue `protobuf:"bytes,2,rep,name=array_value,json=arrayValue,proto3" json:"array_value,omitempty"`
+ HasArrayValue bool `protobuf:"varint,3,opt,name=has_array_value,json=hasArrayValue,proto3" json:"has_array_value,omitempty"`
+ ScalarValue *TypedValue `protobuf:"bytes,4,opt,name=scalar_value,json=scalarValue,proto3" json:"scalar_value,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_ColumnValue.Size(m)
+}
+func (m *ColumnValue) XXX_DiscardUnknown() {
+ xxx_messageInfo_ColumnValue.DiscardUnknown(m)
}
-func (m *ColumnValue) Reset() { *m = ColumnValue{} }
-func (m *ColumnValue) String() string { return proto.CompactTextString(m) }
-func (*ColumnValue) ProtoMessage() {}
-func (*ColumnValue) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
+var xxx_messageInfo_ColumnValue proto.InternalMessageInfo
func (m *ColumnValue) GetValue() []*TypedValue {
if m != nil {
@@ -1064,23 +1276,45 @@ func (m *ColumnValue) GetScalarValue() *TypedValue {
// Generic wrapper to support any SQL type. Struct-like to work around no polymorphism construct.
type TypedValue struct {
- Type Rep `protobuf:"varint,1,opt,name=type,enum=Rep" json:"type,omitempty"`
- BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue" json:"bool_value,omitempty"`
- StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue" json:"string_value,omitempty"`
- NumberValue int64 `protobuf:"zigzag64,4,opt,name=number_value,json=numberValue" json:"number_value,omitempty"`
+ Type Rep `protobuf:"varint,1,opt,name=type,proto3,enum=Rep" json:"type,omitempty"`
+ BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
+ StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
+ NumberValue int64 `protobuf:"zigzag64,4,opt,name=number_value,json=numberValue,proto3" json:"number_value,omitempty"`
// includes numeric types and date/time types.
- BytesValue []byte `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"`
- DoubleValue float64 `protobuf:"fixed64,6,opt,name=double_value,json=doubleValue" json:"double_value,omitempty"`
- Null bool `protobuf:"varint,7,opt,name=null" json:"null,omitempty"`
- ArrayValue []*TypedValue `protobuf:"bytes,8,rep,name=array_value,json=arrayValue" json:"array_value,omitempty"`
- ComponentType Rep `protobuf:"varint,9,opt,name=component_type,json=componentType,enum=Rep" json:"component_type,omitempty"`
- ImplicitlyNull bool `protobuf:"varint,10,opt,name=implicitly_null,json=implicitlyNull" json:"implicitly_null,omitempty"`
+ BytesValue []byte `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"`
+ DoubleValue float64 `protobuf:"fixed64,6,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"`
+ Null bool `protobuf:"varint,7,opt,name=null,proto3" json:"null,omitempty"`
+ ArrayValue []*TypedValue `protobuf:"bytes,8,rep,name=array_value,json=arrayValue,proto3" json:"array_value,omitempty"`
+ ComponentType Rep `protobuf:"varint,9,opt,name=component_type,json=componentType,proto3,enum=Rep" json:"component_type,omitempty"`
+ ImplicitlyNull bool `protobuf:"varint,10,opt,name=implicitly_null,json=implicitlyNull,proto3" json:"implicitly_null,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
}
-func (m *TypedValue) Reset() { *m = TypedValue{} }
-func (m *TypedValue) String() string { return proto.CompactTextString(m) }
-func (*TypedValue) ProtoMessage() {}
-func (*TypedValue) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_TypedValue.Size(m)
+}
+func (m *TypedValue) XXX_DiscardUnknown() {
+ xxx_messageInfo_TypedValue.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_TypedValue proto.InternalMessageInfo
func (m *TypedValue) GetType() Rep {
if m != nil {
@@ -1154,18 +1388,40 @@ func (m *TypedValue) GetImplicitlyNull() bool {
// Represents the breadth of arguments to DatabaseMetaData functions
type MetaDataOperationArgument struct {
- StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue" json:"string_value,omitempty"`
- BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue" json:"bool_value,omitempty"`
- IntValue int32 `protobuf:"zigzag32,3,opt,name=int_value,json=intValue" json:"int_value,omitempty"`
- StringArrayValues []string `protobuf:"bytes,4,rep,name=string_array_values,json=stringArrayValues" json:"string_array_values,omitempty"`
- IntArrayValues []int32 `protobuf:"zigzag32,5,rep,packed,name=int_array_values,json=intArrayValues" json:"int_array_values,omitempty"`
- Type MetaDataOperationArgument_ArgumentType `protobuf:"varint,6,opt,name=type,enum=MetaDataOperationArgument_ArgumentType" json:"type,omitempty"`
+ StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
+ BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
+ IntValue int32 `protobuf:"zigzag32,3,opt,name=int_value,json=intValue,proto3" json:"int_value,omitempty"`
+ StringArrayValues []string `protobuf:"bytes,4,rep,name=string_array_values,json=stringArrayValues,proto3" json:"string_array_values,omitempty"`
+ IntArrayValues []int32 `protobuf:"zigzag32,5,rep,packed,name=int_array_values,json=intArrayValues,proto3" json:"int_array_values,omitempty"`
+ Type MetaDataOperationArgument_ArgumentType `protobuf:"varint,6,opt,name=type,proto3,enum=MetaDataOperationArgument_ArgumentType" json:"type,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+func (m *MetaDataOperationArgument) Reset() { *m = MetaDataOperationArgument{} }
+func (m *MetaDataOperationArgument) String() string { return proto.CompactTextString(m) }
+func (*MetaDataOperationArgument) ProtoMessage() {}
+func (*MetaDataOperationArgument) Descriptor() ([]byte, []int) {
+ return fileDescriptor_common_84e383fbabed0a31, []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_Size() int {
+ return xxx_messageInfo_MetaDataOperationArgument.Size(m)
+}
+func (m *MetaDataOperationArgument) XXX_DiscardUnknown() {
+ xxx_messageInfo_MetaDataOperationArgument.DiscardUnknown(m)
}
-func (m *MetaDataOperationArgument) Reset() { *m = MetaDataOperationArgument{} }
-func (m *MetaDataOperationArgument) String() string { return proto.CompactTextString(m) }
-func (*MetaDataOperationArgument) ProtoMessage() {}
-func (*MetaDataOperationArgument) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
+var xxx_messageInfo_MetaDataOperationArgument proto.InternalMessageInfo
func (m *MetaDataOperationArgument) GetStringValue() string {
if m != nil {
@@ -1210,19 +1466,41 @@ func (m *MetaDataOperationArgument) GetType() MetaDataOperationArgument_Argument
}
type QueryState struct {
- Type StateType `protobuf:"varint,1,opt,name=type,enum=StateType" json:"type,omitempty"`
- Sql string `protobuf:"bytes,2,opt,name=sql" json:"sql,omitempty"`
- Op MetaDataOperation `protobuf:"varint,3,opt,name=op,enum=MetaDataOperation" json:"op,omitempty"`
- Args []*MetaDataOperationArgument `protobuf:"bytes,4,rep,name=args" json:"args,omitempty"`
- HasArgs bool `protobuf:"varint,5,opt,name=has_args,json=hasArgs" json:"has_args,omitempty"`
- HasSql bool `protobuf:"varint,6,opt,name=has_sql,json=hasSql" json:"has_sql,omitempty"`
- HasOp bool `protobuf:"varint,7,opt,name=has_op,json=hasOp" json:"has_op,omitempty"`
+ Type StateType `protobuf:"varint,1,opt,name=type,proto3,enum=StateType" json:"type,omitempty"`
+ Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
+ Op MetaDataOperation `protobuf:"varint,3,opt,name=op,proto3,enum=MetaDataOperation" json:"op,omitempty"`
+ Args []*MetaDataOperationArgument `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
+ HasArgs bool `protobuf:"varint,5,opt,name=has_args,json=hasArgs,proto3" json:"has_args,omitempty"`
+ HasSql bool `protobuf:"varint,6,opt,name=has_sql,json=hasSql,proto3" json:"has_sql,omitempty"`
+ HasOp bool `protobuf:"varint,7,opt,name=has_op,json=hasOp,proto3" json:"has_op,omitempty"`
+ XXX_NoUnkeyedLiteral struct{} `json:"-"`
+ XXX_unrecognized []byte `json:"-"`
+ XXX_sizecache int32 `json:"-"`
+}
+
+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}
+}
+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_Size() int {
+ return xxx_messageInfo_QueryState.Size(m)
+}
+func (m *QueryState) XXX_DiscardUnknown() {
+ xxx_messageInfo_QueryState.DiscardUnknown(m)
}
-func (m *QueryState) Reset() { *m = QueryState{} }
-func (m *QueryState) String() string { return proto.CompactTextString(m) }
-func (*QueryState) ProtoMessage() {}
-func (*QueryState) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
+var xxx_messageInfo_QueryState proto.InternalMessageInfo
func (m *QueryState) GetType() StateType {
if m != nil {
@@ -1298,9 +1576,9 @@ func init() {
proto.RegisterEnum("MetaDataOperationArgument_ArgumentType", MetaDataOperationArgument_ArgumentType_name, MetaDataOperationArgument_ArgumentType_value)
}
-func init() { proto.RegisterFile("common.proto", fileDescriptor0) }
+func init() { proto.RegisterFile("common.proto", fileDescriptor_common_84e383fbabed0a31) }
-var fileDescriptor0 = []byte{
+var fileDescriptor_common_84e383fbabed0a31 = []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,