message

package
v3.2.0 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2018 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

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,proto3" json:"signed,omitempty"`
	Precision            uint32   `protobuf:"varint,2,opt,name=precision,proto3" json:"precision,omitempty"`
	Scale                uint32   `protobuf:"varint,3,opt,name=scale,proto3" json:"scale,omitempty"`
	ParameterType        uint32   `protobuf:"varint,4,opt,name=parameter_type,json=parameterType,proto3" json:"parameter_type,omitempty"`
	TypeName             string   `protobuf:"bytes,5,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
	ClassName            string   `protobuf:"bytes,6,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"`
	Name                 string   `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Metadata for a parameter

func (*AvaticaParameter) Descriptor 

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

func (*AvaticaParameter) GetClassName 

func (m *AvaticaParameter) GetClassName() string

func (*AvaticaParameter) GetName 

func (m *AvaticaParameter) GetName() string

func (*AvaticaParameter) GetParameterType 

func (m *AvaticaParameter) GetParameterType() uint32

func (*AvaticaParameter) GetPrecision 

func (m *AvaticaParameter) GetPrecision() uint32

func (*AvaticaParameter) GetScale 

func (m *AvaticaParameter) GetScale() uint32

func (*AvaticaParameter) GetSigned 

func (m *AvaticaParameter) GetSigned() bool

func (*AvaticaParameter) GetTypeName 

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

func (*AvaticaParameter) XXX_DiscardUnknown 

func (m *AvaticaParameter) XXX_DiscardUnknown()

func (*AvaticaParameter) XXX_Marshal 

func (m *AvaticaParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AvaticaParameter) XXX_Merge 

func (dst *AvaticaParameter) XXX_Merge(src proto.Message)

func (*AvaticaParameter) XXX_Size 

func (m *AvaticaParameter) XXX_Size() int

func (*AvaticaParameter) XXX_Unmarshal 

func (m *AvaticaParameter) XXX_Unmarshal(b []byte) error

type AvaticaType 

type AvaticaType struct {
	Id                   uint32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Rep                  Rep               `protobuf:"varint,3,opt,name=rep,proto3,enum=Rep" json:"rep,omitempty"`
	Columns              []*ColumnMetaData `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"`
	Component            *AvaticaType      `protobuf:"bytes,5,opt,name=component,proto3" json:"component,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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 

func (m *AvaticaType) GetId() uint32

func (*AvaticaType) GetName 

func (m *AvaticaType) GetName() string

func (*AvaticaType) GetRep 

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

func (*AvaticaType) XXX_DiscardUnknown 

func (m *AvaticaType) XXX_DiscardUnknown()

func (*AvaticaType) XXX_Marshal 

func (m *AvaticaType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AvaticaType) XXX_Merge 

func (dst *AvaticaType) XXX_Merge(src proto.Message)

func (*AvaticaType) XXX_Size 

func (m *AvaticaType) XXX_Size() int

func (*AvaticaType) XXX_Unmarshal 

func (m *AvaticaType) XXX_Unmarshal(b []byte) error

type CatalogsRequest 

type CatalogsRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for Meta#getCatalogs()

func (*CatalogsRequest) Descriptor 

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

func (*CatalogsRequest) GetConnectionId 

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

func (*CatalogsRequest) XXX_DiscardUnknown 

func (m *CatalogsRequest) XXX_DiscardUnknown()

func (*CatalogsRequest) XXX_Marshal 

func (m *CatalogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CatalogsRequest) XXX_Merge 

func (dst *CatalogsRequest) XXX_Merge(src proto.Message)

func (*CatalogsRequest) XXX_Size 

func (m *CatalogsRequest) XXX_Size() int

func (*CatalogsRequest) XXX_Unmarshal 

func (m *CatalogsRequest) XXX_Unmarshal(b []byte) error

type CloseConnectionRequest 

type CloseConnectionRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for Meta#closeConnection(Meta.ConnectionHandle)

func (*CloseConnectionRequest) Descriptor 

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

func (*CloseConnectionRequest) GetConnectionId 

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

func (*CloseConnectionRequest) XXX_DiscardUnknown 

func (m *CloseConnectionRequest) XXX_DiscardUnknown()

func (*CloseConnectionRequest) XXX_Marshal 

func (m *CloseConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseConnectionRequest) XXX_Merge 

func (dst *CloseConnectionRequest) XXX_Merge(src proto.Message)

func (*CloseConnectionRequest) XXX_Size 

func (m *CloseConnectionRequest) XXX_Size() int

func (*CloseConnectionRequest) XXX_Unmarshal 

func (m *CloseConnectionRequest) XXX_Unmarshal(b []byte) error

type CloseConnectionResponse 

type CloseConnectionResponse struct {
	Metadata             *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

func (*CloseConnectionResponse) XXX_DiscardUnknown 

func (m *CloseConnectionResponse) XXX_DiscardUnknown()

func (*CloseConnectionResponse) XXX_Marshal 

func (m *CloseConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseConnectionResponse) XXX_Merge 

func (dst *CloseConnectionResponse) XXX_Merge(src proto.Message)

func (*CloseConnectionResponse) XXX_Size 

func (m *CloseConnectionResponse) XXX_Size() int

func (*CloseConnectionResponse) XXX_Unmarshal 

func (m *CloseConnectionResponse) XXX_Unmarshal(b []byte) error

type CloseStatementRequest 

type CloseStatementRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	StatementId          uint32   `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for Meta#closeStatement(Meta.StatementHandle)

func (*CloseStatementRequest) Descriptor 

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

func (*CloseStatementRequest) GetConnectionId 

func (m *CloseStatementRequest) GetConnectionId() string

func (*CloseStatementRequest) GetStatementId 

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

func (*CloseStatementRequest) XXX_DiscardUnknown 

func (m *CloseStatementRequest) XXX_DiscardUnknown()

func (*CloseStatementRequest) XXX_Marshal 

func (m *CloseStatementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseStatementRequest) XXX_Merge 

func (dst *CloseStatementRequest) XXX_Merge(src proto.Message)

func (*CloseStatementRequest) XXX_Size 

func (m *CloseStatementRequest) XXX_Size() int

func (*CloseStatementRequest) XXX_Unmarshal 

func (m *CloseStatementRequest) XXX_Unmarshal(b []byte) error

type CloseStatementResponse 

type CloseStatementResponse struct {
	Metadata             *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

func (*CloseStatementResponse) XXX_DiscardUnknown 

func (m *CloseStatementResponse) XXX_DiscardUnknown()

func (*CloseStatementResponse) XXX_Marshal 

func (m *CloseStatementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseStatementResponse) XXX_Merge 

func (dst *CloseStatementResponse) XXX_Merge(src proto.Message)

func (*CloseStatementResponse) XXX_Size 

func (m *CloseStatementResponse) XXX_Size() int

func (*CloseStatementResponse) XXX_Unmarshal 

func (m *CloseStatementResponse) XXX_Unmarshal(b []byte) error

type ColumnMetaData 

type ColumnMetaData struct {
	Ordinal              uint32       `protobuf:"varint,1,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	AutoIncrement        bool         `protobuf:"varint,2,opt,name=auto_increment,json=autoIncrement,proto3" json:"auto_increment,omitempty"`
	CaseSensitive        bool         `protobuf:"varint,3,opt,name=case_sensitive,json=caseSensitive,proto3" json:"case_sensitive,omitempty"`
	Searchable           bool         `protobuf:"varint,4,opt,name=searchable,proto3" json:"searchable,omitempty"`
	Currency             bool         `protobuf:"varint,5,opt,name=currency,proto3" json:"currency,omitempty"`
	Nullable             uint32       `protobuf:"varint,6,opt,name=nullable,proto3" json:"nullable,omitempty"`
	Signed               bool         `protobuf:"varint,7,opt,name=signed,proto3" json:"signed,omitempty"`
	DisplaySize          uint32       `protobuf:"varint,8,opt,name=display_size,json=displaySize,proto3" json:"display_size,omitempty"`
	Label                string       `protobuf:"bytes,9,opt,name=label,proto3" json:"label,omitempty"`
	ColumnName           string       `protobuf:"bytes,10,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	SchemaName           string       `protobuf:"bytes,11,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	Precision            uint32       `protobuf:"varint,12,opt,name=precision,proto3" json:"precision,omitempty"`
	Scale                uint32       `protobuf:"varint,13,opt,name=scale,proto3" json:"scale,omitempty"`
	TableName            string       `protobuf:"bytes,14,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	CatalogName          string       `protobuf:"bytes,15,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"`
	ReadOnly             bool         `protobuf:"varint,16,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	Writable             bool         `protobuf:"varint,17,opt,name=writable,proto3" json:"writable,omitempty"`
	DefinitelyWritable   bool         `protobuf:"varint,18,opt,name=definitely_writable,json=definitelyWritable,proto3" json:"definitely_writable,omitempty"`
	ColumnClassName      string       `protobuf:"bytes,19,opt,name=column_class_name,json=columnClassName,proto3" json:"column_class_name,omitempty"`
	Type                 *AvaticaType `protobuf:"bytes,20,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ColumnMetaData) Descriptor 

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

func (*ColumnMetaData) GetAutoIncrement 

func (m *ColumnMetaData) GetAutoIncrement() bool

func (*ColumnMetaData) GetCaseSensitive 

func (m *ColumnMetaData) GetCaseSensitive() bool

func (*ColumnMetaData) GetCatalogName 

func (m *ColumnMetaData) GetCatalogName() string

func (*ColumnMetaData) GetColumnClassName 

func (m *ColumnMetaData) GetColumnClassName() string

func (*ColumnMetaData) GetColumnName 

func (m *ColumnMetaData) GetColumnName() string

func (*ColumnMetaData) GetCurrency 

func (m *ColumnMetaData) GetCurrency() bool

func (*ColumnMetaData) GetDefinitelyWritable 

func (m *ColumnMetaData) GetDefinitelyWritable() bool

func (*ColumnMetaData) GetDisplaySize 

func (m *ColumnMetaData) GetDisplaySize() uint32

func (*ColumnMetaData) GetLabel 

func (m *ColumnMetaData) GetLabel() string

func (*ColumnMetaData) GetNullable 

func (m *ColumnMetaData) GetNullable() uint32

func (*ColumnMetaData) GetOrdinal 

func (m *ColumnMetaData) GetOrdinal() uint32

func (*ColumnMetaData) GetPrecision 

func (m *ColumnMetaData) GetPrecision() uint32

func (*ColumnMetaData) GetReadOnly 

func (m *ColumnMetaData) GetReadOnly() bool

func (*ColumnMetaData) GetScale 

func (m *ColumnMetaData) GetScale() uint32

func (*ColumnMetaData) GetSchemaName 

func (m *ColumnMetaData) GetSchemaName() string

func (*ColumnMetaData) GetSearchable 

func (m *ColumnMetaData) GetSearchable() bool

func (*ColumnMetaData) GetSigned 

func (m *ColumnMetaData) GetSigned() bool

func (*ColumnMetaData) GetTableName 

func (m *ColumnMetaData) GetTableName() string

func (*ColumnMetaData) GetType 

func (m *ColumnMetaData) GetType() *AvaticaType

func (*ColumnMetaData) GetWritable 

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

func (*ColumnMetaData) XXX_DiscardUnknown 

func (m *ColumnMetaData) XXX_DiscardUnknown()

func (*ColumnMetaData) XXX_Marshal 

func (m *ColumnMetaData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColumnMetaData) XXX_Merge 

func (dst *ColumnMetaData) XXX_Merge(src proto.Message)

func (*ColumnMetaData) XXX_Size 

func (m *ColumnMetaData) XXX_Size() int

func (*ColumnMetaData) XXX_Unmarshal 

func (m *ColumnMetaData) XXX_Unmarshal(b []byte) error

type ColumnValue 

type ColumnValue struct {
	Value                []*TypedValue `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	ArrayValue           []*TypedValue `protobuf:"bytes,2,rep,name=array_value,json=arrayValue,proto3" json:"array_value,omitempty"`
	HasArrayValue        bool          `protobuf:"varint,3,opt,name=has_array_value,json=hasArrayValue,proto3" json:"has_array_value,omitempty"`
	ScalarValue          *TypedValue   `protobuf:"bytes,4,opt,name=scalar_value,json=scalarValue,proto3" json:"scalar_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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 

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

func (*ColumnValue) XXX_DiscardUnknown 

func (m *ColumnValue) XXX_DiscardUnknown()

func (*ColumnValue) XXX_Marshal 

func (m *ColumnValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColumnValue) XXX_Merge 

func (dst *ColumnValue) XXX_Merge(src proto.Message)

func (*ColumnValue) XXX_Size 

func (m *ColumnValue) XXX_Size() int

func (*ColumnValue) XXX_Unmarshal 

func (m *ColumnValue) XXX_Unmarshal(b []byte) error

type ColumnsRequest 

type ColumnsRequest struct {
	Catalog              string   `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
	SchemaPattern        string   `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
	TableNamePattern     string   `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern,proto3" json:"table_name_pattern,omitempty"`
	ColumnNamePattern    string   `protobuf:"bytes,4,opt,name=column_name_pattern,json=columnNamePattern,proto3" json:"column_name_pattern,omitempty"`
	ConnectionId         string   `protobuf:"bytes,5,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

func (m *ColumnsRequest) GetCatalog() string

func (*ColumnsRequest) GetColumnNamePattern 

func (m *ColumnsRequest) GetColumnNamePattern() string

func (*ColumnsRequest) GetConnectionId 

func (m *ColumnsRequest) GetConnectionId() string

func (*ColumnsRequest) GetSchemaPattern 

func (m *ColumnsRequest) GetSchemaPattern() string

func (*ColumnsRequest) GetTableNamePattern 

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

func (*ColumnsRequest) XXX_DiscardUnknown 

func (m *ColumnsRequest) XXX_DiscardUnknown()

func (*ColumnsRequest) XXX_Marshal 

func (m *ColumnsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColumnsRequest) XXX_Merge 

func (dst *ColumnsRequest) XXX_Merge(src proto.Message)

func (*ColumnsRequest) XXX_Size 

func (m *ColumnsRequest) XXX_Size() int

func (*ColumnsRequest) XXX_Unmarshal 

func (m *ColumnsRequest) XXX_Unmarshal(b []byte) error

type CommitRequest 

type CommitRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to invoke a commit on a Connection

func (*CommitRequest) Descriptor 

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

func (*CommitRequest) GetConnectionId 

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

func (*CommitRequest) XXX_DiscardUnknown 

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal 

func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitRequest) XXX_Merge 

func (dst *CommitRequest) XXX_Merge(src proto.Message)

func (*CommitRequest) XXX_Size 

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal 

func (m *CommitRequest) XXX_Unmarshal(b []byte) error

type CommitResponse 

type CommitResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*CommitResponse) XXX_DiscardUnknown 

func (m *CommitResponse) XXX_DiscardUnknown()

func (*CommitResponse) XXX_Marshal 

func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitResponse) XXX_Merge 

func (dst *CommitResponse) XXX_Merge(src proto.Message)

func (*CommitResponse) XXX_Size 

func (m *CommitResponse) XXX_Size() int

func (*CommitResponse) XXX_Unmarshal 

func (m *CommitResponse) XXX_Unmarshal(b []byte) error

type ConnectionProperties 

type ConnectionProperties struct {
	IsDirty              bool     `protobuf:"varint,1,opt,name=is_dirty,json=isDirty,proto3" json:"is_dirty,omitempty"`
	AutoCommit           bool     `protobuf:"varint,2,opt,name=auto_commit,json=autoCommit,proto3" json:"auto_commit,omitempty"`
	HasAutoCommit        bool     `protobuf:"varint,7,opt,name=has_auto_commit,json=hasAutoCommit,proto3" json:"has_auto_commit,omitempty"`
	ReadOnly             bool     `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	HasReadOnly          bool     `protobuf:"varint,8,opt,name=has_read_only,json=hasReadOnly,proto3" json:"has_read_only,omitempty"`
	TransactionIsolation uint32   `protobuf:"varint,4,opt,name=transaction_isolation,json=transactionIsolation,proto3" json:"transaction_isolation,omitempty"`
	Catalog              string   `protobuf:"bytes,5,opt,name=catalog,proto3" json:"catalog,omitempty"`
	Schema               string   `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Details about a connection

func (*ConnectionProperties) Descriptor 

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

func (*ConnectionProperties) GetAutoCommit 

func (m *ConnectionProperties) GetAutoCommit() bool

func (*ConnectionProperties) GetCatalog 

func (m *ConnectionProperties) GetCatalog() string

func (*ConnectionProperties) GetHasAutoCommit 

func (m *ConnectionProperties) GetHasAutoCommit() bool

func (*ConnectionProperties) GetHasReadOnly 

func (m *ConnectionProperties) GetHasReadOnly() bool

func (*ConnectionProperties) GetIsDirty 

func (m *ConnectionProperties) GetIsDirty() bool

func (*ConnectionProperties) GetReadOnly 

func (m *ConnectionProperties) GetReadOnly() bool

func (*ConnectionProperties) GetSchema 

func (m *ConnectionProperties) GetSchema() string

func (*ConnectionProperties) GetTransactionIsolation 

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

func (*ConnectionProperties) XXX_DiscardUnknown 

func (m *ConnectionProperties) XXX_DiscardUnknown()

func (*ConnectionProperties) XXX_Marshal 

func (m *ConnectionProperties) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionProperties) XXX_Merge 

func (dst *ConnectionProperties) XXX_Merge(src proto.Message)

func (*ConnectionProperties) XXX_Size 

func (m *ConnectionProperties) XXX_Size() int

func (*ConnectionProperties) XXX_Unmarshal 

func (m *ConnectionProperties) XXX_Unmarshal(b []byte) error

type ConnectionSyncRequest 

type ConnectionSyncRequest struct {
	ConnectionId         string                `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ConnProps            *ConnectionProperties `protobuf:"bytes,2,opt,name=conn_props,json=connProps,proto3" json:"conn_props,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConnectionSyncRequest) Descriptor 

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

func (*ConnectionSyncRequest) GetConnProps 

func (m *ConnectionSyncRequest) GetConnProps() *ConnectionProperties

func (*ConnectionSyncRequest) GetConnectionId 

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

func (*ConnectionSyncRequest) XXX_DiscardUnknown 

func (m *ConnectionSyncRequest) XXX_DiscardUnknown()

func (*ConnectionSyncRequest) XXX_Marshal 

func (m *ConnectionSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionSyncRequest) XXX_Merge 

func (dst *ConnectionSyncRequest) XXX_Merge(src proto.Message)

func (*ConnectionSyncRequest) XXX_Size 

func (m *ConnectionSyncRequest) XXX_Size() int

func (*ConnectionSyncRequest) XXX_Unmarshal 

func (m *ConnectionSyncRequest) XXX_Unmarshal(b []byte) error

type ConnectionSyncResponse 

type ConnectionSyncResponse struct {
	ConnProps            *ConnectionProperties `protobuf:"bytes,1,opt,name=conn_props,json=connProps,proto3" json:"conn_props,omitempty"`
	Metadata             *RpcMetadata          `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*ConnectionSyncResponse) XXX_DiscardUnknown 

func (m *ConnectionSyncResponse) XXX_DiscardUnknown()

func (*ConnectionSyncResponse) XXX_Marshal 

func (m *ConnectionSyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionSyncResponse) XXX_Merge 

func (dst *ConnectionSyncResponse) XXX_Merge(src proto.Message)

func (*ConnectionSyncResponse) XXX_Size 

func (m *ConnectionSyncResponse) XXX_Size() int

func (*ConnectionSyncResponse) XXX_Unmarshal 

func (m *ConnectionSyncResponse) XXX_Unmarshal(b []byte) error

type CreateStatementRequest 

type CreateStatementRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for Meta#createStatement(Meta.ConnectionHandle)

func (*CreateStatementRequest) Descriptor 

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

func (*CreateStatementRequest) GetConnectionId 

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

func (*CreateStatementRequest) XXX_DiscardUnknown 

func (m *CreateStatementRequest) XXX_DiscardUnknown()

func (*CreateStatementRequest) XXX_Marshal 

func (m *CreateStatementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateStatementRequest) XXX_Merge 

func (dst *CreateStatementRequest) XXX_Merge(src proto.Message)

func (*CreateStatementRequest) XXX_Size 

func (m *CreateStatementRequest) XXX_Size() int

func (*CreateStatementRequest) XXX_Unmarshal 

func (m *CreateStatementRequest) XXX_Unmarshal(b []byte) error

type CreateStatementResponse 

type CreateStatementResponse struct {
	ConnectionId         string       `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	StatementId          uint32       `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	Metadata             *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Response to CreateStatementRequest

func (*CreateStatementResponse) Descriptor 

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

func (*CreateStatementResponse) GetConnectionId 

func (m *CreateStatementResponse) GetConnectionId() string

func (*CreateStatementResponse) GetMetadata 

func (m *CreateStatementResponse) GetMetadata() *RpcMetadata

func (*CreateStatementResponse) GetStatementId 

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

func (*CreateStatementResponse) XXX_DiscardUnknown 

func (m *CreateStatementResponse) XXX_DiscardUnknown()

func (*CreateStatementResponse) XXX_Marshal 

func (m *CreateStatementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateStatementResponse) XXX_Merge 

func (dst *CreateStatementResponse) XXX_Merge(src proto.Message)

func (*CreateStatementResponse) XXX_Size 

func (m *CreateStatementResponse) XXX_Size() int

func (*CreateStatementResponse) XXX_Unmarshal 

func (m *CreateStatementResponse) XXX_Unmarshal(b []byte) error

type CursorFactory 

type CursorFactory struct {
	Style                CursorFactory_Style `protobuf:"varint,1,opt,name=style,proto3,enum=CursorFactory_Style" json:"style,omitempty"`
	ClassName            string              `protobuf:"bytes,2,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"`
	FieldNames           []string            `protobuf:"bytes,3,rep,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Information necessary to convert an Iterable into a Calcite Cursor

func (*CursorFactory) Descriptor 

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

func (*CursorFactory) GetClassName 

func (m *CursorFactory) GetClassName() string

func (*CursorFactory) GetFieldNames 

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

func (*CursorFactory) GetStyle 

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

func (*CursorFactory) XXX_DiscardUnknown 

func (m *CursorFactory) XXX_DiscardUnknown()

func (*CursorFactory) XXX_Marshal 

func (m *CursorFactory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CursorFactory) XXX_Merge 

func (dst *CursorFactory) XXX_Merge(src proto.Message)

func (*CursorFactory) XXX_Size 

func (m *CursorFactory) XXX_Size() int

func (*CursorFactory) XXX_Unmarshal 

func (m *CursorFactory) XXX_Unmarshal(b []byte) error

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,proto3" json:"name,omitempty"`
	Functions            []string `protobuf:"bytes,2,rep,name=functions,proto3" json:"functions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*DatabaseProperty) Descriptor 

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

func (*DatabaseProperty) GetFunctions 

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

func (*DatabaseProperty) GetName 

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

func (*DatabaseProperty) XXX_DiscardUnknown 

func (m *DatabaseProperty) XXX_DiscardUnknown()

func (*DatabaseProperty) XXX_Marshal 

func (m *DatabaseProperty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatabaseProperty) XXX_Merge 

func (dst *DatabaseProperty) XXX_Merge(src proto.Message)

func (*DatabaseProperty) XXX_Size 

func (m *DatabaseProperty) XXX_Size() int

func (*DatabaseProperty) XXX_Unmarshal 

func (m *DatabaseProperty) XXX_Unmarshal(b []byte) error

type DatabasePropertyElement 

type DatabasePropertyElement struct {
	Key                  *DatabaseProperty `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *TypedValue       `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Metadata             *RpcMetadata      `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*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

func (*DatabasePropertyElement) XXX_DiscardUnknown 

func (m *DatabasePropertyElement) XXX_DiscardUnknown()

func (*DatabasePropertyElement) XXX_Marshal 

func (m *DatabasePropertyElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatabasePropertyElement) XXX_Merge 

func (dst *DatabasePropertyElement) XXX_Merge(src proto.Message)

func (*DatabasePropertyElement) XXX_Size 

func (m *DatabasePropertyElement) XXX_Size() int

func (*DatabasePropertyElement) XXX_Unmarshal 

func (m *DatabasePropertyElement) XXX_Unmarshal(b []byte) error

type DatabasePropertyRequest 

type DatabasePropertyRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for Meta#getDatabaseProperties()

func (*DatabasePropertyRequest) Descriptor 

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

func (*DatabasePropertyRequest) GetConnectionId 

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

func (*DatabasePropertyRequest) XXX_DiscardUnknown 

func (m *DatabasePropertyRequest) XXX_DiscardUnknown()

func (*DatabasePropertyRequest) XXX_Marshal 

func (m *DatabasePropertyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatabasePropertyRequest) XXX_Merge 

func (dst *DatabasePropertyRequest) XXX_Merge(src proto.Message)

func (*DatabasePropertyRequest) XXX_Size 

func (m *DatabasePropertyRequest) XXX_Size() int

func (*DatabasePropertyRequest) XXX_Unmarshal 

func (m *DatabasePropertyRequest) XXX_Unmarshal(b []byte) error

type DatabasePropertyResponse 

type DatabasePropertyResponse struct {
	Props                []*DatabasePropertyElement `protobuf:"bytes,1,rep,name=props,proto3" json:"props,omitempty"`
	Metadata             *RpcMetadata               `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

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

func (*DatabasePropertyResponse) XXX_DiscardUnknown 

func (m *DatabasePropertyResponse) XXX_DiscardUnknown()

func (*DatabasePropertyResponse) XXX_Marshal 

func (m *DatabasePropertyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatabasePropertyResponse) XXX_Merge 

func (dst *DatabasePropertyResponse) XXX_Merge(src proto.Message)

func (*DatabasePropertyResponse) XXX_Size 

func (m *DatabasePropertyResponse) XXX_Size() int

func (*DatabasePropertyResponse) XXX_Unmarshal 

func (m *DatabasePropertyResponse) XXX_Unmarshal(b []byte) error

type ErrorResponse 

type ErrorResponse struct {
	Exceptions           []string     `protobuf:"bytes,1,rep,name=exceptions,proto3" json:"exceptions,omitempty"`
	HasExceptions        bool         `protobuf:"varint,7,opt,name=has_exceptions,json=hasExceptions,proto3" json:"has_exceptions,omitempty"`
	ErrorMessage         string       `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Severity             Severity     `protobuf:"varint,3,opt,name=severity,proto3,enum=Severity" json:"severity,omitempty"`
	ErrorCode            uint32       `protobuf:"varint,4,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	SqlState             string       `protobuf:"bytes,5,opt,name=sql_state,json=sqlState,proto3" json:"sql_state,omitempty"`
	Metadata             *RpcMetadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

func (*ErrorResponse) Descriptor 

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

func (*ErrorResponse) GetErrorCode 

func (m *ErrorResponse) GetErrorCode() uint32

func (*ErrorResponse) GetErrorMessage 

func (m *ErrorResponse) GetErrorMessage() string

func (*ErrorResponse) GetExceptions 

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

func (*ErrorResponse) GetHasExceptions 

func (m *ErrorResponse) GetHasExceptions() bool

func (*ErrorResponse) GetMetadata 

func (m *ErrorResponse) GetMetadata() *RpcMetadata

func (*ErrorResponse) GetSeverity 

func (m *ErrorResponse) GetSeverity() Severity

func (*ErrorResponse) GetSqlState 

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

func (*ErrorResponse) XXX_DiscardUnknown 

func (m *ErrorResponse) XXX_DiscardUnknown()

func (*ErrorResponse) XXX_Marshal 

func (m *ErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorResponse) XXX_Merge 

func (dst *ErrorResponse) XXX_Merge(src proto.Message)

func (*ErrorResponse) XXX_Size 

func (m *ErrorResponse) XXX_Size() int

func (*ErrorResponse) XXX_Unmarshal 

func (m *ErrorResponse) XXX_Unmarshal(b []byte) error

type ExecuteBatchRequest 

type ExecuteBatchRequest struct {
	ConnectionId         string         `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	StatementId          uint32         `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	Updates              []*UpdateBatch `protobuf:"bytes,3,rep,name=updates,proto3" json:"updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ExecuteBatchRequest) Descriptor 

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

func (*ExecuteBatchRequest) GetConnectionId 

func (m *ExecuteBatchRequest) GetConnectionId() string

func (*ExecuteBatchRequest) GetStatementId 

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

func (*ExecuteBatchRequest) XXX_DiscardUnknown 

func (m *ExecuteBatchRequest) XXX_DiscardUnknown()

func (*ExecuteBatchRequest) XXX_Marshal 

func (m *ExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteBatchRequest) XXX_Merge 

func (dst *ExecuteBatchRequest) XXX_Merge(src proto.Message)

func (*ExecuteBatchRequest) XXX_Size 

func (m *ExecuteBatchRequest) XXX_Size() int

func (*ExecuteBatchRequest) XXX_Unmarshal 

func (m *ExecuteBatchRequest) XXX_Unmarshal(b []byte) error

type ExecuteBatchResponse 

type ExecuteBatchResponse struct {
	ConnectionId         string       `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	StatementId          uint32       `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	UpdateCounts         []uint64     `protobuf:"varint,3,rep,packed,name=update_counts,json=updateCounts,proto3" json:"update_counts,omitempty"`
	MissingStatement     bool         `protobuf:"varint,4,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"`
	Metadata             *RpcMetadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Response to a batch update request

func (*ExecuteBatchResponse) Descriptor 

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

func (*ExecuteBatchResponse) GetConnectionId 

func (m *ExecuteBatchResponse) GetConnectionId() string

func (*ExecuteBatchResponse) GetMetadata 

func (m *ExecuteBatchResponse) GetMetadata() *RpcMetadata

func (*ExecuteBatchResponse) GetMissingStatement 

func (m *ExecuteBatchResponse) GetMissingStatement() bool

func (*ExecuteBatchResponse) GetStatementId 

func (m *ExecuteBatchResponse) GetStatementId() uint32

func (*ExecuteBatchResponse) GetUpdateCounts 

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

func (*ExecuteBatchResponse) XXX_DiscardUnknown 

func (m *ExecuteBatchResponse) XXX_DiscardUnknown()

func (*ExecuteBatchResponse) XXX_Marshal 

func (m *ExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteBatchResponse) XXX_Merge 

func (dst *ExecuteBatchResponse) XXX_Merge(src proto.Message)

func (*ExecuteBatchResponse) XXX_Size 

func (m *ExecuteBatchResponse) XXX_Size() int

func (*ExecuteBatchResponse) XXX_Unmarshal 

func (m *ExecuteBatchResponse) XXX_Unmarshal(b []byte) error

type ExecuteRequest 

type ExecuteRequest struct {
	StatementHandle             *StatementHandle `protobuf:"bytes,1,opt,name=statementHandle,proto3" json:"statementHandle,omitempty"`
	ParameterValues             []*TypedValue    `protobuf:"bytes,2,rep,name=parameter_values,json=parameterValues,proto3" json:"parameter_values,omitempty"`
	DeprecatedFirstFrameMaxSize uint64           `` /* 149-byte string literal not displayed */
	HasParameterValues          bool             `protobuf:"varint,4,opt,name=has_parameter_values,json=hasParameterValues,proto3" json:"has_parameter_values,omitempty"`
	FirstFrameMaxSize           int32            `protobuf:"varint,5,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3" json:"first_frame_max_size,omitempty"`
	XXX_NoUnkeyedLiteral        struct{}         `json:"-"`
	XXX_unrecognized            []byte           `json:"-"`
	XXX_sizecache               int32            `json:"-"`
}

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 

func (m *ExecuteRequest) GetFirstFrameMaxSize() int32

func (*ExecuteRequest) GetHasParameterValues 

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

func (*ExecuteRequest) XXX_DiscardUnknown 

func (m *ExecuteRequest) XXX_DiscardUnknown()

func (*ExecuteRequest) XXX_Marshal 

func (m *ExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteRequest) XXX_Merge 

func (dst *ExecuteRequest) XXX_Merge(src proto.Message)

func (*ExecuteRequest) XXX_Size 

func (m *ExecuteRequest) XXX_Size() int

func (*ExecuteRequest) XXX_Unmarshal 

func (m *ExecuteRequest) XXX_Unmarshal(b []byte) error

type ExecuteResponse 

type ExecuteResponse struct {
	Results              []*ResultSetResponse `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	MissingStatement     bool                 `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"`
	Metadata             *RpcMetadata         `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Response to PrepareAndExecuteRequest

func (*ExecuteResponse) Descriptor 

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

func (*ExecuteResponse) GetMetadata 

func (m *ExecuteResponse) GetMetadata() *RpcMetadata

func (*ExecuteResponse) GetMissingStatement 

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

func (*ExecuteResponse) XXX_DiscardUnknown 

func (m *ExecuteResponse) XXX_DiscardUnknown()

func (*ExecuteResponse) XXX_Marshal 

func (m *ExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteResponse) XXX_Merge 

func (dst *ExecuteResponse) XXX_Merge(src proto.Message)

func (*ExecuteResponse) XXX_Size 

func (m *ExecuteResponse) XXX_Size() int

func (*ExecuteResponse) XXX_Unmarshal 

func (m *ExecuteResponse) XXX_Unmarshal(b []byte) error

type FetchRequest 

type FetchRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	StatementId          uint32   `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	Offset               uint64   `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	FetchMaxRowCount     uint32   `protobuf:"varint,4,opt,name=fetch_max_row_count,json=fetchMaxRowCount,proto3" json:"fetch_max_row_count,omitempty"`
	FrameMaxSize         int32    `protobuf:"varint,5,opt,name=frame_max_size,json=frameMaxSize,proto3" json:"frame_max_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*FetchRequest) Descriptor 

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

func (*FetchRequest) GetConnectionId 

func (m *FetchRequest) GetConnectionId() string

func (*FetchRequest) GetFetchMaxRowCount 

func (m *FetchRequest) GetFetchMaxRowCount() uint32

func (*FetchRequest) GetFrameMaxSize 

func (m *FetchRequest) GetFrameMaxSize() int32

func (*FetchRequest) GetOffset 

func (m *FetchRequest) GetOffset() uint64

func (*FetchRequest) GetStatementId 

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

func (*FetchRequest) XXX_DiscardUnknown 

func (m *FetchRequest) XXX_DiscardUnknown()

func (*FetchRequest) XXX_Marshal 

func (m *FetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchRequest) XXX_Merge 

func (dst *FetchRequest) XXX_Merge(src proto.Message)

func (*FetchRequest) XXX_Size 

func (m *FetchRequest) XXX_Size() int

func (*FetchRequest) XXX_Unmarshal 

func (m *FetchRequest) XXX_Unmarshal(b []byte) error

type FetchResponse 

type FetchResponse struct {
	Frame                *Frame       `protobuf:"bytes,1,opt,name=frame,proto3" json:"frame,omitempty"`
	MissingStatement     bool         `protobuf:"varint,2,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"`
	MissingResults       bool         `protobuf:"varint,3,opt,name=missing_results,json=missingResults,proto3" json:"missing_results,omitempty"`
	Metadata             *RpcMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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 

func (m *FetchResponse) GetMissingResults() bool

func (*FetchResponse) GetMissingStatement 

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

func (*FetchResponse) XXX_DiscardUnknown 

func (m *FetchResponse) XXX_DiscardUnknown()

func (*FetchResponse) XXX_Marshal 

func (m *FetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchResponse) XXX_Merge 

func (dst *FetchResponse) XXX_Merge(src proto.Message)

func (*FetchResponse) XXX_Size 

func (m *FetchResponse) XXX_Size() int

func (*FetchResponse) XXX_Unmarshal 

func (m *FetchResponse) XXX_Unmarshal(b []byte) error

type Frame 

type Frame struct {
	Offset               uint64   `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Done                 bool     `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	Rows                 []*Row   `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A collection of rows

func (*Frame) Descriptor 

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

func (*Frame) GetDone 

func (m *Frame) GetDone() bool

func (*Frame) GetOffset 

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

func (*Frame) XXX_DiscardUnknown 

func (m *Frame) XXX_DiscardUnknown()

func (*Frame) XXX_Marshal 

func (m *Frame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Frame) XXX_Merge 

func (dst *Frame) XXX_Merge(src proto.Message)

func (*Frame) XXX_Size 

func (m *Frame) XXX_Size() int

func (*Frame) XXX_Unmarshal 

func (m *Frame) XXX_Unmarshal(b []byte) error

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,proto3" json:"string_value,omitempty"`
	BoolValue            bool                                   `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
	IntValue             int32                                  `protobuf:"zigzag32,3,opt,name=int_value,json=intValue,proto3" json:"int_value,omitempty"`
	StringArrayValues    []string                               `protobuf:"bytes,4,rep,name=string_array_values,json=stringArrayValues,proto3" json:"string_array_values,omitempty"`
	IntArrayValues       []int32                                `protobuf:"zigzag32,5,rep,packed,name=int_array_values,json=intArrayValues,proto3" json:"int_array_values,omitempty"`
	Type                 MetaDataOperationArgument_ArgumentType `protobuf:"varint,6,opt,name=type,proto3,enum=MetaDataOperationArgument_ArgumentType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

Represents the breadth of arguments to DatabaseMetaData functions

func (*MetaDataOperationArgument) Descriptor 

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

func (*MetaDataOperationArgument) GetBoolValue 

func (m *MetaDataOperationArgument) GetBoolValue() bool

func (*MetaDataOperationArgument) GetIntArrayValues 

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

func (*MetaDataOperationArgument) GetIntValue 

func (m *MetaDataOperationArgument) GetIntValue() int32

func (*MetaDataOperationArgument) GetStringArrayValues 

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

func (*MetaDataOperationArgument) GetStringValue 

func (m *MetaDataOperationArgument) GetStringValue() string

func (*MetaDataOperationArgument) GetType 

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

func (*MetaDataOperationArgument) XXX_DiscardUnknown 

func (m *MetaDataOperationArgument) XXX_DiscardUnknown()

func (*MetaDataOperationArgument) XXX_Marshal 

func (m *MetaDataOperationArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetaDataOperationArgument) XXX_Merge 

func (dst *MetaDataOperationArgument) XXX_Merge(src proto.Message)

func (*MetaDataOperationArgument) XXX_Size 

func (m *MetaDataOperationArgument) XXX_Size() int

func (*MetaDataOperationArgument) XXX_Unmarshal 

func (m *MetaDataOperationArgument) XXX_Unmarshal(b []byte) error

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,proto3" json:"connection_id,omitempty"`
	Info                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*OpenConnectionRequest) Descriptor 

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

func (*OpenConnectionRequest) GetConnectionId 

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

func (*OpenConnectionRequest) XXX_DiscardUnknown 

func (m *OpenConnectionRequest) XXX_DiscardUnknown()

func (*OpenConnectionRequest) XXX_Marshal 

func (m *OpenConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenConnectionRequest) XXX_Merge 

func (dst *OpenConnectionRequest) XXX_Merge(src proto.Message)

func (*OpenConnectionRequest) XXX_Size 

func (m *OpenConnectionRequest) XXX_Size() int

func (*OpenConnectionRequest) XXX_Unmarshal 

func (m *OpenConnectionRequest) XXX_Unmarshal(b []byte) error

type OpenConnectionResponse 

type OpenConnectionResponse struct {
	Metadata             *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

func (*OpenConnectionResponse) XXX_DiscardUnknown 

func (m *OpenConnectionResponse) XXX_DiscardUnknown()

func (*OpenConnectionResponse) XXX_Marshal 

func (m *OpenConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenConnectionResponse) XXX_Merge 

func (dst *OpenConnectionResponse) XXX_Merge(src proto.Message)

func (*OpenConnectionResponse) XXX_Size 

func (m *OpenConnectionResponse) XXX_Size() int

func (*OpenConnectionResponse) XXX_Unmarshal 

func (m *OpenConnectionResponse) XXX_Unmarshal(b []byte) error

type PrepareAndExecuteBatchRequest 

type PrepareAndExecuteBatchRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	StatementId          uint32   `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	SqlCommands          []string `protobuf:"bytes,3,rep,name=sql_commands,json=sqlCommands,proto3" json:"sql_commands,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to prepare and execute a collection of sql statements.

func (*PrepareAndExecuteBatchRequest) Descriptor 

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

func (*PrepareAndExecuteBatchRequest) GetConnectionId 

func (m *PrepareAndExecuteBatchRequest) GetConnectionId() string

func (*PrepareAndExecuteBatchRequest) GetSqlCommands 

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

func (*PrepareAndExecuteBatchRequest) GetStatementId 

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

func (*PrepareAndExecuteBatchRequest) XXX_DiscardUnknown 

func (m *PrepareAndExecuteBatchRequest) XXX_DiscardUnknown()

func (*PrepareAndExecuteBatchRequest) XXX_Marshal 

func (m *PrepareAndExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareAndExecuteBatchRequest) XXX_Merge 

func (dst *PrepareAndExecuteBatchRequest) XXX_Merge(src proto.Message)

func (*PrepareAndExecuteBatchRequest) XXX_Size 

func (m *PrepareAndExecuteBatchRequest) XXX_Size() int

func (*PrepareAndExecuteBatchRequest) XXX_Unmarshal 

func (m *PrepareAndExecuteBatchRequest) XXX_Unmarshal(b []byte) error

type PrepareAndExecuteRequest 

type PrepareAndExecuteRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Sql                  string   `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	MaxRowCount          uint64   `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount,proto3" json:"max_row_count,omitempty"`
	StatementId          uint32   `protobuf:"varint,4,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	MaxRowsTotal         int64    `protobuf:"varint,5,opt,name=max_rows_total,json=maxRowsTotal,proto3" json:"max_rows_total,omitempty"`
	FirstFrameMaxSize    int32    `protobuf:"varint,6,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3" json:"first_frame_max_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*PrepareAndExecuteRequest) Descriptor 

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

func (*PrepareAndExecuteRequest) GetConnectionId 

func (m *PrepareAndExecuteRequest) GetConnectionId() string

func (*PrepareAndExecuteRequest) GetFirstFrameMaxSize 

func (m *PrepareAndExecuteRequest) GetFirstFrameMaxSize() int32

func (*PrepareAndExecuteRequest) GetMaxRowCount 

func (m *PrepareAndExecuteRequest) GetMaxRowCount() uint64

func (*PrepareAndExecuteRequest) GetMaxRowsTotal 

func (m *PrepareAndExecuteRequest) GetMaxRowsTotal() int64

func (*PrepareAndExecuteRequest) GetSql 

func (m *PrepareAndExecuteRequest) GetSql() string

func (*PrepareAndExecuteRequest) GetStatementId 

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

func (*PrepareAndExecuteRequest) XXX_DiscardUnknown 

func (m *PrepareAndExecuteRequest) XXX_DiscardUnknown()

func (*PrepareAndExecuteRequest) XXX_Marshal 

func (m *PrepareAndExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareAndExecuteRequest) XXX_Merge 

func (dst *PrepareAndExecuteRequest) XXX_Merge(src proto.Message)

func (*PrepareAndExecuteRequest) XXX_Size 

func (m *PrepareAndExecuteRequest) XXX_Size() int

func (*PrepareAndExecuteRequest) XXX_Unmarshal 

func (m *PrepareAndExecuteRequest) XXX_Unmarshal(b []byte) error

type PrepareRequest 

type PrepareRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Sql                  string   `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	MaxRowCount          uint64   `protobuf:"varint,3,opt,name=max_row_count,json=maxRowCount,proto3" json:"max_row_count,omitempty"`
	MaxRowsTotal         int64    `protobuf:"varint,4,opt,name=max_rows_total,json=maxRowsTotal,proto3" json:"max_rows_total,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*PrepareRequest) Descriptor 

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

func (*PrepareRequest) GetConnectionId 

func (m *PrepareRequest) GetConnectionId() string

func (*PrepareRequest) GetMaxRowCount 

func (m *PrepareRequest) GetMaxRowCount() uint64

func (*PrepareRequest) GetMaxRowsTotal 

func (m *PrepareRequest) GetMaxRowsTotal() int64

func (*PrepareRequest) GetSql 

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

func (*PrepareRequest) XXX_DiscardUnknown 

func (m *PrepareRequest) XXX_DiscardUnknown()

func (*PrepareRequest) XXX_Marshal 

func (m *PrepareRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareRequest) XXX_Merge 

func (dst *PrepareRequest) XXX_Merge(src proto.Message)

func (*PrepareRequest) XXX_Size 

func (m *PrepareRequest) XXX_Size() int

func (*PrepareRequest) XXX_Unmarshal 

func (m *PrepareRequest) XXX_Unmarshal(b []byte) error

type PrepareResponse 

type PrepareResponse struct {
	Statement            *StatementHandle `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"`
	Metadata             *RpcMetadata     `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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

func (*PrepareResponse) XXX_DiscardUnknown 

func (m *PrepareResponse) XXX_DiscardUnknown()

func (*PrepareResponse) XXX_Marshal 

func (m *PrepareResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareResponse) XXX_Merge 

func (dst *PrepareResponse) XXX_Merge(src proto.Message)

func (*PrepareResponse) XXX_Size 

func (m *PrepareResponse) XXX_Size() int

func (*PrepareResponse) XXX_Unmarshal 

func (m *PrepareResponse) XXX_Unmarshal(b []byte) error

type QueryState 

type QueryState struct {
	Type                 StateType                    `protobuf:"varint,1,opt,name=type,proto3,enum=StateType" json:"type,omitempty"`
	Sql                  string                       `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	Op                   MetaDataOperation            `protobuf:"varint,3,opt,name=op,proto3,enum=MetaDataOperation" json:"op,omitempty"`
	Args                 []*MetaDataOperationArgument `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	HasArgs              bool                         `protobuf:"varint,5,opt,name=has_args,json=hasArgs,proto3" json:"has_args,omitempty"`
	HasSql               bool                         `protobuf:"varint,6,opt,name=has_sql,json=hasSql,proto3" json:"has_sql,omitempty"`
	HasOp                bool                         `protobuf:"varint,7,opt,name=has_op,json=hasOp,proto3" json:"has_op,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*QueryState) Descriptor 

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

func (*QueryState) GetArgs 

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

func (*QueryState) GetHasArgs 

func (m *QueryState) GetHasArgs() bool

func (*QueryState) GetHasOp 

func (m *QueryState) GetHasOp() bool

func (*QueryState) GetHasSql 

func (m *QueryState) GetHasSql() bool

func (*QueryState) GetOp 

func (m *QueryState) GetOp() MetaDataOperation

func (*QueryState) GetSql 

func (m *QueryState) GetSql() string

func (*QueryState) GetType 

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

func (*QueryState) XXX_DiscardUnknown 

func (m *QueryState) XXX_DiscardUnknown()

func (*QueryState) XXX_Marshal 

func (m *QueryState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryState) XXX_Merge 

func (dst *QueryState) XXX_Merge(src proto.Message)

func (*QueryState) XXX_Size 

func (m *QueryState) XXX_Size() int

func (*QueryState) XXX_Unmarshal 

func (m *QueryState) XXX_Unmarshal(b []byte) error

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,proto3" json:"connection_id,omitempty"`
	StatementId  uint32     `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	OwnStatement bool       `protobuf:"varint,3,opt,name=own_statement,json=ownStatement,proto3" json:"own_statement,omitempty"`
	Signature    *Signature `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	FirstFrame   *Frame     `protobuf:"bytes,5,opt,name=first_frame,json=firstFrame,proto3" json:"first_frame,omitempty"`
	UpdateCount  uint64     `protobuf:"varint,6,opt,name=update_count,json=updateCount,proto3" json:"update_count,omitempty"`
	// with no signature nor other data.
	Metadata             *RpcMetadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Response that contains a result set.

func (*ResultSetResponse) Descriptor 

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

func (*ResultSetResponse) GetConnectionId 

func (m *ResultSetResponse) GetConnectionId() string

func (*ResultSetResponse) GetFirstFrame 

func (m *ResultSetResponse) GetFirstFrame() *Frame

func (*ResultSetResponse) GetMetadata 

func (m *ResultSetResponse) GetMetadata() *RpcMetadata

func (*ResultSetResponse) GetOwnStatement 

func (m *ResultSetResponse) GetOwnStatement() bool

func (*ResultSetResponse) GetSignature 

func (m *ResultSetResponse) GetSignature() *Signature

func (*ResultSetResponse) GetStatementId 

func (m *ResultSetResponse) GetStatementId() uint32

func (*ResultSetResponse) GetUpdateCount 

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

func (*ResultSetResponse) XXX_DiscardUnknown 

func (m *ResultSetResponse) XXX_DiscardUnknown()

func (*ResultSetResponse) XXX_Marshal 

func (m *ResultSetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultSetResponse) XXX_Merge 

func (dst *ResultSetResponse) XXX_Merge(src proto.Message)

func (*ResultSetResponse) XXX_Size 

func (m *ResultSetResponse) XXX_Size() int

func (*ResultSetResponse) XXX_Unmarshal 

func (m *ResultSetResponse) XXX_Unmarshal(b []byte) error

type RollbackRequest 

type RollbackRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to invoke rollback on a Connection

func (*RollbackRequest) Descriptor 

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

func (*RollbackRequest) GetConnectionId 

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

func (*RollbackRequest) XXX_DiscardUnknown 

func (m *RollbackRequest) XXX_DiscardUnknown()

func (*RollbackRequest) XXX_Marshal 

func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollbackRequest) XXX_Merge 

func (dst *RollbackRequest) XXX_Merge(src proto.Message)

func (*RollbackRequest) XXX_Size 

func (m *RollbackRequest) XXX_Size() int

func (*RollbackRequest) XXX_Unmarshal 

func (m *RollbackRequest) XXX_Unmarshal(b []byte) error

type RollbackResponse 

type RollbackResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*RollbackResponse) XXX_DiscardUnknown 

func (m *RollbackResponse) XXX_DiscardUnknown()

func (*RollbackResponse) XXX_Marshal 

func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollbackResponse) XXX_Merge 

func (dst *RollbackResponse) XXX_Merge(src proto.Message)

func (*RollbackResponse) XXX_Size 

func (m *RollbackResponse) XXX_Size() int

func (*RollbackResponse) XXX_Unmarshal 

func (m *RollbackResponse) XXX_Unmarshal(b []byte) error

type Row 

type Row struct {
	Value                []*ColumnValue `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Row) XXX_Merge 

func (dst *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

func (m *Row) XXX_Unmarshal(b []byte) error

type RpcMetadata 

type RpcMetadata struct {
	ServerAddress        string   `protobuf:"bytes,1,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Generic metadata for the server to return with each response.

func (*RpcMetadata) Descriptor 

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

func (*RpcMetadata) GetServerAddress 

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

func (*RpcMetadata) XXX_DiscardUnknown 

func (m *RpcMetadata) XXX_DiscardUnknown()

func (*RpcMetadata) XXX_Marshal 

func (m *RpcMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcMetadata) XXX_Merge 

func (dst *RpcMetadata) XXX_Merge(src proto.Message)

func (*RpcMetadata) XXX_Size 

func (m *RpcMetadata) XXX_Size() int

func (*RpcMetadata) XXX_Unmarshal 

func (m *RpcMetadata) XXX_Unmarshal(b []byte) error

type SchemasRequest 

type SchemasRequest struct {
	Catalog              string   `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
	SchemaPattern        string   `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
	ConnectionId         string   `protobuf:"bytes,3,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*SchemasRequest) Descriptor 

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

func (*SchemasRequest) GetCatalog 

func (m *SchemasRequest) GetCatalog() string

func (*SchemasRequest) GetConnectionId 

func (m *SchemasRequest) GetConnectionId() string

func (*SchemasRequest) GetSchemaPattern 

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

func (*SchemasRequest) XXX_DiscardUnknown 

func (m *SchemasRequest) XXX_DiscardUnknown()

func (*SchemasRequest) XXX_Marshal 

func (m *SchemasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemasRequest) XXX_Merge 

func (dst *SchemasRequest) XXX_Merge(src proto.Message)

func (*SchemasRequest) XXX_Size 

func (m *SchemasRequest) XXX_Size() int

func (*SchemasRequest) XXX_Unmarshal 

func (m *SchemasRequest) XXX_Unmarshal(b []byte) error

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,proto3" json:"columns,omitempty"`
	Sql                  string              `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	Parameters           []*AvaticaParameter `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"`
	CursorFactory        *CursorFactory      `protobuf:"bytes,4,opt,name=cursor_factory,json=cursorFactory,proto3" json:"cursor_factory,omitempty"`
	StatementType        StatementType       `protobuf:"varint,5,opt,name=statementType,proto3,enum=StatementType" json:"statementType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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 

func (m *Signature) GetSql() string

func (*Signature) GetStatementType 

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

func (*Signature) XXX_DiscardUnknown 

func (m *Signature) XXX_DiscardUnknown()

func (*Signature) XXX_Marshal 

func (m *Signature) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Signature) XXX_Merge 

func (dst *Signature) XXX_Merge(src proto.Message)

func (*Signature) XXX_Size 

func (m *Signature) XXX_Size() int

func (*Signature) XXX_Unmarshal 

func (m *Signature) XXX_Unmarshal(b []byte) error

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,proto3" json:"connection_id,omitempty"`
	Id                   uint32     `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Signature            *Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Statement handle

func (*StatementHandle) Descriptor 

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

func (*StatementHandle) GetConnectionId 

func (m *StatementHandle) GetConnectionId() string

func (*StatementHandle) GetId 

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

func (*StatementHandle) XXX_DiscardUnknown 

func (m *StatementHandle) XXX_DiscardUnknown()

func (*StatementHandle) XXX_Marshal 

func (m *StatementHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatementHandle) XXX_Merge 

func (dst *StatementHandle) XXX_Merge(src proto.Message)

func (*StatementHandle) XXX_Size 

func (m *StatementHandle) XXX_Size() int

func (*StatementHandle) XXX_Unmarshal 

func (m *StatementHandle) XXX_Unmarshal(b []byte) error

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,proto3" json:"connection_id,omitempty"`
	StatementId          uint32      `protobuf:"varint,2,opt,name=statement_id,json=statementId,proto3" json:"statement_id,omitempty"`
	State                *QueryState `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Offset               uint64      `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SyncResultsRequest) Descriptor 

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

func (*SyncResultsRequest) GetConnectionId 

func (m *SyncResultsRequest) GetConnectionId() string

func (*SyncResultsRequest) GetOffset 

func (m *SyncResultsRequest) GetOffset() uint64

func (*SyncResultsRequest) GetState 

func (m *SyncResultsRequest) GetState() *QueryState

func (*SyncResultsRequest) GetStatementId 

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

func (*SyncResultsRequest) XXX_DiscardUnknown 

func (m *SyncResultsRequest) XXX_DiscardUnknown()

func (*SyncResultsRequest) XXX_Marshal 

func (m *SyncResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncResultsRequest) XXX_Merge 

func (dst *SyncResultsRequest) XXX_Merge(src proto.Message)

func (*SyncResultsRequest) XXX_Size 

func (m *SyncResultsRequest) XXX_Size() int

func (*SyncResultsRequest) XXX_Unmarshal 

func (m *SyncResultsRequest) XXX_Unmarshal(b []byte) error

type SyncResultsResponse 

type SyncResultsResponse struct {
	MissingStatement     bool         `protobuf:"varint,1,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"`
	MoreResults          bool         `protobuf:"varint,2,opt,name=more_results,json=moreResults,proto3" json:"more_results,omitempty"`
	Metadata             *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SyncResultsResponse) Descriptor 

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

func (*SyncResultsResponse) GetMetadata 

func (m *SyncResultsResponse) GetMetadata() *RpcMetadata

func (*SyncResultsResponse) GetMissingStatement 

func (m *SyncResultsResponse) GetMissingStatement() bool

func (*SyncResultsResponse) GetMoreResults 

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

func (*SyncResultsResponse) XXX_DiscardUnknown 

func (m *SyncResultsResponse) XXX_DiscardUnknown()

func (*SyncResultsResponse) XXX_Marshal 

func (m *SyncResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncResultsResponse) XXX_Merge 

func (dst *SyncResultsResponse) XXX_Merge(src proto.Message)

func (*SyncResultsResponse) XXX_Size 

func (m *SyncResultsResponse) XXX_Size() int

func (*SyncResultsResponse) XXX_Unmarshal 

func (m *SyncResultsResponse) XXX_Unmarshal(b []byte) error

type TableTypesRequest 

type TableTypesRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for Meta#getTableTypes()

func (*TableTypesRequest) Descriptor 

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

func (*TableTypesRequest) GetConnectionId 

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

func (*TableTypesRequest) XXX_DiscardUnknown 

func (m *TableTypesRequest) XXX_DiscardUnknown()

func (*TableTypesRequest) XXX_Marshal 

func (m *TableTypesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableTypesRequest) XXX_Merge 

func (dst *TableTypesRequest) XXX_Merge(src proto.Message)

func (*TableTypesRequest) XXX_Size 

func (m *TableTypesRequest) XXX_Size() int

func (*TableTypesRequest) XXX_Unmarshal 

func (m *TableTypesRequest) XXX_Unmarshal(b []byte) error

type TablesRequest 

type TablesRequest struct {
	Catalog              string   `protobuf:"bytes,1,opt,name=catalog,proto3" json:"catalog,omitempty"`
	SchemaPattern        string   `protobuf:"bytes,2,opt,name=schema_pattern,json=schemaPattern,proto3" json:"schema_pattern,omitempty"`
	TableNamePattern     string   `protobuf:"bytes,3,opt,name=table_name_pattern,json=tableNamePattern,proto3" json:"table_name_pattern,omitempty"`
	TypeList             []string `protobuf:"bytes,4,rep,name=type_list,json=typeList,proto3" json:"type_list,omitempty"`
	HasTypeList          bool     `protobuf:"varint,6,opt,name=has_type_list,json=hasTypeList,proto3" json:"has_type_list,omitempty"`
	ConnectionId         string   `protobuf:"bytes,7,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

func (m *TablesRequest) GetCatalog() string

func (*TablesRequest) GetConnectionId 

func (m *TablesRequest) GetConnectionId() string

func (*TablesRequest) GetHasTypeList 

func (m *TablesRequest) GetHasTypeList() bool

func (*TablesRequest) GetSchemaPattern 

func (m *TablesRequest) GetSchemaPattern() string

func (*TablesRequest) GetTableNamePattern 

func (m *TablesRequest) GetTableNamePattern() string

func (*TablesRequest) GetTypeList 

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

func (*TablesRequest) XXX_DiscardUnknown 

func (m *TablesRequest) XXX_DiscardUnknown()

func (*TablesRequest) XXX_Marshal 

func (m *TablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TablesRequest) XXX_Merge 

func (dst *TablesRequest) XXX_Merge(src proto.Message)

func (*TablesRequest) XXX_Size 

func (m *TablesRequest) XXX_Size() int

func (*TablesRequest) XXX_Unmarshal 

func (m *TablesRequest) XXX_Unmarshal(b []byte) error

type TypeInfoRequest 

type TypeInfoRequest struct {
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for Meta#getTypeInfo()

func (*TypeInfoRequest) Descriptor 

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

func (*TypeInfoRequest) GetConnectionId 

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

func (*TypeInfoRequest) XXX_DiscardUnknown 

func (m *TypeInfoRequest) XXX_DiscardUnknown()

func (*TypeInfoRequest) XXX_Marshal 

func (m *TypeInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TypeInfoRequest) XXX_Merge 

func (dst *TypeInfoRequest) XXX_Merge(src proto.Message)

func (*TypeInfoRequest) XXX_Size 

func (m *TypeInfoRequest) XXX_Size() int

func (*TypeInfoRequest) XXX_Unmarshal 

func (m *TypeInfoRequest) XXX_Unmarshal(b []byte) error

type TypedValue 

type TypedValue struct {
	Type        Rep    `protobuf:"varint,1,opt,name=type,proto3,enum=Rep" json:"type,omitempty"`
	BoolValue   bool   `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
	NumberValue int64  `protobuf:"zigzag64,4,opt,name=number_value,json=numberValue,proto3" json:"number_value,omitempty"`
	// includes numeric types and date/time types.
	BytesValue           []byte        `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"`
	DoubleValue          float64       `protobuf:"fixed64,6,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"`
	Null                 bool          `protobuf:"varint,7,opt,name=null,proto3" json:"null,omitempty"`
	ArrayValue           []*TypedValue `protobuf:"bytes,8,rep,name=array_value,json=arrayValue,proto3" json:"array_value,omitempty"`
	ComponentType        Rep           `protobuf:"varint,9,opt,name=component_type,json=componentType,proto3,enum=Rep" json:"component_type,omitempty"`
	ImplicitlyNull       bool          `protobuf:"varint,10,opt,name=implicitly_null,json=implicitlyNull,proto3" json:"implicitly_null,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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 

func (m *TypedValue) GetBoolValue() bool

func (*TypedValue) GetBytesValue 

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

func (*TypedValue) GetComponentType 

func (m *TypedValue) GetComponentType() Rep

func (*TypedValue) GetDoubleValue 

func (m *TypedValue) GetDoubleValue() float64

func (*TypedValue) GetImplicitlyNull 

func (m *TypedValue) GetImplicitlyNull() bool

func (*TypedValue) GetNull 

func (m *TypedValue) GetNull() bool

func (*TypedValue) GetNumberValue 

func (m *TypedValue) GetNumberValue() int64

func (*TypedValue) GetStringValue 

func (m *TypedValue) GetStringValue() string

func (*TypedValue) GetType 

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

func (*TypedValue) XXX_DiscardUnknown 

func (m *TypedValue) XXX_DiscardUnknown()

func (*TypedValue) XXX_Marshal 

func (m *TypedValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TypedValue) XXX_Merge 

func (dst *TypedValue) XXX_Merge(src proto.Message)

func (*TypedValue) XXX_Size 

func (m *TypedValue) XXX_Size() int

func (*TypedValue) XXX_Unmarshal 

func (m *TypedValue) XXX_Unmarshal(b []byte) error

type UpdateBatch 

type UpdateBatch struct {
	ParameterValues      []*TypedValue `protobuf:"bytes,1,rep,name=parameter_values,json=parameterValues,proto3" json:"parameter_values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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

func (*UpdateBatch) XXX_DiscardUnknown 

func (m *UpdateBatch) XXX_DiscardUnknown()

func (*UpdateBatch) XXX_Marshal 

func (m *UpdateBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateBatch) XXX_Merge 

func (dst *UpdateBatch) XXX_Merge(src proto.Message)

func (*UpdateBatch) XXX_Size 

func (m *UpdateBatch) XXX_Size() int

func (*UpdateBatch) XXX_Unmarshal 

func (m *UpdateBatch) XXX_Unmarshal(b []byte) error

type WireMessage 

type WireMessage struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	WrappedMessage       []byte   `protobuf:"bytes,2,opt,name=wrapped_message,json=wrappedMessage,proto3" json:"wrapped_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message which encapsulates another message to support a single RPC endpoint

func (*WireMessage) Descriptor 

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

func (*WireMessage) GetName 

func (m *WireMessage) GetName() string

func (*WireMessage) GetWrappedMessage 

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

func (*WireMessage) XXX_DiscardUnknown 

func (m *WireMessage) XXX_DiscardUnknown()

func (*WireMessage) XXX_Marshal 

func (m *WireMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WireMessage) XXX_Merge 

func (dst *WireMessage) XXX_Merge(src proto.Message)

func (*WireMessage) XXX_Size 

func (m *WireMessage) XXX_Size() int

func (*WireMessage) XXX_Unmarshal 

func (m *WireMessage) XXX_Unmarshal(b []byte) error

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.