message

package
v2.3.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 4, 2018 License: Apache-2.0 Imports: 3 Imported by: 4

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
var CursorFactory_Style_name = map[int32]string{
	0: "OBJECT",
	1: "RECORD",
	2: "RECORD_PROJECTION",
	3: "ARRAY",
	4: "LIST",
	5: "MAP",
}
View Source 
var CursorFactory_Style_value = map[string]int32{
	"OBJECT":            0,
	"RECORD":            1,
	"RECORD_PROJECTION": 2,
	"ARRAY":             3,
	"LIST":              4,
	"MAP":               5,
}
View Source 
var MetaDataOperationArgument_ArgumentType_name = map[int32]string{
	0: "STRING",
	1: "BOOL",
	2: "INT",
	3: "REPEATED_STRING",
	4: "REPEATED_INT",
	5: "NULL",
}
View Source 
var MetaDataOperationArgument_ArgumentType_value = map[string]int32{
	"STRING":          0,
	"BOOL":            1,
	"INT":             2,
	"REPEATED_STRING": 3,
	"REPEATED_INT":    4,
	"NULL":            5,
}
View Source 
var MetaDataOperation_name = map[int32]string{
	0:  "GET_ATTRIBUTES",
	1:  "GET_BEST_ROW_IDENTIFIER",
	2:  "GET_CATALOGS",
	3:  "GET_CLIENT_INFO_PROPERTIES",
	4:  "GET_COLUMN_PRIVILEGES",
	5:  "GET_COLUMNS",
	6:  "GET_CROSS_REFERENCE",
	7:  "GET_EXPORTED_KEYS",
	8:  "GET_FUNCTION_COLUMNS",
	9:  "GET_FUNCTIONS",
	10: "GET_IMPORTED_KEYS",
	11: "GET_INDEX_INFO",
	12: "GET_PRIMARY_KEYS",
	13: "GET_PROCEDURE_COLUMNS",
	14: "GET_PROCEDURES",
	15: "GET_PSEUDO_COLUMNS",
	16: "GET_SCHEMAS",
	17: "GET_SCHEMAS_WITH_ARGS",
	18: "GET_SUPER_TABLES",
	19: "GET_SUPER_TYPES",
	20: "GET_TABLE_PRIVILEGES",
	21: "GET_TABLES",
	22: "GET_TABLE_TYPES",
	23: "GET_TYPE_INFO",
	24: "GET_UDTS",
	25: "GET_VERSION_COLUMNS",
}
View Source 
var MetaDataOperation_value = map[string]int32{
	"GET_ATTRIBUTES":             0,
	"GET_BEST_ROW_IDENTIFIER":    1,
	"GET_CATALOGS":               2,
	"GET_CLIENT_INFO_PROPERTIES": 3,
	"GET_COLUMN_PRIVILEGES":      4,
	"GET_COLUMNS":                5,
	"GET_CROSS_REFERENCE":        6,
	"GET_EXPORTED_KEYS":          7,
	"GET_FUNCTION_COLUMNS":       8,
	"GET_FUNCTIONS":              9,
	"GET_IMPORTED_KEYS":          10,
	"GET_INDEX_INFO":             11,
	"GET_PRIMARY_KEYS":           12,
	"GET_PROCEDURE_COLUMNS":      13,
	"GET_PROCEDURES":             14,
	"GET_PSEUDO_COLUMNS":         15,
	"GET_SCHEMAS":                16,
	"GET_SCHEMAS_WITH_ARGS":      17,
	"GET_SUPER_TABLES":           18,
	"GET_SUPER_TYPES":            19,
	"GET_TABLE_PRIVILEGES":       20,
	"GET_TABLES":                 21,
	"GET_TABLE_TYPES":            22,
	"GET_TYPE_INFO":              23,
	"GET_UDTS":                   24,
	"GET_VERSION_COLUMNS":        25,
}
View Source 
var Rep_name = map[int32]string{
	0:  "PRIMITIVE_BOOLEAN",
	1:  "PRIMITIVE_BYTE",
	2:  "PRIMITIVE_CHAR",
	3:  "PRIMITIVE_SHORT",
	4:  "PRIMITIVE_INT",
	5:  "PRIMITIVE_LONG",
	6:  "PRIMITIVE_FLOAT",
	7:  "PRIMITIVE_DOUBLE",
	8:  "BOOLEAN",
	9:  "BYTE",
	10: "CHARACTER",
	11: "SHORT",
	12: "INTEGER",
	13: "LONG",
	14: "FLOAT",
	15: "DOUBLE",
	25: "BIG_INTEGER",
	26: "BIG_DECIMAL",
	16: "JAVA_SQL_TIME",
	17: "JAVA_SQL_TIMESTAMP",
	18: "JAVA_SQL_DATE",
	19: "JAVA_UTIL_DATE",
	20: "BYTE_STRING",
	21: "STRING",
	22: "NUMBER",
	23: "OBJECT",
	24: "NULL",
	27: "ARRAY",
	28: "STRUCT",
	29: "MULTISET",
}
View Source 
var Rep_value = map[string]int32{
	"PRIMITIVE_BOOLEAN":  0,
	"PRIMITIVE_BYTE":     1,
	"PRIMITIVE_CHAR":     2,
	"PRIMITIVE_SHORT":    3,
	"PRIMITIVE_INT":      4,
	"PRIMITIVE_LONG":     5,
	"PRIMITIVE_FLOAT":    6,
	"PRIMITIVE_DOUBLE":   7,
	"BOOLEAN":            8,
	"BYTE":               9,
	"CHARACTER":          10,
	"SHORT":              11,
	"INTEGER":            12,
	"LONG":               13,
	"FLOAT":              14,
	"DOUBLE":             15,
	"BIG_INTEGER":        25,
	"BIG_DECIMAL":        26,
	"JAVA_SQL_TIME":      16,
	"JAVA_SQL_TIMESTAMP": 17,
	"JAVA_SQL_DATE":      18,
	"JAVA_UTIL_DATE":     19,
	"BYTE_STRING":        20,
	"STRING":             21,
	"NUMBER":             22,
	"OBJECT":             23,
	"NULL":               24,
	"ARRAY":              27,
	"STRUCT":             28,
	"MULTISET":           29,
}
View Source 
var Severity_name = map[int32]string{
	0: "UNKNOWN_SEVERITY",
	1: "FATAL_SEVERITY",
	2: "ERROR_SEVERITY",
	3: "WARNING_SEVERITY",
}
View Source 
var Severity_value = map[string]int32{
	"UNKNOWN_SEVERITY": 0,
	"FATAL_SEVERITY":   1,
	"ERROR_SEVERITY":   2,
	"WARNING_SEVERITY": 3,
}
View Source 
var StateType_name = map[int32]string{
	0: "SQL",
	1: "METADATA",
}
View Source 
var StateType_value = map[string]int32{
	"SQL":      0,
	"METADATA": 1,
}
View Source 
var StatementType_name = map[int32]string{
	0:  "SELECT",
	1:  "INSERT",
	2:  "UPDATE",
	3:  "DELETE",
	4:  "UPSERT",
	5:  "MERGE",
	6:  "OTHER_DML",
	7:  "CREATE",
	8:  "DROP",
	9:  "ALTER",
	10: "OTHER_DDL",
	11: "CALL",
}
View Source 
var StatementType_value = map[string]int32{
	"SELECT":    0,
	"INSERT":    1,
	"UPDATE":    2,
	"DELETE":    3,
	"UPSERT":    4,
	"MERGE":     5,
	"OTHER_DML": 6,
	"CREATE":    7,
	"DROP":      8,
	"ALTER":     9,
	"OTHER_DDL": 10,
	"CALL":      11,
}

Functions

This section is empty.

Types

type AvaticaParameter 

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"`
}

Metadata for a parameter

func (*AvaticaParameter) Descriptor 

func (*AvaticaParameter) Descriptor() ([]byte, []int)

func (*AvaticaParameter) GetClassName added in v1.3.0 

func (m *AvaticaParameter) GetClassName() string

func (*AvaticaParameter) GetName added in v1.3.0 

func (m *AvaticaParameter) GetName() string

func (*AvaticaParameter) GetParameterType added in v1.3.0 

func (m *AvaticaParameter) GetParameterType() uint32

func (*AvaticaParameter) GetPrecision added in v1.3.0 

func (m *AvaticaParameter) GetPrecision() uint32

func (*AvaticaParameter) GetScale added in v1.3.0 

func (m *AvaticaParameter) GetScale() uint32

func (*AvaticaParameter) GetSigned added in v1.3.0 

func (m *AvaticaParameter) GetSigned() bool

func (*AvaticaParameter) GetTypeName added in v1.3.0 

func (m *AvaticaParameter) GetTypeName() string

func (*AvaticaParameter) ProtoMessage 

func (*AvaticaParameter) ProtoMessage()

func (*AvaticaParameter) Reset 

func (m *AvaticaParameter) Reset()

func (*AvaticaParameter) String 

func (m *AvaticaParameter) String() string

type AvaticaType 

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"`
}

Base class for a column type

func (*AvaticaType) Descriptor 

func (*AvaticaType) Descriptor() ([]byte, []int)

func (*AvaticaType) GetColumns 

func (m *AvaticaType) GetColumns() []*ColumnMetaData

func (*AvaticaType) GetComponent 

func (m *AvaticaType) GetComponent() *AvaticaType

func (*AvaticaType) GetId added in v1.3.0 

func (m *AvaticaType) GetId() uint32

func (*AvaticaType) GetName added in v1.3.0 

func (m *AvaticaType) GetName() string

func (*AvaticaType) GetRep added in v1.3.0 

func (m *AvaticaType) GetRep() Rep

func (*AvaticaType) ProtoMessage 

func (*AvaticaType) ProtoMessage()

func (*AvaticaType) Reset 

func (m *AvaticaType) Reset()

func (*AvaticaType) String 

func (m *AvaticaType) String() string

type CatalogsRequest 

type CatalogsRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
}

Request for Meta#getCatalogs()

func (*CatalogsRequest) Descriptor 

func (*CatalogsRequest) Descriptor() ([]byte, []int)

func (*CatalogsRequest) GetConnectionId added in v1.3.0 

func (m *CatalogsRequest) GetConnectionId() string

func (*CatalogsRequest) ProtoMessage 

func (*CatalogsRequest) ProtoMessage()

func (*CatalogsRequest) Reset 

func (m *CatalogsRequest) Reset()

func (*CatalogsRequest) String 

func (m *CatalogsRequest) String() string

type CloseConnectionRequest 

type CloseConnectionRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
}

Request for Meta#closeConnection(Meta.ConnectionHandle)

func (*CloseConnectionRequest) Descriptor 

func (*CloseConnectionRequest) Descriptor() ([]byte, []int)

func (*CloseConnectionRequest) GetConnectionId added in v1.3.0 

func (m *CloseConnectionRequest) GetConnectionId() string

func (*CloseConnectionRequest) ProtoMessage 

func (*CloseConnectionRequest) ProtoMessage()

func (*CloseConnectionRequest) Reset 

func (m *CloseConnectionRequest) Reset()

func (*CloseConnectionRequest) String 

func (m *CloseConnectionRequest) String() string

type CloseConnectionResponse 

type CloseConnectionResponse struct {
	Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
}

Response to CloseConnectionRequest {

func (*CloseConnectionResponse) Descriptor 

func (*CloseConnectionResponse) Descriptor() ([]byte, []int)

func (*CloseConnectionResponse) GetMetadata 

func (m *CloseConnectionResponse) GetMetadata() *RpcMetadata

func (*CloseConnectionResponse) ProtoMessage 

func (*CloseConnectionResponse) ProtoMessage()

func (*CloseConnectionResponse) Reset 

func (m *CloseConnectionResponse) Reset()

func (*CloseConnectionResponse) String 

func (m *CloseConnectionResponse) String() string

type CloseStatementRequest 

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"`
}

Request for Meta#closeStatement(Meta.StatementHandle)

func (*CloseStatementRequest) Descriptor 

func (*CloseStatementRequest) Descriptor() ([]byte, []int)

func (*CloseStatementRequest) GetConnectionId added in v1.3.0 

func (m *CloseStatementRequest) GetConnectionId() string

func (*CloseStatementRequest) GetStatementId added in v1.3.0 

func (m *CloseStatementRequest) GetStatementId() uint32

func (*CloseStatementRequest) ProtoMessage 

func (*CloseStatementRequest) ProtoMessage()

func (*CloseStatementRequest) Reset 

func (m *CloseStatementRequest) Reset()

func (*CloseStatementRequest) String 

func (m *CloseStatementRequest) String() string

type CloseStatementResponse 

type CloseStatementResponse struct {
	Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
}

Response to CloseStatementRequest

func (*CloseStatementResponse) Descriptor 

func (*CloseStatementResponse) Descriptor() ([]byte, []int)

func (*CloseStatementResponse) GetMetadata 

func (m *CloseStatementResponse) GetMetadata() *RpcMetadata

func (*CloseStatementResponse) ProtoMessage 

func (*CloseStatementResponse) ProtoMessage()

func (*CloseStatementResponse) Reset 

func (m *CloseStatementResponse) Reset()

func (*CloseStatementResponse) String 

func (m *CloseStatementResponse) String() string

type ColumnMetaData 

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 (*ColumnMetaData) Descriptor 

func (*ColumnMetaData) Descriptor() ([]byte, []int)

func (*ColumnMetaData) GetAutoIncrement added in v1.3.0 

func (m *ColumnMetaData) GetAutoIncrement() bool

func (*ColumnMetaData) GetCaseSensitive added in v1.3.0 

func (m *ColumnMetaData) GetCaseSensitive() bool

func (*ColumnMetaData) GetCatalogName added in v1.3.0 

func (m *ColumnMetaData) GetCatalogName() string

func (*ColumnMetaData) GetColumnClassName added in v1.3.0 

func (m *ColumnMetaData) GetColumnClassName() string

func (*ColumnMetaData) GetColumnName added in v1.3.0 

func (m *ColumnMetaData) GetColumnName() string

func (*ColumnMetaData) GetCurrency added in v1.3.0 

func (m *ColumnMetaData) GetCurrency() bool

func (*ColumnMetaData) GetDefinitelyWritable added in v1.3.0 

func (m *ColumnMetaData) GetDefinitelyWritable() bool

func (*ColumnMetaData) GetDisplaySize added in v1.3.0 

func (m *ColumnMetaData) GetDisplaySize() uint32

func (*ColumnMetaData) GetLabel added in v1.3.0 

func (m *ColumnMetaData) GetLabel() string

func (*ColumnMetaData) GetNullable added in v1.3.0 

func (m *ColumnMetaData) GetNullable() uint32

func (*ColumnMetaData) GetOrdinal added in v1.3.0 

func (m *ColumnMetaData) GetOrdinal() uint32

func (*ColumnMetaData) GetPrecision added in v1.3.0 

func (m *ColumnMetaData) GetPrecision() uint32

func (*ColumnMetaData) GetReadOnly added in v1.3.0 

func (m *ColumnMetaData) GetReadOnly() bool

func (*ColumnMetaData) GetScale added in v1.3.0 

func (m *ColumnMetaData) GetScale() uint32

func (*ColumnMetaData) GetSchemaName added in v1.3.0 

func (m *ColumnMetaData) GetSchemaName() string

func (*ColumnMetaData) GetSearchable added in v1.3.0 

func (m *ColumnMetaData) GetSearchable() bool

func (*ColumnMetaData) GetSigned added in v1.3.0 

func (m *ColumnMetaData) GetSigned() bool

func (*ColumnMetaData) GetTableName added in v1.3.0 

func (m *ColumnMetaData) GetTableName() string

func (*ColumnMetaData) GetType 

func (m *ColumnMetaData) GetType() *AvaticaType

func (*ColumnMetaData) GetWritable added in v1.3.0 

func (m *ColumnMetaData) GetWritable() bool

func (*ColumnMetaData) ProtoMessage 

func (*ColumnMetaData) ProtoMessage()

func (*ColumnMetaData) Reset 

func (m *ColumnMetaData) Reset()

func (*ColumnMetaData) String 

func (m *ColumnMetaData) String() string

type ColumnValue 

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"`
}

A value might be a TypedValue or an Array of TypedValue's

func (*ColumnValue) Descriptor 

func (*ColumnValue) Descriptor() ([]byte, []int)

func (*ColumnValue) GetArrayValue 

func (m *ColumnValue) GetArrayValue() []*TypedValue

func (*ColumnValue) GetHasArrayValue added in v1.3.0 

func (m *ColumnValue) GetHasArrayValue() bool

func (*ColumnValue) GetScalarValue 

func (m *ColumnValue) GetScalarValue() *TypedValue

func (*ColumnValue) GetValue 

func (m *ColumnValue) GetValue() []*TypedValue

func (*ColumnValue) ProtoMessage 

func (*ColumnValue) ProtoMessage()

func (*ColumnValue) Reset 

func (m *ColumnValue) Reset()

func (*ColumnValue) String 

func (m *ColumnValue) String() string

type ColumnsRequest 

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"`
}

Request for Meta#getColumns(String, org.apache.calcite.avatica.Meta.Pat, 

org.apache.calcite.avatica.Meta.Pat, org.apache.calcite.avatica.Meta.Pat).

func (*ColumnsRequest) Descriptor 

func (*ColumnsRequest) Descriptor() ([]byte, []int)

func (*ColumnsRequest) GetCatalog added in v1.3.0 

func (m *ColumnsRequest) GetCatalog() string

func (*ColumnsRequest) GetColumnNamePattern added in v1.3.0 

func (m *ColumnsRequest) GetColumnNamePattern() string

func (*ColumnsRequest) GetConnectionId added in v1.3.0 

func (m *ColumnsRequest) GetConnectionId() string

func (*ColumnsRequest) GetSchemaPattern added in v1.3.0 

func (m *ColumnsRequest) GetSchemaPattern() string

func (*ColumnsRequest) GetTableNamePattern added in v1.3.0 

func (m *ColumnsRequest) GetTableNamePattern() string

func (*ColumnsRequest) ProtoMessage 

func (*ColumnsRequest) ProtoMessage()

func (*ColumnsRequest) Reset 

func (m *ColumnsRequest) Reset()

func (*ColumnsRequest) String 

func (m *ColumnsRequest) String() string

type CommitRequest 

type CommitRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
}

Request to invoke a commit on a Connection

func (*CommitRequest) Descriptor 

func (*CommitRequest) Descriptor() ([]byte, []int)

func (*CommitRequest) GetConnectionId added in v1.3.0 

func (m *CommitRequest) GetConnectionId() string

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset 

func (m *CommitRequest) Reset()

func (*CommitRequest) String 

func (m *CommitRequest) String() string

type CommitResponse 

type CommitResponse struct {
}

Response to a commit request

func (*CommitResponse) Descriptor 

func (*CommitResponse) Descriptor() ([]byte, []int)

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset 

func (m *CommitResponse) Reset()

func (*CommitResponse) String 

func (m *CommitResponse) String() string

type ConnectionProperties 

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"`
}

Details about a connection

func (*ConnectionProperties) Descriptor 

func (*ConnectionProperties) Descriptor() ([]byte, []int)

func (*ConnectionProperties) GetAutoCommit added in v1.3.0 

func (m *ConnectionProperties) GetAutoCommit() bool

func (*ConnectionProperties) GetCatalog added in v1.3.0 

func (m *ConnectionProperties) GetCatalog() string

func (*ConnectionProperties) GetHasAutoCommit added in v1.3.0 

func (m *ConnectionProperties) GetHasAutoCommit() bool

func (*ConnectionProperties) GetHasReadOnly added in v1.3.0 

func (m *ConnectionProperties) GetHasReadOnly() bool

func (*ConnectionProperties) GetIsDirty added in v1.3.0 

func (m *ConnectionProperties) GetIsDirty() bool

func (*ConnectionProperties) GetReadOnly added in v1.3.0 

func (m *ConnectionProperties) GetReadOnly() bool

func (*ConnectionProperties) GetSchema added in v1.3.0 

func (m *ConnectionProperties) GetSchema() string

func (*ConnectionProperties) GetTransactionIsolation added in v1.3.0 

func (m *ConnectionProperties) GetTransactionIsolation() uint32

func (*ConnectionProperties) ProtoMessage 

func (*ConnectionProperties) ProtoMessage()

func (*ConnectionProperties) Reset 

func (m *ConnectionProperties) Reset()

func (*ConnectionProperties) String 

func (m *ConnectionProperties) String() string

type ConnectionSyncRequest 

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"`
}

func (*ConnectionSyncRequest) Descriptor 

func (*ConnectionSyncRequest) Descriptor() ([]byte, []int)

func (*ConnectionSyncRequest) GetConnProps 

func (m *ConnectionSyncRequest) GetConnProps() *ConnectionProperties

func (*ConnectionSyncRequest) GetConnectionId added in v1.3.0 

func (m *ConnectionSyncRequest) GetConnectionId() string

func (*ConnectionSyncRequest) ProtoMessage 

func (*ConnectionSyncRequest) ProtoMessage()

func (*ConnectionSyncRequest) Reset 

func (m *ConnectionSyncRequest) Reset()

func (*ConnectionSyncRequest) String 

func (m *ConnectionSyncRequest) String() string

type ConnectionSyncResponse 

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"`
}

Response to ConnectionSyncRequest

func (*ConnectionSyncResponse) Descriptor 

func (*ConnectionSyncResponse) Descriptor() ([]byte, []int)

func (*ConnectionSyncResponse) GetConnProps 

func (m *ConnectionSyncResponse) GetConnProps() *ConnectionProperties

func (*ConnectionSyncResponse) GetMetadata 

func (m *ConnectionSyncResponse) GetMetadata() *RpcMetadata

func (*ConnectionSyncResponse) ProtoMessage 

func (*ConnectionSyncResponse) ProtoMessage()

func (*ConnectionSyncResponse) Reset 

func (m *ConnectionSyncResponse) Reset()

func (*ConnectionSyncResponse) String 

func (m *ConnectionSyncResponse) String() string

type CreateStatementRequest 

type CreateStatementRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
}

Request for Meta#createStatement(Meta.ConnectionHandle)

func (*CreateStatementRequest) Descriptor 

func (*CreateStatementRequest) Descriptor() ([]byte, []int)

func (*CreateStatementRequest) GetConnectionId added in v1.3.0 

func (m *CreateStatementRequest) GetConnectionId() string

func (*CreateStatementRequest) ProtoMessage 

func (*CreateStatementRequest) ProtoMessage()

func (*CreateStatementRequest) Reset 

func (m *CreateStatementRequest) Reset()

func (*CreateStatementRequest) String 

func (m *CreateStatementRequest) String() string

type CreateStatementResponse 

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"`
}

Response to CreateStatementRequest

func (*CreateStatementResponse) Descriptor 

func (*CreateStatementResponse) Descriptor() ([]byte, []int)

func (*CreateStatementResponse) GetConnectionId added in v1.3.0 

func (m *CreateStatementResponse) GetConnectionId() string

func (*CreateStatementResponse) GetMetadata 

func (m *CreateStatementResponse) GetMetadata() *RpcMetadata

func (*CreateStatementResponse) GetStatementId added in v1.3.0 

func (m *CreateStatementResponse) GetStatementId() uint32

func (*CreateStatementResponse) ProtoMessage 

func (*CreateStatementResponse) ProtoMessage()

func (*CreateStatementResponse) Reset 

func (m *CreateStatementResponse) Reset()

func (*CreateStatementResponse) String 

func (m *CreateStatementResponse) String() string

type CursorFactory 

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"`
}

Information necessary to convert an Iterable into a Calcite Cursor

func (*CursorFactory) Descriptor 

func (*CursorFactory) Descriptor() ([]byte, []int)

func (*CursorFactory) GetClassName added in v1.3.0 

func (m *CursorFactory) GetClassName() string

func (*CursorFactory) GetFieldNames added in v1.3.0 

func (m *CursorFactory) GetFieldNames() []string

func (*CursorFactory) GetStyle added in v1.3.0 

func (m *CursorFactory) GetStyle() CursorFactory_Style

func (*CursorFactory) ProtoMessage 

func (*CursorFactory) ProtoMessage()

func (*CursorFactory) Reset 

func (m *CursorFactory) Reset()

func (*CursorFactory) String 

func (m *CursorFactory) String() string

type CursorFactory_Style 

type CursorFactory_Style int32
const (
	CursorFactory_OBJECT            CursorFactory_Style = 0
	CursorFactory_RECORD            CursorFactory_Style = 1
	CursorFactory_RECORD_PROJECTION CursorFactory_Style = 2
	CursorFactory_ARRAY             CursorFactory_Style = 3
	CursorFactory_LIST              CursorFactory_Style = 4
	CursorFactory_MAP               CursorFactory_Style = 5
)

func (CursorFactory_Style) EnumDescriptor 

func (CursorFactory_Style) EnumDescriptor() ([]byte, []int)

func (CursorFactory_Style) String 

func (x CursorFactory_Style) String() string

type DatabaseProperty 

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"`
}

Database property, list of functions the database provides for a certain operation

func (*DatabaseProperty) Descriptor 

func (*DatabaseProperty) Descriptor() ([]byte, []int)

func (*DatabaseProperty) GetFunctions added in v1.3.0 

func (m *DatabaseProperty) GetFunctions() []string

func (*DatabaseProperty) GetName added in v1.3.0 

func (m *DatabaseProperty) GetName() string

func (*DatabaseProperty) ProtoMessage 

func (*DatabaseProperty) ProtoMessage()

func (*DatabaseProperty) Reset 

func (m *DatabaseProperty) Reset()

func (*DatabaseProperty) String 

func (m *DatabaseProperty) String() string

type DatabasePropertyElement 

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"`
}

func (*DatabasePropertyElement) Descriptor 

func (*DatabasePropertyElement) Descriptor() ([]byte, []int)

func (*DatabasePropertyElement) GetKey 

func (m *DatabasePropertyElement) GetKey() *DatabaseProperty

func (*DatabasePropertyElement) GetMetadata 

func (m *DatabasePropertyElement) GetMetadata() *RpcMetadata

func (*DatabasePropertyElement) GetValue 

func (m *DatabasePropertyElement) GetValue() *TypedValue

func (*DatabasePropertyElement) ProtoMessage 

func (*DatabasePropertyElement) ProtoMessage()

func (*DatabasePropertyElement) Reset 

func (m *DatabasePropertyElement) Reset()

func (*DatabasePropertyElement) String 

func (m *DatabasePropertyElement) String() string

type DatabasePropertyRequest 

type DatabasePropertyRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
}

Request for Meta#getDatabaseProperties()

func (*DatabasePropertyRequest) Descriptor 

func (*DatabasePropertyRequest) Descriptor() ([]byte, []int)

func (*DatabasePropertyRequest) GetConnectionId added in v1.3.0 

func (m *DatabasePropertyRequest) GetConnectionId() string

func (*DatabasePropertyRequest) ProtoMessage 

func (*DatabasePropertyRequest) ProtoMessage()

func (*DatabasePropertyRequest) Reset 

func (m *DatabasePropertyRequest) Reset()

func (*DatabasePropertyRequest) String 

func (m *DatabasePropertyRequest) String() string

type DatabasePropertyResponse 

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"`
}

Response for Meta#getDatabaseProperties()

func (*DatabasePropertyResponse) Descriptor 

func (*DatabasePropertyResponse) Descriptor() ([]byte, []int)

func (*DatabasePropertyResponse) GetMetadata 

func (m *DatabasePropertyResponse) GetMetadata() *RpcMetadata

func (*DatabasePropertyResponse) GetProps 

func (m *DatabasePropertyResponse) GetProps() []*DatabasePropertyElement

func (*DatabasePropertyResponse) ProtoMessage 

func (*DatabasePropertyResponse) ProtoMessage()

func (*DatabasePropertyResponse) Reset 

func (m *DatabasePropertyResponse) Reset()

func (*DatabasePropertyResponse) String 

func (m *DatabasePropertyResponse) String() string

type ErrorResponse 

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"`
}

Send contextual information about some error over the wire from the server.

func (*ErrorResponse) Descriptor 

func (*ErrorResponse) Descriptor() ([]byte, []int)

func (*ErrorResponse) GetErrorCode added in v1.3.0 

func (m *ErrorResponse) GetErrorCode() uint32

func (*ErrorResponse) GetErrorMessage added in v1.3.0 

func (m *ErrorResponse) GetErrorMessage() string

func (*ErrorResponse) GetExceptions added in v1.3.0 

func (m *ErrorResponse) GetExceptions() []string

func (*ErrorResponse) GetHasExceptions added in v1.3.0 

func (m *ErrorResponse) GetHasExceptions() bool

func (*ErrorResponse) GetMetadata 

func (m *ErrorResponse) GetMetadata() *RpcMetadata

func (*ErrorResponse) GetSeverity added in v1.3.0 

func (m *ErrorResponse) GetSeverity() Severity

func (*ErrorResponse) GetSqlState added in v1.3.0 

func (m *ErrorResponse) GetSqlState() string

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) Reset 

func (m *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (m *ErrorResponse) String() string

type ExecuteBatchRequest 

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"`
}

func (*ExecuteBatchRequest) Descriptor 

func (*ExecuteBatchRequest) Descriptor() ([]byte, []int)

func (*ExecuteBatchRequest) GetConnectionId added in v1.3.0 

func (m *ExecuteBatchRequest) GetConnectionId() string

func (*ExecuteBatchRequest) GetStatementId added in v1.3.0 

func (m *ExecuteBatchRequest) GetStatementId() uint32

func (*ExecuteBatchRequest) GetUpdates 

func (m *ExecuteBatchRequest) GetUpdates() []*UpdateBatch

func (*ExecuteBatchRequest) ProtoMessage 

func (*ExecuteBatchRequest) ProtoMessage()

func (*ExecuteBatchRequest) Reset 

func (m *ExecuteBatchRequest) Reset()

func (*ExecuteBatchRequest) String 

func (m *ExecuteBatchRequest) String() string

type ExecuteBatchResponse 

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"`
}

Response to a batch update request

func (*ExecuteBatchResponse) Descriptor 

func (*ExecuteBatchResponse) Descriptor() ([]byte, []int)

func (*ExecuteBatchResponse) GetConnectionId added in v1.3.0 

func (m *ExecuteBatchResponse) GetConnectionId() string

func (*ExecuteBatchResponse) GetMetadata 

func (m *ExecuteBatchResponse) GetMetadata() *RpcMetadata

func (*ExecuteBatchResponse) GetMissingStatement added in v1.3.0 

func (m *ExecuteBatchResponse) GetMissingStatement() bool

func (*ExecuteBatchResponse) GetStatementId added in v1.3.0 

func (m *ExecuteBatchResponse) GetStatementId() uint32

func (*ExecuteBatchResponse) GetUpdateCounts added in v1.3.0 

func (m *ExecuteBatchResponse) GetUpdateCounts() []uint64

func (*ExecuteBatchResponse) ProtoMessage 

func (*ExecuteBatchResponse) ProtoMessage()

func (*ExecuteBatchResponse) Reset 

func (m *ExecuteBatchResponse) Reset()

func (*ExecuteBatchResponse) String 

func (m *ExecuteBatchResponse) String() string

type ExecuteRequest 

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           `` /* 142-byte string literal not displayed */
	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"`
}

Request for Meta#execute(Meta.ConnectionHandle, list, long)

func (*ExecuteRequest) Descriptor 

func (*ExecuteRequest) Descriptor() ([]byte, []int)

func (*ExecuteRequest) GetDeprecatedFirstFrameMaxSize 

func (m *ExecuteRequest) GetDeprecatedFirstFrameMaxSize() uint64

func (*ExecuteRequest) GetFirstFrameMaxSize added in v1.3.0 

func (m *ExecuteRequest) GetFirstFrameMaxSize() int32

func (*ExecuteRequest) GetHasParameterValues added in v1.3.0 

func (m *ExecuteRequest) GetHasParameterValues() bool

func (*ExecuteRequest) GetParameterValues 

func (m *ExecuteRequest) GetParameterValues() []*TypedValue

func (*ExecuteRequest) GetStatementHandle 

func (m *ExecuteRequest) GetStatementHandle() *StatementHandle

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset 

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (m *ExecuteRequest) String() string

type ExecuteResponse 

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"`
}

Response to PrepareAndExecuteRequest

func (*ExecuteResponse) Descriptor 

func (*ExecuteResponse) Descriptor() ([]byte, []int)

func (*ExecuteResponse) GetMetadata 

func (m *ExecuteResponse) GetMetadata() *RpcMetadata

func (*ExecuteResponse) GetMissingStatement added in v1.3.0 

func (m *ExecuteResponse) GetMissingStatement() bool

func (*ExecuteResponse) GetResults 

func (m *ExecuteResponse) GetResults() []*ResultSetResponse

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset 

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (m *ExecuteResponse) String() string

type FetchRequest 

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"`
}

Request for Meta#fetch(Meta.StatementHandle, List, long, int)

func (*FetchRequest) Descriptor 

func (*FetchRequest) Descriptor() ([]byte, []int)

func (*FetchRequest) GetConnectionId added in v1.3.0 

func (m *FetchRequest) GetConnectionId() string

func (*FetchRequest) GetFetchMaxRowCount added in v1.3.0 

func (m *FetchRequest) GetFetchMaxRowCount() uint32

func (*FetchRequest) GetFrameMaxSize added in v1.3.0 

func (m *FetchRequest) GetFrameMaxSize() int32

func (*FetchRequest) GetOffset added in v1.3.0 

func (m *FetchRequest) GetOffset() uint64

func (*FetchRequest) GetStatementId added in v1.3.0 

func (m *FetchRequest) GetStatementId() uint32

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) Reset 

func (m *FetchRequest) Reset()

func (*FetchRequest) String 

func (m *FetchRequest) String() string

type FetchResponse 

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"`
}

Response to FetchRequest

func (*FetchResponse) Descriptor 

func (*FetchResponse) Descriptor() ([]byte, []int)

func (*FetchResponse) GetFrame 

func (m *FetchResponse) GetFrame() *Frame

func (*FetchResponse) GetMetadata 

func (m *FetchResponse) GetMetadata() *RpcMetadata

func (*FetchResponse) GetMissingResults added in v1.3.0 

func (m *FetchResponse) GetMissingResults() bool

func (*FetchResponse) GetMissingStatement added in v1.3.0 

func (m *FetchResponse) GetMissingStatement() bool

func (*FetchResponse) ProtoMessage 

func (*FetchResponse) ProtoMessage()

func (*FetchResponse) Reset 

func (m *FetchResponse) Reset()

func (*FetchResponse) String 

func (m *FetchResponse) String() string

type Frame 

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"`
}

A collection of rows

func (*Frame) Descriptor 

func (*Frame) Descriptor() ([]byte, []int)

func (*Frame) GetDone added in v1.3.0 

func (m *Frame) GetDone() bool

func (*Frame) GetOffset added in v1.3.0 

func (m *Frame) GetOffset() uint64

func (*Frame) GetRows 

func (m *Frame) GetRows() []*Row

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) Reset 

func (m *Frame) Reset()

func (*Frame) String 

func (m *Frame) String() string

type MetaDataOperation 

type MetaDataOperation int32

Enumeration corresponding to DatabaseMetaData operations 

const (
	MetaDataOperation_GET_ATTRIBUTES             MetaDataOperation = 0
	MetaDataOperation_GET_BEST_ROW_IDENTIFIER    MetaDataOperation = 1
	MetaDataOperation_GET_CATALOGS               MetaDataOperation = 2
	MetaDataOperation_GET_CLIENT_INFO_PROPERTIES MetaDataOperation = 3
	MetaDataOperation_GET_COLUMN_PRIVILEGES      MetaDataOperation = 4
	MetaDataOperation_GET_COLUMNS                MetaDataOperation = 5
	MetaDataOperation_GET_CROSS_REFERENCE        MetaDataOperation = 6
	MetaDataOperation_GET_EXPORTED_KEYS          MetaDataOperation = 7
	MetaDataOperation_GET_FUNCTION_COLUMNS       MetaDataOperation = 8
	MetaDataOperation_GET_FUNCTIONS              MetaDataOperation = 9
	MetaDataOperation_GET_IMPORTED_KEYS          MetaDataOperation = 10
	MetaDataOperation_GET_INDEX_INFO             MetaDataOperation = 11
	MetaDataOperation_GET_PRIMARY_KEYS           MetaDataOperation = 12
	MetaDataOperation_GET_PROCEDURE_COLUMNS      MetaDataOperation = 13
	MetaDataOperation_GET_PROCEDURES             MetaDataOperation = 14
	MetaDataOperation_GET_PSEUDO_COLUMNS         MetaDataOperation = 15
	MetaDataOperation_GET_SCHEMAS                MetaDataOperation = 16
	MetaDataOperation_GET_SCHEMAS_WITH_ARGS      MetaDataOperation = 17
	MetaDataOperation_GET_SUPER_TABLES           MetaDataOperation = 18
	MetaDataOperation_GET_SUPER_TYPES            MetaDataOperation = 19
	MetaDataOperation_GET_TABLE_PRIVILEGES       MetaDataOperation = 20
	MetaDataOperation_GET_TABLES                 MetaDataOperation = 21
	MetaDataOperation_GET_TABLE_TYPES            MetaDataOperation = 22
	MetaDataOperation_GET_TYPE_INFO              MetaDataOperation = 23
	MetaDataOperation_GET_UDTS                   MetaDataOperation = 24
	MetaDataOperation_GET_VERSION_COLUMNS        MetaDataOperation = 25
)

func (MetaDataOperation) EnumDescriptor 

func (MetaDataOperation) EnumDescriptor() ([]byte, []int)

func (MetaDataOperation) String 

func (x MetaDataOperation) String() string

type MetaDataOperationArgument 

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"`
}

Represents the breadth of arguments to DatabaseMetaData functions

func (*MetaDataOperationArgument) Descriptor 

func (*MetaDataOperationArgument) Descriptor() ([]byte, []int)

func (*MetaDataOperationArgument) GetBoolValue added in v1.3.0 

func (m *MetaDataOperationArgument) GetBoolValue() bool

func (*MetaDataOperationArgument) GetIntArrayValues added in v1.3.0 

func (m *MetaDataOperationArgument) GetIntArrayValues() []int32

func (*MetaDataOperationArgument) GetIntValue added in v1.3.0 

func (m *MetaDataOperationArgument) GetIntValue() int32

func (*MetaDataOperationArgument) GetStringArrayValues added in v1.3.0 

func (m *MetaDataOperationArgument) GetStringArrayValues() []string

func (*MetaDataOperationArgument) GetStringValue added in v1.3.0 

func (m *MetaDataOperationArgument) GetStringValue() string

func (*MetaDataOperationArgument) GetType added in v1.3.0 

func (m *MetaDataOperationArgument) GetType() MetaDataOperationArgument_ArgumentType

func (*MetaDataOperationArgument) ProtoMessage 

func (*MetaDataOperationArgument) ProtoMessage()

func (*MetaDataOperationArgument) Reset 

func (m *MetaDataOperationArgument) Reset()

func (*MetaDataOperationArgument) String 

func (m *MetaDataOperationArgument) String() string

type MetaDataOperationArgument_ArgumentType 

type MetaDataOperationArgument_ArgumentType int32
const (
	MetaDataOperationArgument_STRING          MetaDataOperationArgument_ArgumentType = 0
	MetaDataOperationArgument_BOOL            MetaDataOperationArgument_ArgumentType = 1
	MetaDataOperationArgument_INT             MetaDataOperationArgument_ArgumentType = 2
	MetaDataOperationArgument_REPEATED_STRING MetaDataOperationArgument_ArgumentType = 3
	MetaDataOperationArgument_REPEATED_INT    MetaDataOperationArgument_ArgumentType = 4
	MetaDataOperationArgument_NULL            MetaDataOperationArgument_ArgumentType = 5
)

func (MetaDataOperationArgument_ArgumentType) EnumDescriptor 

func (MetaDataOperationArgument_ArgumentType) EnumDescriptor() ([]byte, []int)

func (MetaDataOperationArgument_ArgumentType) String 

func (x MetaDataOperationArgument_ArgumentType) String() string

type OpenConnectionRequest 

type OpenConnectionRequest struct {
	ConnectionId string            `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
	Info         map[string]string `` /* 128-byte string literal not displayed */
}

Request for Meta#openConnection(Meta.ConnectionHandle, Map<String, String>)

func (*OpenConnectionRequest) Descriptor 

func (*OpenConnectionRequest) Descriptor() ([]byte, []int)

func (*OpenConnectionRequest) GetConnectionId added in v1.3.0 

func (m *OpenConnectionRequest) GetConnectionId() string

func (*OpenConnectionRequest) GetInfo 

func (m *OpenConnectionRequest) GetInfo() map[string]string

func (*OpenConnectionRequest) ProtoMessage 

func (*OpenConnectionRequest) ProtoMessage()

func (*OpenConnectionRequest) Reset 

func (m *OpenConnectionRequest) Reset()

func (*OpenConnectionRequest) String 

func (m *OpenConnectionRequest) String() string

type OpenConnectionResponse 

type OpenConnectionResponse struct {
	Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
}

Response to OpenConnectionRequest {

func (*OpenConnectionResponse) Descriptor 

func (*OpenConnectionResponse) Descriptor() ([]byte, []int)

func (*OpenConnectionResponse) GetMetadata 

func (m *OpenConnectionResponse) GetMetadata() *RpcMetadata

func (*OpenConnectionResponse) ProtoMessage 

func (*OpenConnectionResponse) ProtoMessage()

func (*OpenConnectionResponse) Reset 

func (m *OpenConnectionResponse) Reset()

func (*OpenConnectionResponse) String 

func (m *OpenConnectionResponse) String() string

type PrepareAndExecuteBatchRequest 

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"`
}

Request to prepare and execute a collection of sql statements.

func (*PrepareAndExecuteBatchRequest) Descriptor 

func (*PrepareAndExecuteBatchRequest) Descriptor() ([]byte, []int)

func (*PrepareAndExecuteBatchRequest) GetConnectionId added in v1.3.0 

func (m *PrepareAndExecuteBatchRequest) GetConnectionId() string

func (*PrepareAndExecuteBatchRequest) GetSqlCommands added in v1.3.0 

func (m *PrepareAndExecuteBatchRequest) GetSqlCommands() []string

func (*PrepareAndExecuteBatchRequest) GetStatementId added in v1.3.0 

func (m *PrepareAndExecuteBatchRequest) GetStatementId() uint32

func (*PrepareAndExecuteBatchRequest) ProtoMessage 

func (*PrepareAndExecuteBatchRequest) ProtoMessage()

func (*PrepareAndExecuteBatchRequest) Reset 

func (m *PrepareAndExecuteBatchRequest) Reset()

func (*PrepareAndExecuteBatchRequest) String 

func (m *PrepareAndExecuteBatchRequest) String() string

type PrepareAndExecuteRequest 

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"`
}

Request for Meta#prepareAndExecute(Meta.StatementHandle, String, long, Meta.PrepareCallback)

func (*PrepareAndExecuteRequest) Descriptor 

func (*PrepareAndExecuteRequest) Descriptor() ([]byte, []int)

func (*PrepareAndExecuteRequest) GetConnectionId added in v1.3.0 

func (m *PrepareAndExecuteRequest) GetConnectionId() string

func (*PrepareAndExecuteRequest) GetFirstFrameMaxSize added in v1.3.0 

func (m *PrepareAndExecuteRequest) GetFirstFrameMaxSize() int32

func (*PrepareAndExecuteRequest) GetMaxRowCount added in v1.3.0 

func (m *PrepareAndExecuteRequest) GetMaxRowCount() uint64

func (*PrepareAndExecuteRequest) GetMaxRowsTotal added in v1.3.0 

func (m *PrepareAndExecuteRequest) GetMaxRowsTotal() int64

func (*PrepareAndExecuteRequest) GetSql added in v1.3.0 

func (m *PrepareAndExecuteRequest) GetSql() string

func (*PrepareAndExecuteRequest) GetStatementId added in v1.3.0 

func (m *PrepareAndExecuteRequest) GetStatementId() uint32

func (*PrepareAndExecuteRequest) ProtoMessage 

func (*PrepareAndExecuteRequest) ProtoMessage()

func (*PrepareAndExecuteRequest) Reset 

func (m *PrepareAndExecuteRequest) Reset()

func (*PrepareAndExecuteRequest) String 

func (m *PrepareAndExecuteRequest) String() string

type PrepareRequest 

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"`
}

Request for Meta.prepare(Meta.ConnectionHandle, String, long)

func (*PrepareRequest) Descriptor 

func (*PrepareRequest) Descriptor() ([]byte, []int)

func (*PrepareRequest) GetConnectionId added in v1.3.0 

func (m *PrepareRequest) GetConnectionId() string

func (*PrepareRequest) GetMaxRowCount added in v1.3.0 

func (m *PrepareRequest) GetMaxRowCount() uint64

func (*PrepareRequest) GetMaxRowsTotal added in v1.3.0 

func (m *PrepareRequest) GetMaxRowsTotal() int64

func (*PrepareRequest) GetSql added in v1.3.0 

func (m *PrepareRequest) GetSql() string

func (*PrepareRequest) ProtoMessage 

func (*PrepareRequest) ProtoMessage()

func (*PrepareRequest) Reset 

func (m *PrepareRequest) Reset()

func (*PrepareRequest) String 

func (m *PrepareRequest) String() string

type PrepareResponse 

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"`
}

Response to PrepareRequest

func (*PrepareResponse) Descriptor 

func (*PrepareResponse) Descriptor() ([]byte, []int)

func (*PrepareResponse) GetMetadata 

func (m *PrepareResponse) GetMetadata() *RpcMetadata

func (*PrepareResponse) GetStatement 

func (m *PrepareResponse) GetStatement() *StatementHandle

func (*PrepareResponse) ProtoMessage 

func (*PrepareResponse) ProtoMessage()

func (*PrepareResponse) Reset 

func (m *PrepareResponse) Reset()

func (*PrepareResponse) String 

func (m *PrepareResponse) String() string

type QueryState 

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"`
}

func (*QueryState) Descriptor 

func (*QueryState) Descriptor() ([]byte, []int)

func (*QueryState) GetArgs 

func (m *QueryState) GetArgs() []*MetaDataOperationArgument

func (*QueryState) GetHasArgs added in v1.3.0 

func (m *QueryState) GetHasArgs() bool

func (*QueryState) GetHasOp added in v1.3.0 

func (m *QueryState) GetHasOp() bool

func (*QueryState) GetHasSql added in v1.3.0 

func (m *QueryState) GetHasSql() bool

func (*QueryState) GetOp added in v1.3.0 

func (m *QueryState) GetOp() MetaDataOperation

func (*QueryState) GetSql added in v1.3.0 

func (m *QueryState) GetSql() string

func (*QueryState) GetType added in v1.3.0 

func (m *QueryState) GetType() StateType

func (*QueryState) ProtoMessage 

func (*QueryState) ProtoMessage()

func (*QueryState) Reset 

func (m *QueryState) Reset()

func (*QueryState) String 

func (m *QueryState) String() string

type Rep 

type Rep int32
const (
	Rep_PRIMITIVE_BOOLEAN  Rep = 0
	Rep_PRIMITIVE_BYTE     Rep = 1
	Rep_PRIMITIVE_CHAR     Rep = 2
	Rep_PRIMITIVE_SHORT    Rep = 3
	Rep_PRIMITIVE_INT      Rep = 4
	Rep_PRIMITIVE_LONG     Rep = 5
	Rep_PRIMITIVE_FLOAT    Rep = 6
	Rep_PRIMITIVE_DOUBLE   Rep = 7
	Rep_BOOLEAN            Rep = 8
	Rep_BYTE               Rep = 9
	Rep_CHARACTER          Rep = 10
	Rep_SHORT              Rep = 11
	Rep_INTEGER            Rep = 12
	Rep_LONG               Rep = 13
	Rep_FLOAT              Rep = 14
	Rep_DOUBLE             Rep = 15
	Rep_BIG_INTEGER        Rep = 25
	Rep_BIG_DECIMAL        Rep = 26
	Rep_JAVA_SQL_TIME      Rep = 16
	Rep_JAVA_SQL_TIMESTAMP Rep = 17
	Rep_JAVA_SQL_DATE      Rep = 18
	Rep_JAVA_UTIL_DATE     Rep = 19
	Rep_BYTE_STRING        Rep = 20
	Rep_STRING             Rep = 21
	Rep_NUMBER             Rep = 22
	Rep_OBJECT             Rep = 23
	Rep_NULL               Rep = 24
	Rep_ARRAY              Rep = 27
	Rep_STRUCT             Rep = 28
	Rep_MULTISET           Rep = 29
)

func (Rep) EnumDescriptor 

func (Rep) EnumDescriptor() ([]byte, []int)

func (Rep) String 

func (x Rep) String() string

type ResultSetResponse 

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"`
	// with no signature nor other data.
	Metadata *RpcMetadata `protobuf:"bytes,7,opt,name=metadata" json:"metadata,omitempty"`
}

Response that contains a result set.

func (*ResultSetResponse) Descriptor 

func (*ResultSetResponse) Descriptor() ([]byte, []int)

func (*ResultSetResponse) GetConnectionId added in v1.3.0 

func (m *ResultSetResponse) GetConnectionId() string

func (*ResultSetResponse) GetFirstFrame 

func (m *ResultSetResponse) GetFirstFrame() *Frame

func (*ResultSetResponse) GetMetadata 

func (m *ResultSetResponse) GetMetadata() *RpcMetadata

func (*ResultSetResponse) GetOwnStatement added in v1.3.0 

func (m *ResultSetResponse) GetOwnStatement() bool

func (*ResultSetResponse) GetSignature 

func (m *ResultSetResponse) GetSignature() *Signature

func (*ResultSetResponse) GetStatementId added in v1.3.0 

func (m *ResultSetResponse) GetStatementId() uint32

func (*ResultSetResponse) GetUpdateCount added in v1.3.0 

func (m *ResultSetResponse) GetUpdateCount() uint64

func (*ResultSetResponse) ProtoMessage 

func (*ResultSetResponse) ProtoMessage()

func (*ResultSetResponse) Reset 

func (m *ResultSetResponse) Reset()

func (*ResultSetResponse) String 

func (m *ResultSetResponse) String() string

type RollbackRequest 

type RollbackRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
}

Request to invoke rollback on a Connection

func (*RollbackRequest) Descriptor 

func (*RollbackRequest) Descriptor() ([]byte, []int)

func (*RollbackRequest) GetConnectionId added in v1.3.0 

func (m *RollbackRequest) GetConnectionId() string

func (*RollbackRequest) ProtoMessage 

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) Reset 

func (m *RollbackRequest) Reset()

func (*RollbackRequest) String 

func (m *RollbackRequest) String() string

type RollbackResponse 

type RollbackResponse struct {
}

Response to a rollback request

func (*RollbackResponse) Descriptor 

func (*RollbackResponse) Descriptor() ([]byte, []int)

func (*RollbackResponse) ProtoMessage 

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) Reset 

func (m *RollbackResponse) Reset()

func (*RollbackResponse) String 

func (m *RollbackResponse) String() string

type Row 

type Row struct {
	Value []*ColumnValue `protobuf:"bytes,1,rep,name=value" json:"value,omitempty"`
}

A row is a collection of values

func (*Row) Descriptor 

func (*Row) Descriptor() ([]byte, []int)

func (*Row) GetValue 

func (m *Row) GetValue() []*ColumnValue

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) String 

func (m *Row) String() string

type RpcMetadata 

type RpcMetadata struct {
	ServerAddress string `protobuf:"bytes,1,opt,name=server_address,json=serverAddress" json:"server_address,omitempty"`
}

Generic metadata for the server to return with each response.

func (*RpcMetadata) Descriptor 

func (*RpcMetadata) Descriptor() ([]byte, []int)

func (*RpcMetadata) GetServerAddress added in v1.3.0 

func (m *RpcMetadata) GetServerAddress() string

func (*RpcMetadata) ProtoMessage 

func (*RpcMetadata) ProtoMessage()

func (*RpcMetadata) Reset 

func (m *RpcMetadata) Reset()

func (*RpcMetadata) String 

func (m *RpcMetadata) String() string

type SchemasRequest 

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"`
}

Request for Meta#getSchemas(String, org.apache.calcite.avatica.Meta.Pat)}

func (*SchemasRequest) Descriptor 

func (*SchemasRequest) Descriptor() ([]byte, []int)

func (*SchemasRequest) GetCatalog added in v1.3.0 

func (m *SchemasRequest) GetCatalog() string

func (*SchemasRequest) GetConnectionId added in v1.3.0 

func (m *SchemasRequest) GetConnectionId() string

func (*SchemasRequest) GetSchemaPattern added in v1.3.0 

func (m *SchemasRequest) GetSchemaPattern() string

func (*SchemasRequest) ProtoMessage 

func (*SchemasRequest) ProtoMessage()

func (*SchemasRequest) Reset 

func (m *SchemasRequest) Reset()

func (*SchemasRequest) String 

func (m *SchemasRequest) String() string

type Severity 

type Severity int32

The severity of some unexpected outcome to an operation. Protobuf enum values must be unique across all other enums 

const (
	Severity_UNKNOWN_SEVERITY Severity = 0
	Severity_FATAL_SEVERITY   Severity = 1
	Severity_ERROR_SEVERITY   Severity = 2
	Severity_WARNING_SEVERITY Severity = 3
)

func (Severity) EnumDescriptor 

func (Severity) EnumDescriptor() ([]byte, []int)

func (Severity) String 

func (x Severity) String() string

type Signature 

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"`
}

Results of preparing a statement

func (*Signature) Descriptor 

func (*Signature) Descriptor() ([]byte, []int)

func (*Signature) GetColumns 

func (m *Signature) GetColumns() []*ColumnMetaData

func (*Signature) GetCursorFactory 

func (m *Signature) GetCursorFactory() *CursorFactory

func (*Signature) GetParameters 

func (m *Signature) GetParameters() []*AvaticaParameter

func (*Signature) GetSql added in v1.3.0 

func (m *Signature) GetSql() string

func (*Signature) GetStatementType added in v1.3.0 

func (m *Signature) GetStatementType() StatementType

func (*Signature) ProtoMessage 

func (*Signature) ProtoMessage()

func (*Signature) Reset 

func (m *Signature) Reset()

func (*Signature) String 

func (m *Signature) String() string

type StateType 

type StateType int32
const (
	StateType_SQL      StateType = 0
	StateType_METADATA StateType = 1
)

func (StateType) EnumDescriptor 

func (StateType) EnumDescriptor() ([]byte, []int)

func (StateType) String 

func (x StateType) String() string

type StatementHandle 

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"`
}

Statement handle

func (*StatementHandle) Descriptor 

func (*StatementHandle) Descriptor() ([]byte, []int)

func (*StatementHandle) GetConnectionId added in v1.3.0 

func (m *StatementHandle) GetConnectionId() string

func (*StatementHandle) GetId added in v1.3.0 

func (m *StatementHandle) GetId() uint32

func (*StatementHandle) GetSignature 

func (m *StatementHandle) GetSignature() *Signature

func (*StatementHandle) ProtoMessage 

func (*StatementHandle) ProtoMessage()

func (*StatementHandle) Reset 

func (m *StatementHandle) Reset()

func (*StatementHandle) String 

func (m *StatementHandle) String() string

type StatementType 

type StatementType int32

Has to be consistent with Meta.StatementType 

const (
	StatementType_SELECT    StatementType = 0
	StatementType_INSERT    StatementType = 1
	StatementType_UPDATE    StatementType = 2
	StatementType_DELETE    StatementType = 3
	StatementType_UPSERT    StatementType = 4
	StatementType_MERGE     StatementType = 5
	StatementType_OTHER_DML StatementType = 6
	StatementType_CREATE    StatementType = 7
	StatementType_DROP      StatementType = 8
	StatementType_ALTER     StatementType = 9
	StatementType_OTHER_DDL StatementType = 10
	StatementType_CALL      StatementType = 11
)

func (StatementType) EnumDescriptor 

func (StatementType) EnumDescriptor() ([]byte, []int)

func (StatementType) String 

func (x StatementType) String() string

type SyncResultsRequest 

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"`
}

func (*SyncResultsRequest) Descriptor 

func (*SyncResultsRequest) Descriptor() ([]byte, []int)

func (*SyncResultsRequest) GetConnectionId added in v1.3.0 

func (m *SyncResultsRequest) GetConnectionId() string

func (*SyncResultsRequest) GetOffset added in v1.3.0 

func (m *SyncResultsRequest) GetOffset() uint64

func (*SyncResultsRequest) GetState 

func (m *SyncResultsRequest) GetState() *QueryState

func (*SyncResultsRequest) GetStatementId added in v1.3.0 

func (m *SyncResultsRequest) GetStatementId() uint32

func (*SyncResultsRequest) ProtoMessage 

func (*SyncResultsRequest) ProtoMessage()

func (*SyncResultsRequest) Reset 

func (m *SyncResultsRequest) Reset()

func (*SyncResultsRequest) String 

func (m *SyncResultsRequest) String() string

type SyncResultsResponse 

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"`
}

func (*SyncResultsResponse) Descriptor 

func (*SyncResultsResponse) Descriptor() ([]byte, []int)

func (*SyncResultsResponse) GetMetadata 

func (m *SyncResultsResponse) GetMetadata() *RpcMetadata

func (*SyncResultsResponse) GetMissingStatement added in v1.3.0 

func (m *SyncResultsResponse) GetMissingStatement() bool

func (*SyncResultsResponse) GetMoreResults added in v1.3.0 

func (m *SyncResultsResponse) GetMoreResults() bool

func (*SyncResultsResponse) ProtoMessage 

func (*SyncResultsResponse) ProtoMessage()

func (*SyncResultsResponse) Reset 

func (m *SyncResultsResponse) Reset()

func (*SyncResultsResponse) String 

func (m *SyncResultsResponse) String() string

type TableTypesRequest 

type TableTypesRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
}

Request for Meta#getTableTypes()

func (*TableTypesRequest) Descriptor 

func (*TableTypesRequest) Descriptor() ([]byte, []int)

func (*TableTypesRequest) GetConnectionId added in v1.3.0 

func (m *TableTypesRequest) GetConnectionId() string

func (*TableTypesRequest) ProtoMessage 

func (*TableTypesRequest) ProtoMessage()

func (*TableTypesRequest) Reset 

func (m *TableTypesRequest) Reset()

func (*TableTypesRequest) String 

func (m *TableTypesRequest) String() string

type TablesRequest 

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"`
}

Request for Request for Meta#getTables(String, org.apache.calcite.avatica.Meta.Pat, 

org.apache.calcite.avatica.Meta.Pat, java.util.List)

func (*TablesRequest) Descriptor 

func (*TablesRequest) Descriptor() ([]byte, []int)

func (*TablesRequest) GetCatalog added in v1.3.0 

func (m *TablesRequest) GetCatalog() string

func (*TablesRequest) GetConnectionId added in v1.3.0 

func (m *TablesRequest) GetConnectionId() string

func (*TablesRequest) GetHasTypeList added in v1.3.0 

func (m *TablesRequest) GetHasTypeList() bool

func (*TablesRequest) GetSchemaPattern added in v1.3.0 

func (m *TablesRequest) GetSchemaPattern() string

func (*TablesRequest) GetTableNamePattern added in v1.3.0 

func (m *TablesRequest) GetTableNamePattern() string

func (*TablesRequest) GetTypeList added in v1.3.0 

func (m *TablesRequest) GetTypeList() []string

func (*TablesRequest) ProtoMessage 

func (*TablesRequest) ProtoMessage()

func (*TablesRequest) Reset 

func (m *TablesRequest) Reset()

func (*TablesRequest) String 

func (m *TablesRequest) String() string

type TypeInfoRequest 

type TypeInfoRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId" json:"connection_id,omitempty"`
}

Request for Meta#getTypeInfo()

func (*TypeInfoRequest) Descriptor 

func (*TypeInfoRequest) Descriptor() ([]byte, []int)

func (*TypeInfoRequest) GetConnectionId added in v1.3.0 

func (m *TypeInfoRequest) GetConnectionId() string

func (*TypeInfoRequest) ProtoMessage 

func (*TypeInfoRequest) ProtoMessage()

func (*TypeInfoRequest) Reset 

func (m *TypeInfoRequest) Reset()

func (*TypeInfoRequest) String 

func (m *TypeInfoRequest) String() string

type TypedValue 

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"`
	// 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"`
}

Generic wrapper to support any SQL type. Struct-like to work around no polymorphism construct.

func (*TypedValue) Descriptor 

func (*TypedValue) Descriptor() ([]byte, []int)

func (*TypedValue) GetArrayValue 

func (m *TypedValue) GetArrayValue() []*TypedValue

func (*TypedValue) GetBoolValue added in v1.3.0 

func (m *TypedValue) GetBoolValue() bool

func (*TypedValue) GetBytesValue added in v1.3.0 

func (m *TypedValue) GetBytesValue() []byte

func (*TypedValue) GetComponentType 

func (m *TypedValue) GetComponentType() Rep

func (*TypedValue) GetDoubleValue added in v1.3.0 

func (m *TypedValue) GetDoubleValue() float64

func (*TypedValue) GetImplicitlyNull 

func (m *TypedValue) GetImplicitlyNull() bool

func (*TypedValue) GetNull added in v1.3.0 

func (m *TypedValue) GetNull() bool

func (*TypedValue) GetNumberValue added in v1.3.0 

func (m *TypedValue) GetNumberValue() int64

func (*TypedValue) GetStringValue added in v1.3.0 

func (m *TypedValue) GetStringValue() string

func (*TypedValue) GetType added in v1.3.0 

func (m *TypedValue) GetType() Rep

func (*TypedValue) ProtoMessage 

func (*TypedValue) ProtoMessage()

func (*TypedValue) Reset 

func (m *TypedValue) Reset()

func (*TypedValue) String 

func (m *TypedValue) String() string

type UpdateBatch 

type UpdateBatch struct {
	ParameterValues []*TypedValue `protobuf:"bytes,1,rep,name=parameter_values,json=parameterValues" json:"parameter_values,omitempty"`
}

Each command is a list of TypedValues

func (*UpdateBatch) Descriptor 

func (*UpdateBatch) Descriptor() ([]byte, []int)

func (*UpdateBatch) GetParameterValues 

func (m *UpdateBatch) GetParameterValues() []*TypedValue

func (*UpdateBatch) ProtoMessage 

func (*UpdateBatch) ProtoMessage()

func (*UpdateBatch) Reset 

func (m *UpdateBatch) Reset()

func (*UpdateBatch) String 

func (m *UpdateBatch) String() string

type WireMessage 

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"`
}

Message which encapsulates another message to support a single RPC endpoint

func (*WireMessage) Descriptor 

func (*WireMessage) Descriptor() ([]byte, []int)

func (*WireMessage) GetName added in v1.3.0 

func (m *WireMessage) GetName() string

func (*WireMessage) GetWrappedMessage added in v1.3.0 

func (m *WireMessage) GetWrappedMessage() []byte

func (*WireMessage) ProtoMessage 

func (*WireMessage) ProtoMessage()

func (*WireMessage) Reset 

func (m *WireMessage) Reset()

func (*WireMessage) String 

func (m *WireMessage) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.