| // |
| // Licensed to the Apache Software Foundation (ASF) under one or more |
| // contributor license agreements. See the NOTICE file distributed with |
| // this work for additional information regarding copyright ownership. |
| // The ASF licenses this file to you under the Apache License, Version 2.0 |
| // (the "License"); you may not use this file except in compliance with |
| // the License. You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| // Code generated by protoc-gen-go. DO NOT EDIT. |
| // versions: |
| // protoc-gen-go v1.28.1 |
| // protoc v3.21.5 |
| // source: responses.proto |
| |
| package message |
| |
| import ( |
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" |
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" |
| reflect "reflect" |
| sync "sync" |
| ) |
| |
| const ( |
| // Verify that this generated code is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) |
| // Verify that runtime/protoimpl is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) |
| ) |
| |
| // Response that contains a result set. |
| type ResultSetResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| 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"` // -1 for normal result sets, else this response contains a dummy result set |
| // with no signature nor other data. |
| Metadata *RpcMetadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *ResultSetResponse) Reset() { |
| *x = ResultSetResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[0] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ResultSetResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ResultSetResponse) ProtoMessage() {} |
| |
| func (x *ResultSetResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[0] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ResultSetResponse.ProtoReflect.Descriptor instead. |
| func (*ResultSetResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{0} |
| } |
| |
| func (x *ResultSetResponse) GetConnectionId() string { |
| if x != nil { |
| return x.ConnectionId |
| } |
| return "" |
| } |
| |
| func (x *ResultSetResponse) GetStatementId() uint32 { |
| if x != nil { |
| return x.StatementId |
| } |
| return 0 |
| } |
| |
| func (x *ResultSetResponse) GetOwnStatement() bool { |
| if x != nil { |
| return x.OwnStatement |
| } |
| return false |
| } |
| |
| func (x *ResultSetResponse) GetSignature() *Signature { |
| if x != nil { |
| return x.Signature |
| } |
| return nil |
| } |
| |
| func (x *ResultSetResponse) GetFirstFrame() *Frame { |
| if x != nil { |
| return x.FirstFrame |
| } |
| return nil |
| } |
| |
| func (x *ResultSetResponse) GetUpdateCount() uint64 { |
| if x != nil { |
| return x.UpdateCount |
| } |
| return 0 |
| } |
| |
| func (x *ResultSetResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response to PrepareAndExecuteRequest |
| type ExecuteResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| 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"` // Did the request fail because of no-cached statement |
| Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *ExecuteResponse) Reset() { |
| *x = ExecuteResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[1] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ExecuteResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ExecuteResponse) ProtoMessage() {} |
| |
| func (x *ExecuteResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[1] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead. |
| func (*ExecuteResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{1} |
| } |
| |
| func (x *ExecuteResponse) GetResults() []*ResultSetResponse { |
| if x != nil { |
| return x.Results |
| } |
| return nil |
| } |
| |
| func (x *ExecuteResponse) GetMissingStatement() bool { |
| if x != nil { |
| return x.MissingStatement |
| } |
| return false |
| } |
| |
| func (x *ExecuteResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response to PrepareRequest |
| type PrepareResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Statement *StatementHandle `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"` |
| Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *PrepareResponse) Reset() { |
| *x = PrepareResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[2] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *PrepareResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*PrepareResponse) ProtoMessage() {} |
| |
| func (x *PrepareResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[2] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use PrepareResponse.ProtoReflect.Descriptor instead. |
| func (*PrepareResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{2} |
| } |
| |
| func (x *PrepareResponse) GetStatement() *StatementHandle { |
| if x != nil { |
| return x.Statement |
| } |
| return nil |
| } |
| |
| func (x *PrepareResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response to FetchRequest |
| type FetchResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| 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"` // Did the request fail because of no-cached statement |
| MissingResults bool `protobuf:"varint,3,opt,name=missing_results,json=missingResults,proto3" json:"missing_results,omitempty"` // Did the request fail because of a cached-statement w/o ResultSet |
| Metadata *RpcMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *FetchResponse) Reset() { |
| *x = FetchResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[3] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *FetchResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*FetchResponse) ProtoMessage() {} |
| |
| func (x *FetchResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[3] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use FetchResponse.ProtoReflect.Descriptor instead. |
| func (*FetchResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{3} |
| } |
| |
| func (x *FetchResponse) GetFrame() *Frame { |
| if x != nil { |
| return x.Frame |
| } |
| return nil |
| } |
| |
| func (x *FetchResponse) GetMissingStatement() bool { |
| if x != nil { |
| return x.MissingStatement |
| } |
| return false |
| } |
| |
| func (x *FetchResponse) GetMissingResults() bool { |
| if x != nil { |
| return x.MissingResults |
| } |
| return false |
| } |
| |
| func (x *FetchResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response to CreateStatementRequest |
| type CreateStatementResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| 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"` |
| } |
| |
| func (x *CreateStatementResponse) Reset() { |
| *x = CreateStatementResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[4] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *CreateStatementResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*CreateStatementResponse) ProtoMessage() {} |
| |
| func (x *CreateStatementResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[4] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use CreateStatementResponse.ProtoReflect.Descriptor instead. |
| func (*CreateStatementResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{4} |
| } |
| |
| func (x *CreateStatementResponse) GetConnectionId() string { |
| if x != nil { |
| return x.ConnectionId |
| } |
| return "" |
| } |
| |
| func (x *CreateStatementResponse) GetStatementId() uint32 { |
| if x != nil { |
| return x.StatementId |
| } |
| return 0 |
| } |
| |
| func (x *CreateStatementResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response to CloseStatementRequest |
| type CloseStatementResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *CloseStatementResponse) Reset() { |
| *x = CloseStatementResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[5] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *CloseStatementResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*CloseStatementResponse) ProtoMessage() {} |
| |
| func (x *CloseStatementResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[5] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use CloseStatementResponse.ProtoReflect.Descriptor instead. |
| func (*CloseStatementResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{5} |
| } |
| |
| func (x *CloseStatementResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response to OpenConnectionRequest { |
| type OpenConnectionResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *OpenConnectionResponse) Reset() { |
| *x = OpenConnectionResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[6] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *OpenConnectionResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*OpenConnectionResponse) ProtoMessage() {} |
| |
| func (x *OpenConnectionResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[6] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use OpenConnectionResponse.ProtoReflect.Descriptor instead. |
| func (*OpenConnectionResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{6} |
| } |
| |
| func (x *OpenConnectionResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response to CloseConnectionRequest { |
| type CloseConnectionResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *CloseConnectionResponse) Reset() { |
| *x = CloseConnectionResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[7] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *CloseConnectionResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*CloseConnectionResponse) ProtoMessage() {} |
| |
| func (x *CloseConnectionResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[7] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use CloseConnectionResponse.ProtoReflect.Descriptor instead. |
| func (*CloseConnectionResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{7} |
| } |
| |
| func (x *CloseConnectionResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response to ConnectionSyncRequest |
| type ConnectionSyncResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| 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"` |
| } |
| |
| func (x *ConnectionSyncResponse) Reset() { |
| *x = ConnectionSyncResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[8] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ConnectionSyncResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ConnectionSyncResponse) ProtoMessage() {} |
| |
| func (x *ConnectionSyncResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[8] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ConnectionSyncResponse.ProtoReflect.Descriptor instead. |
| func (*ConnectionSyncResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{8} |
| } |
| |
| func (x *ConnectionSyncResponse) GetConnProps() *ConnectionProperties { |
| if x != nil { |
| return x.ConnProps |
| } |
| return nil |
| } |
| |
| func (x *ConnectionSyncResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| type DatabasePropertyElement struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| 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"` |
| } |
| |
| func (x *DatabasePropertyElement) Reset() { |
| *x = DatabasePropertyElement{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[9] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *DatabasePropertyElement) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*DatabasePropertyElement) ProtoMessage() {} |
| |
| func (x *DatabasePropertyElement) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[9] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use DatabasePropertyElement.ProtoReflect.Descriptor instead. |
| func (*DatabasePropertyElement) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{9} |
| } |
| |
| func (x *DatabasePropertyElement) GetKey() *DatabaseProperty { |
| if x != nil { |
| return x.Key |
| } |
| return nil |
| } |
| |
| func (x *DatabasePropertyElement) GetValue() *TypedValue { |
| if x != nil { |
| return x.Value |
| } |
| return nil |
| } |
| |
| func (x *DatabasePropertyElement) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Response for Meta#getDatabaseProperties() |
| type DatabasePropertyResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Props []*DatabasePropertyElement `protobuf:"bytes,1,rep,name=props,proto3" json:"props,omitempty"` |
| Metadata *RpcMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *DatabasePropertyResponse) Reset() { |
| *x = DatabasePropertyResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[10] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *DatabasePropertyResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*DatabasePropertyResponse) ProtoMessage() {} |
| |
| func (x *DatabasePropertyResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[10] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use DatabasePropertyResponse.ProtoReflect.Descriptor instead. |
| func (*DatabasePropertyResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{10} |
| } |
| |
| func (x *DatabasePropertyResponse) GetProps() []*DatabasePropertyElement { |
| if x != nil { |
| return x.Props |
| } |
| return nil |
| } |
| |
| func (x *DatabasePropertyResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Send contextual information about some error over the wire from the server. |
| type ErrorResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| Exceptions []string `protobuf:"bytes,1,rep,name=exceptions,proto3" json:"exceptions,omitempty"` // exception stacktraces, many for linked exceptions. |
| HasExceptions bool `protobuf:"varint,7,opt,name=has_exceptions,json=hasExceptions,proto3" json:"has_exceptions,omitempty"` // are there stacktraces contained? |
| ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // human readable description |
| 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"` // numeric identifier for error |
| SqlState string `protobuf:"bytes,5,opt,name=sql_state,json=sqlState,proto3" json:"sql_state,omitempty"` // five-character standard-defined value |
| Metadata *RpcMetadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *ErrorResponse) Reset() { |
| *x = ErrorResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[11] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ErrorResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ErrorResponse) ProtoMessage() {} |
| |
| func (x *ErrorResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[11] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead. |
| func (*ErrorResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{11} |
| } |
| |
| func (x *ErrorResponse) GetExceptions() []string { |
| if x != nil { |
| return x.Exceptions |
| } |
| return nil |
| } |
| |
| func (x *ErrorResponse) GetHasExceptions() bool { |
| if x != nil { |
| return x.HasExceptions |
| } |
| return false |
| } |
| |
| func (x *ErrorResponse) GetErrorMessage() string { |
| if x != nil { |
| return x.ErrorMessage |
| } |
| return "" |
| } |
| |
| func (x *ErrorResponse) GetSeverity() Severity { |
| if x != nil { |
| return x.Severity |
| } |
| return Severity_UNKNOWN_SEVERITY |
| } |
| |
| func (x *ErrorResponse) GetErrorCode() uint32 { |
| if x != nil { |
| return x.ErrorCode |
| } |
| return 0 |
| } |
| |
| func (x *ErrorResponse) GetSqlState() string { |
| if x != nil { |
| return x.SqlState |
| } |
| return "" |
| } |
| |
| func (x *ErrorResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| type SyncResultsResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| MissingStatement bool `protobuf:"varint,1,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"` // Server doesn't have the statement with the ID from the request |
| MoreResults bool `protobuf:"varint,2,opt,name=more_results,json=moreResults,proto3" json:"more_results,omitempty"` // Should the client fetch() to get more results |
| Metadata *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *SyncResultsResponse) Reset() { |
| *x = SyncResultsResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[12] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *SyncResultsResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*SyncResultsResponse) ProtoMessage() {} |
| |
| func (x *SyncResultsResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[12] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use SyncResultsResponse.ProtoReflect.Descriptor instead. |
| func (*SyncResultsResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{12} |
| } |
| |
| func (x *SyncResultsResponse) GetMissingStatement() bool { |
| if x != nil { |
| return x.MissingStatement |
| } |
| return false |
| } |
| |
| func (x *SyncResultsResponse) GetMoreResults() bool { |
| if x != nil { |
| return x.MoreResults |
| } |
| return false |
| } |
| |
| func (x *SyncResultsResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| // Generic metadata for the server to return with each response. |
| type RpcMetadata struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| ServerAddress string `protobuf:"bytes,1,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"` // The host:port of the server |
| } |
| |
| func (x *RpcMetadata) Reset() { |
| *x = RpcMetadata{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[13] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *RpcMetadata) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*RpcMetadata) ProtoMessage() {} |
| |
| func (x *RpcMetadata) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[13] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use RpcMetadata.ProtoReflect.Descriptor instead. |
| func (*RpcMetadata) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{13} |
| } |
| |
| func (x *RpcMetadata) GetServerAddress() string { |
| if x != nil { |
| return x.ServerAddress |
| } |
| return "" |
| } |
| |
| // Response to a commit request |
| type CommitResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| } |
| |
| func (x *CommitResponse) Reset() { |
| *x = CommitResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[14] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *CommitResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*CommitResponse) ProtoMessage() {} |
| |
| func (x *CommitResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[14] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead. |
| func (*CommitResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{14} |
| } |
| |
| // Response to a rollback request |
| type RollbackResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| } |
| |
| func (x *RollbackResponse) Reset() { |
| *x = RollbackResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[15] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *RollbackResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*RollbackResponse) ProtoMessage() {} |
| |
| func (x *RollbackResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[15] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use RollbackResponse.ProtoReflect.Descriptor instead. |
| func (*RollbackResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{15} |
| } |
| |
| // Response to a batch update request |
| type ExecuteBatchResponse struct { |
| state protoimpl.MessageState |
| sizeCache protoimpl.SizeCache |
| unknownFields protoimpl.UnknownFields |
| |
| 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"` // Did the request fail because of no-cached statement |
| Metadata *RpcMetadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"` |
| } |
| |
| func (x *ExecuteBatchResponse) Reset() { |
| *x = ExecuteBatchResponse{} |
| if protoimpl.UnsafeEnabled { |
| mi := &file_responses_proto_msgTypes[16] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| } |
| |
| func (x *ExecuteBatchResponse) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*ExecuteBatchResponse) ProtoMessage() {} |
| |
| func (x *ExecuteBatchResponse) ProtoReflect() protoreflect.Message { |
| mi := &file_responses_proto_msgTypes[16] |
| if protoimpl.UnsafeEnabled && x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use ExecuteBatchResponse.ProtoReflect.Descriptor instead. |
| func (*ExecuteBatchResponse) Descriptor() ([]byte, []int) { |
| return file_responses_proto_rawDescGZIP(), []int{16} |
| } |
| |
| func (x *ExecuteBatchResponse) GetConnectionId() string { |
| if x != nil { |
| return x.ConnectionId |
| } |
| return "" |
| } |
| |
| func (x *ExecuteBatchResponse) GetStatementId() uint32 { |
| if x != nil { |
| return x.StatementId |
| } |
| return 0 |
| } |
| |
| func (x *ExecuteBatchResponse) GetUpdateCounts() []uint64 { |
| if x != nil { |
| return x.UpdateCounts |
| } |
| return nil |
| } |
| |
| func (x *ExecuteBatchResponse) GetMissingStatement() bool { |
| if x != nil { |
| return x.MissingStatement |
| } |
| return false |
| } |
| |
| func (x *ExecuteBatchResponse) GetMetadata() *RpcMetadata { |
| if x != nil { |
| return x.Metadata |
| } |
| return nil |
| } |
| |
| var File_responses_proto protoreflect.FileDescriptor |
| |
| var file_responses_proto_rawDesc = []byte{ |
| 0x0a, 0x0f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, |
| 0x6f, 0x1a, 0x0c, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, |
| 0xa0, 0x02, 0x0a, 0x11, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, |
| 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, |
| 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x63, 0x6f, |
| 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x74, |
| 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, |
| 0x52, 0x0b, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x23, 0x0a, |
| 0x0d, 0x6f, 0x77, 0x6e, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x03, |
| 0x20, 0x01, 0x28, 0x08, 0x52, 0x0c, 0x6f, 0x77, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, |
| 0x6e, 0x74, 0x12, 0x28, 0x0a, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x18, |
| 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0a, 0x2e, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, |
| 0x65, 0x52, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x12, 0x27, 0x0a, 0x0b, |
| 0x66, 0x69, 0x72, 0x73, 0x74, 0x5f, 0x66, 0x72, 0x61, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, |
| 0x0b, 0x32, 0x06, 0x2e, 0x46, 0x72, 0x61, 0x6d, 0x65, 0x52, 0x0a, 0x66, 0x69, 0x72, 0x73, 0x74, |
| 0x46, 0x72, 0x61, 0x6d, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, |
| 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0b, 0x75, 0x70, 0x64, |
| 0x61, 0x74, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, |
| 0x64, 0x61, 0x74, 0x61, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, |
| 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, |
| 0x74, 0x61, 0x22, 0x96, 0x01, 0x0a, 0x0f, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x52, 0x65, |
| 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2c, 0x0a, 0x07, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, |
| 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, |
| 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x52, 0x07, 0x72, 0x65, 0x73, |
| 0x75, 0x6c, 0x74, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x5f, |
| 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, |
| 0x10, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, |
| 0x74, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, |
| 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, |
| 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x6b, 0x0a, 0x0f, 0x50, |
| 0x72, 0x65, 0x70, 0x61, 0x72, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2e, |
| 0x0a, 0x09, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, |
| 0x0b, 0x32, 0x10, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x48, 0x61, 0x6e, |
| 0x64, 0x6c, 0x65, 0x52, 0x09, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x28, |
| 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, |
| 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, |
| 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0xad, 0x01, 0x0a, 0x0d, 0x46, 0x65, 0x74, |
| 0x63, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1c, 0x0a, 0x05, 0x66, 0x72, |
| 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x06, 0x2e, 0x46, 0x72, 0x61, 0x6d, |
| 0x65, 0x52, 0x05, 0x66, 0x72, 0x61, 0x6d, 0x65, 0x12, 0x2b, 0x0a, 0x11, 0x6d, 0x69, 0x73, 0x73, |
| 0x69, 0x6e, 0x67, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, |
| 0x01, 0x28, 0x08, 0x52, 0x10, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, |
| 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x27, 0x0a, 0x0f, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, |
| 0x5f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0e, |
| 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x12, 0x28, |
| 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, |
| 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, |
| 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x8b, 0x01, 0x0a, 0x17, 0x43, 0x72, 0x65, |
| 0x61, 0x74, 0x65, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, |
| 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, |
| 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x63, 0x6f, 0x6e, |
| 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x74, 0x61, |
| 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, |
| 0x0b, 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x28, 0x0a, 0x08, |
| 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, |
| 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, |
| 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x42, 0x0a, 0x16, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x53, |
| 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, |
| 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, |
| 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, |
| 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x42, 0x0a, 0x16, 0x4f, 0x70, |
| 0x65, 0x6e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, |
| 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, |
| 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, |
| 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x43, |
| 0x0a, 0x17, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, |
| 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, |
| 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, |
| 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, |
| 0x61, 0x74, 0x61, 0x22, 0x78, 0x0a, 0x16, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, |
| 0x6e, 0x53, 0x79, 0x6e, 0x63, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x34, 0x0a, |
| 0x0a, 0x63, 0x6f, 0x6e, 0x6e, 0x5f, 0x70, 0x72, 0x6f, 0x70, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, |
| 0x0b, 0x32, 0x15, 0x2e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x50, 0x72, |
| 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x52, 0x09, 0x63, 0x6f, 0x6e, 0x6e, 0x50, 0x72, |
| 0x6f, 0x70, 0x73, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, |
| 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, |
| 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x8b, 0x01, |
| 0x0a, 0x17, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, |
| 0x74, 0x79, 0x45, 0x6c, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x23, 0x0a, 0x03, 0x6b, 0x65, 0x79, |
| 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, |
| 0x65, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x21, |
| 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0b, 0x2e, |
| 0x54, 0x79, 0x70, 0x65, 0x64, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, |
| 0x65, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, |
| 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, |
| 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x74, 0x0a, 0x18, 0x44, |
| 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x52, |
| 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2e, 0x0a, 0x05, 0x70, 0x72, 0x6f, 0x70, 0x73, |
| 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, |
| 0x65, 0x50, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x79, 0x45, 0x6c, 0x65, 0x6d, 0x65, 0x6e, 0x74, |
| 0x52, 0x05, 0x70, 0x72, 0x6f, 0x70, 0x73, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, |
| 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, |
| 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, |
| 0x61, 0x22, 0x88, 0x02, 0x0a, 0x0d, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, |
| 0x6e, 0x73, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x65, 0x78, 0x63, 0x65, 0x70, 0x74, 0x69, 0x6f, 0x6e, |
| 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0a, 0x65, 0x78, 0x63, 0x65, 0x70, 0x74, 0x69, |
| 0x6f, 0x6e, 0x73, 0x12, 0x25, 0x0a, 0x0e, 0x68, 0x61, 0x73, 0x5f, 0x65, 0x78, 0x63, 0x65, 0x70, |
| 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0d, 0x68, 0x61, 0x73, |
| 0x45, 0x78, 0x63, 0x65, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x65, 0x72, |
| 0x72, 0x6f, 0x72, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, |
| 0x09, 0x52, 0x0c, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, |
| 0x25, 0x0a, 0x08, 0x73, 0x65, 0x76, 0x65, 0x72, 0x69, 0x74, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, |
| 0x0e, 0x32, 0x09, 0x2e, 0x53, 0x65, 0x76, 0x65, 0x72, 0x69, 0x74, 0x79, 0x52, 0x08, 0x73, 0x65, |
| 0x76, 0x65, 0x72, 0x69, 0x74, 0x79, 0x12, 0x1d, 0x0a, 0x0a, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, |
| 0x63, 0x6f, 0x64, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x09, 0x65, 0x72, 0x72, 0x6f, |
| 0x72, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x71, 0x6c, 0x5f, 0x73, 0x74, 0x61, |
| 0x74, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x71, 0x6c, 0x53, 0x74, 0x61, |
| 0x74, 0x65, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x06, |
| 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, |
| 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x8f, 0x01, 0x0a, |
| 0x13, 0x53, 0x79, 0x6e, 0x63, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, |
| 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2b, 0x0a, 0x11, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x5f, |
| 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, |
| 0x10, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, |
| 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x6d, 0x6f, 0x72, 0x65, 0x5f, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, |
| 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, 0x6d, 0x6f, 0x72, 0x65, 0x52, 0x65, 0x73, |
| 0x75, 0x6c, 0x74, 0x73, 0x12, 0x28, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, |
| 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, |
| 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x34, |
| 0x0a, 0x0b, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x25, 0x0a, |
| 0x0e, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, |
| 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x41, 0x64, 0x64, |
| 0x72, 0x65, 0x73, 0x73, 0x22, 0x10, 0x0a, 0x0e, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x52, 0x65, |
| 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x12, 0x0a, 0x10, 0x52, 0x6f, 0x6c, 0x6c, 0x62, 0x61, |
| 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xda, 0x01, 0x0a, 0x14, 0x45, |
| 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x42, 0x61, 0x74, 0x63, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, |
| 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, |
| 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x63, 0x6f, 0x6e, 0x6e, |
| 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x74, 0x61, 0x74, |
| 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, |
| 0x73, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0d, 0x75, |
| 0x70, 0x64, 0x61, 0x74, 0x65, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x73, 0x18, 0x03, 0x20, 0x03, |
| 0x28, 0x04, 0x52, 0x0c, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x73, |
| 0x12, 0x2b, 0x0a, 0x11, 0x6d, 0x69, 0x73, 0x73, 0x69, 0x6e, 0x67, 0x5f, 0x73, 0x74, 0x61, 0x74, |
| 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x10, 0x6d, 0x69, 0x73, |
| 0x73, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x61, 0x74, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x28, 0x0a, |
| 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, |
| 0x0c, 0x2e, 0x52, 0x70, 0x63, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, |
| 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x42, 0x22, 0x0a, 0x20, 0x6f, 0x72, 0x67, 0x2e, 0x61, |
| 0x70, 0x61, 0x63, 0x68, 0x65, 0x2e, 0x63, 0x61, 0x6c, 0x63, 0x69, 0x74, 0x65, 0x2e, 0x61, 0x76, |
| 0x61, 0x74, 0x69, 0x63, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, |
| 0x74, 0x6f, 0x33, |
| } |
| |
| var ( |
| file_responses_proto_rawDescOnce sync.Once |
| file_responses_proto_rawDescData = file_responses_proto_rawDesc |
| ) |
| |
| func file_responses_proto_rawDescGZIP() []byte { |
| file_responses_proto_rawDescOnce.Do(func() { |
| file_responses_proto_rawDescData = protoimpl.X.CompressGZIP(file_responses_proto_rawDescData) |
| }) |
| return file_responses_proto_rawDescData |
| } |
| |
| var file_responses_proto_msgTypes = make([]protoimpl.MessageInfo, 17) |
| var file_responses_proto_goTypes = []interface{}{ |
| (*ResultSetResponse)(nil), // 0: ResultSetResponse |
| (*ExecuteResponse)(nil), // 1: ExecuteResponse |
| (*PrepareResponse)(nil), // 2: PrepareResponse |
| (*FetchResponse)(nil), // 3: FetchResponse |
| (*CreateStatementResponse)(nil), // 4: CreateStatementResponse |
| (*CloseStatementResponse)(nil), // 5: CloseStatementResponse |
| (*OpenConnectionResponse)(nil), // 6: OpenConnectionResponse |
| (*CloseConnectionResponse)(nil), // 7: CloseConnectionResponse |
| (*ConnectionSyncResponse)(nil), // 8: ConnectionSyncResponse |
| (*DatabasePropertyElement)(nil), // 9: DatabasePropertyElement |
| (*DatabasePropertyResponse)(nil), // 10: DatabasePropertyResponse |
| (*ErrorResponse)(nil), // 11: ErrorResponse |
| (*SyncResultsResponse)(nil), // 12: SyncResultsResponse |
| (*RpcMetadata)(nil), // 13: RpcMetadata |
| (*CommitResponse)(nil), // 14: CommitResponse |
| (*RollbackResponse)(nil), // 15: RollbackResponse |
| (*ExecuteBatchResponse)(nil), // 16: ExecuteBatchResponse |
| (*Signature)(nil), // 17: Signature |
| (*Frame)(nil), // 18: Frame |
| (*StatementHandle)(nil), // 19: StatementHandle |
| (*ConnectionProperties)(nil), // 20: ConnectionProperties |
| (*DatabaseProperty)(nil), // 21: DatabaseProperty |
| (*TypedValue)(nil), // 22: TypedValue |
| (Severity)(0), // 23: Severity |
| } |
| var file_responses_proto_depIdxs = []int32{ |
| 17, // 0: ResultSetResponse.signature:type_name -> Signature |
| 18, // 1: ResultSetResponse.first_frame:type_name -> Frame |
| 13, // 2: ResultSetResponse.metadata:type_name -> RpcMetadata |
| 0, // 3: ExecuteResponse.results:type_name -> ResultSetResponse |
| 13, // 4: ExecuteResponse.metadata:type_name -> RpcMetadata |
| 19, // 5: PrepareResponse.statement:type_name -> StatementHandle |
| 13, // 6: PrepareResponse.metadata:type_name -> RpcMetadata |
| 18, // 7: FetchResponse.frame:type_name -> Frame |
| 13, // 8: FetchResponse.metadata:type_name -> RpcMetadata |
| 13, // 9: CreateStatementResponse.metadata:type_name -> RpcMetadata |
| 13, // 10: CloseStatementResponse.metadata:type_name -> RpcMetadata |
| 13, // 11: OpenConnectionResponse.metadata:type_name -> RpcMetadata |
| 13, // 12: CloseConnectionResponse.metadata:type_name -> RpcMetadata |
| 20, // 13: ConnectionSyncResponse.conn_props:type_name -> ConnectionProperties |
| 13, // 14: ConnectionSyncResponse.metadata:type_name -> RpcMetadata |
| 21, // 15: DatabasePropertyElement.key:type_name -> DatabaseProperty |
| 22, // 16: DatabasePropertyElement.value:type_name -> TypedValue |
| 13, // 17: DatabasePropertyElement.metadata:type_name -> RpcMetadata |
| 9, // 18: DatabasePropertyResponse.props:type_name -> DatabasePropertyElement |
| 13, // 19: DatabasePropertyResponse.metadata:type_name -> RpcMetadata |
| 23, // 20: ErrorResponse.severity:type_name -> Severity |
| 13, // 21: ErrorResponse.metadata:type_name -> RpcMetadata |
| 13, // 22: SyncResultsResponse.metadata:type_name -> RpcMetadata |
| 13, // 23: ExecuteBatchResponse.metadata:type_name -> RpcMetadata |
| 24, // [24:24] is the sub-list for method output_type |
| 24, // [24:24] is the sub-list for method input_type |
| 24, // [24:24] is the sub-list for extension type_name |
| 24, // [24:24] is the sub-list for extension extendee |
| 0, // [0:24] is the sub-list for field type_name |
| } |
| |
| func init() { file_responses_proto_init() } |
| func file_responses_proto_init() { |
| if File_responses_proto != nil { |
| return |
| } |
| file_common_proto_init() |
| if !protoimpl.UnsafeEnabled { |
| file_responses_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ResultSetResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ExecuteResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*PrepareResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*FetchResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*CreateStatementResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*CloseStatementResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*OpenConnectionResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*CloseConnectionResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ConnectionSyncResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*DatabasePropertyElement); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*DatabasePropertyResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ErrorResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*SyncResultsResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*RpcMetadata); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*CommitResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*RollbackResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| file_responses_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { |
| switch v := v.(*ExecuteBatchResponse); i { |
| case 0: |
| return &v.state |
| case 1: |
| return &v.sizeCache |
| case 2: |
| return &v.unknownFields |
| default: |
| return nil |
| } |
| } |
| } |
| type x struct{} |
| out := protoimpl.TypeBuilder{ |
| File: protoimpl.DescBuilder{ |
| GoPackagePath: reflect.TypeOf(x{}).PkgPath(), |
| RawDescriptor: file_responses_proto_rawDesc, |
| NumEnums: 0, |
| NumMessages: 17, |
| NumExtensions: 0, |
| NumServices: 0, |
| }, |
| GoTypes: file_responses_proto_goTypes, |
| DependencyIndexes: file_responses_proto_depIdxs, |
| MessageInfos: file_responses_proto_msgTypes, |
| }.Build() |
| File_responses_proto = out.File |
| file_responses_proto_rawDesc = nil |
| file_responses_proto_goTypes = nil |
| file_responses_proto_depIdxs = nil |
| } |
