message

package
v5.3.0 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2023 License: Apache-2.0 Imports: 4 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

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",
	}
	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,
	}
)

Enum value maps for StatementType.

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",
	}
	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,
	}
)

Enum value maps for Rep.

View Source 
var (
	Severity_name = map[int32]string{
		0: "UNKNOWN_SEVERITY",
		1: "FATAL_SEVERITY",
		2: "ERROR_SEVERITY",
		3: "WARNING_SEVERITY",
	}
	Severity_value = map[string]int32{
		"UNKNOWN_SEVERITY": 0,
		"FATAL_SEVERITY":   1,
		"ERROR_SEVERITY":   2,
		"WARNING_SEVERITY": 3,
	}
)

Enum value maps for Severity.

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",
	}
	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,
	}
)

Enum value maps for MetaDataOperation.

View Source 
var (
	StateType_name = map[int32]string{
		0: "SQL",
		1: "METADATA",
	}
	StateType_value = map[string]int32{
		"SQL":      0,
		"METADATA": 1,
	}
)

Enum value maps for StateType.

View Source 
var (
	CursorFactory_Style_name = map[int32]string{
		0: "OBJECT",
		1: "RECORD",
		2: "RECORD_PROJECTION",
		3: "ARRAY",
		4: "LIST",
		5: "MAP",
	}
	CursorFactory_Style_value = map[string]int32{
		"OBJECT":            0,
		"RECORD":            1,
		"RECORD_PROJECTION": 2,
		"ARRAY":             3,
		"LIST":              4,
		"MAP":               5,
	}
)

Enum value maps for CursorFactory_Style.

View Source 
var (
	MetaDataOperationArgument_ArgumentType_name = map[int32]string{
		0: "STRING",
		1: "BOOL",
		2: "INT",
		3: "REPEATED_STRING",
		4: "REPEATED_INT",
		5: "NULL",
	}
	MetaDataOperationArgument_ArgumentType_value = map[string]int32{
		"STRING":          0,
		"BOOL":            1,
		"INT":             2,
		"REPEATED_STRING": 3,
		"REPEATED_INT":    4,
		"NULL":            5,
	}
)

Enum value maps for MetaDataOperationArgument_ArgumentType.

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_requests_proto protoreflect.FileDescriptor
View Source 
var File_responses_proto protoreflect.FileDescriptor

Functions

func ServerAddressFromMetadata 

func ServerAddressFromMetadata(message MetadataProvider) string

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"`
	// contains filtered or unexported fields
}

Metadata for a parameter

func (*AvaticaParameter) Descriptor deprecated 

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

Deprecated: Use AvaticaParameter.ProtoReflect.Descriptor instead.

func (*AvaticaParameter) GetClassName 

func (x *AvaticaParameter) GetClassName() string

func (*AvaticaParameter) GetName 

func (x *AvaticaParameter) GetName() string

func (*AvaticaParameter) GetParameterType 

func (x *AvaticaParameter) GetParameterType() uint32

func (*AvaticaParameter) GetPrecision 

func (x *AvaticaParameter) GetPrecision() uint32

func (*AvaticaParameter) GetScale 

func (x *AvaticaParameter) GetScale() uint32

func (*AvaticaParameter) GetSigned 

func (x *AvaticaParameter) GetSigned() bool

func (*AvaticaParameter) GetTypeName 

func (x *AvaticaParameter) GetTypeName() string

func (*AvaticaParameter) ProtoMessage 

func (*AvaticaParameter) ProtoMessage()

func (*AvaticaParameter) ProtoReflect added in v5.1.0 

func (x *AvaticaParameter) ProtoReflect() protoreflect.Message

func (*AvaticaParameter) Reset 

func (x *AvaticaParameter) Reset()

func (*AvaticaParameter) String 

func (x *AvaticaParameter) String() string

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"`     // Only present when name = STRUCT
	Component *AvaticaType      `protobuf:"bytes,5,opt,name=component,proto3" json:"component,omitempty"` // Only present when name = ARRAY
	// contains filtered or unexported fields
}

Base class for a column type

func (*AvaticaType) Descriptor deprecated 

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

Deprecated: Use AvaticaType.ProtoReflect.Descriptor instead.

func (*AvaticaType) GetColumns 

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

func (*AvaticaType) GetComponent 

func (x *AvaticaType) GetComponent() *AvaticaType

func (*AvaticaType) GetId 

func (x *AvaticaType) GetId() uint32

func (*AvaticaType) GetName 

func (x *AvaticaType) GetName() string

func (*AvaticaType) GetRep 

func (x *AvaticaType) GetRep() Rep

func (*AvaticaType) ProtoMessage 

func (*AvaticaType) ProtoMessage()

func (*AvaticaType) ProtoReflect added in v5.1.0 

func (x *AvaticaType) ProtoReflect() protoreflect.Message

func (*AvaticaType) Reset 

func (x *AvaticaType) Reset()

func (*AvaticaType) String 

func (x *AvaticaType) String() string

type CatalogsRequest 

type CatalogsRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Request for Meta#getCatalogs()

func (*CatalogsRequest) Descriptor deprecated 

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

Deprecated: Use CatalogsRequest.ProtoReflect.Descriptor instead.

func (*CatalogsRequest) GetConnectionId 

func (x *CatalogsRequest) GetConnectionId() string

func (*CatalogsRequest) ProtoMessage 

func (*CatalogsRequest) ProtoMessage()

func (*CatalogsRequest) ProtoReflect added in v5.1.0 

func (x *CatalogsRequest) ProtoReflect() protoreflect.Message

func (*CatalogsRequest) Reset 

func (x *CatalogsRequest) Reset()

func (*CatalogsRequest) String 

func (x *CatalogsRequest) String() string

type CloseConnectionRequest 

type CloseConnectionRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Request for Meta#closeConnection(Meta.ConnectionHandle)

func (*CloseConnectionRequest) Descriptor deprecated 

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

Deprecated: Use CloseConnectionRequest.ProtoReflect.Descriptor instead.

func (*CloseConnectionRequest) GetConnectionId 

func (x *CloseConnectionRequest) GetConnectionId() string

func (*CloseConnectionRequest) ProtoMessage 

func (*CloseConnectionRequest) ProtoMessage()

func (*CloseConnectionRequest) ProtoReflect added in v5.1.0 

func (x *CloseConnectionRequest) ProtoReflect() protoreflect.Message

func (*CloseConnectionRequest) Reset 

func (x *CloseConnectionRequest) Reset()

func (*CloseConnectionRequest) String 

func (x *CloseConnectionRequest) String() string

type CloseConnectionResponse 

type CloseConnectionResponse struct {
	Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Response to CloseConnectionRequest {

func (*CloseConnectionResponse) Descriptor deprecated 

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

Deprecated: Use CloseConnectionResponse.ProtoReflect.Descriptor instead.

func (*CloseConnectionResponse) GetMetadata 

func (x *CloseConnectionResponse) GetMetadata() *RpcMetadata

func (*CloseConnectionResponse) ProtoMessage 

func (*CloseConnectionResponse) ProtoMessage()

func (*CloseConnectionResponse) ProtoReflect added in v5.1.0 

func (x *CloseConnectionResponse) ProtoReflect() protoreflect.Message

func (*CloseConnectionResponse) Reset 

func (x *CloseConnectionResponse) Reset()

func (*CloseConnectionResponse) String 

func (x *CloseConnectionResponse) String() string

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"`
	// contains filtered or unexported fields
}

Request for Meta#closeStatement(Meta.StatementHandle)

func (*CloseStatementRequest) Descriptor deprecated 

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

Deprecated: Use CloseStatementRequest.ProtoReflect.Descriptor instead.

func (*CloseStatementRequest) GetConnectionId 

func (x *CloseStatementRequest) GetConnectionId() string

func (*CloseStatementRequest) GetStatementId 

func (x *CloseStatementRequest) GetStatementId() uint32

func (*CloseStatementRequest) ProtoMessage 

func (*CloseStatementRequest) ProtoMessage()

func (*CloseStatementRequest) ProtoReflect added in v5.1.0 

func (x *CloseStatementRequest) ProtoReflect() protoreflect.Message

func (*CloseStatementRequest) Reset 

func (x *CloseStatementRequest) Reset()

func (*CloseStatementRequest) String 

func (x *CloseStatementRequest) String() string

type CloseStatementResponse 

type CloseStatementResponse struct {
	Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Response to CloseStatementRequest

func (*CloseStatementResponse) Descriptor deprecated 

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

Deprecated: Use CloseStatementResponse.ProtoReflect.Descriptor instead.

func (*CloseStatementResponse) GetMetadata 

func (x *CloseStatementResponse) GetMetadata() *RpcMetadata

func (*CloseStatementResponse) ProtoMessage 

func (*CloseStatementResponse) ProtoMessage()

func (*CloseStatementResponse) ProtoReflect added in v5.1.0 

func (x *CloseStatementResponse) ProtoReflect() protoreflect.Message

func (*CloseStatementResponse) Reset 

func (x *CloseStatementResponse) Reset()

func (*CloseStatementResponse) String 

func (x *CloseStatementResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ColumnMetaData) Descriptor deprecated 

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

Deprecated: Use ColumnMetaData.ProtoReflect.Descriptor instead.

func (*ColumnMetaData) GetAutoIncrement 

func (x *ColumnMetaData) GetAutoIncrement() bool

func (*ColumnMetaData) GetCaseSensitive 

func (x *ColumnMetaData) GetCaseSensitive() bool

func (*ColumnMetaData) GetCatalogName 

func (x *ColumnMetaData) GetCatalogName() string

func (*ColumnMetaData) GetColumnClassName 

func (x *ColumnMetaData) GetColumnClassName() string

func (*ColumnMetaData) GetColumnName 

func (x *ColumnMetaData) GetColumnName() string

func (*ColumnMetaData) GetCurrency 

func (x *ColumnMetaData) GetCurrency() bool

func (*ColumnMetaData) GetDefinitelyWritable 

func (x *ColumnMetaData) GetDefinitelyWritable() bool

func (*ColumnMetaData) GetDisplaySize 

func (x *ColumnMetaData) GetDisplaySize() uint32

func (*ColumnMetaData) GetLabel 

func (x *ColumnMetaData) GetLabel() string

func (*ColumnMetaData) GetNullable 

func (x *ColumnMetaData) GetNullable() uint32

func (*ColumnMetaData) GetOrdinal 

func (x *ColumnMetaData) GetOrdinal() uint32

func (*ColumnMetaData) GetPrecision 

func (x *ColumnMetaData) GetPrecision() uint32

func (*ColumnMetaData) GetReadOnly 

func (x *ColumnMetaData) GetReadOnly() bool

func (*ColumnMetaData) GetScale 

func (x *ColumnMetaData) GetScale() uint32

func (*ColumnMetaData) GetSchemaName 

func (x *ColumnMetaData) GetSchemaName() string

func (*ColumnMetaData) GetSearchable 

func (x *ColumnMetaData) GetSearchable() bool

func (*ColumnMetaData) GetSigned 

func (x *ColumnMetaData) GetSigned() bool

func (*ColumnMetaData) GetTableName 

func (x *ColumnMetaData) GetTableName() string

func (*ColumnMetaData) GetType 

func (x *ColumnMetaData) GetType() *AvaticaType

func (*ColumnMetaData) GetWritable 

func (x *ColumnMetaData) GetWritable() bool

func (*ColumnMetaData) ProtoMessage 

func (*ColumnMetaData) ProtoMessage()

func (*ColumnMetaData) ProtoReflect added in v5.1.0 

func (x *ColumnMetaData) ProtoReflect() protoreflect.Message

func (*ColumnMetaData) Reset 

func (x *ColumnMetaData) Reset()

func (*ColumnMetaData) String 

func (x *ColumnMetaData) String() string

type ColumnValue 

type ColumnValue struct {
	Value         []*TypedValue `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` // deprecated, use array_value or scalar_value
	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"` // Is an array value set?
	ScalarValue   *TypedValue   `protobuf:"bytes,4,opt,name=scalar_value,json=scalarValue,proto3" json:"scalar_value,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ColumnValue) Descriptor deprecated 

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

Deprecated: Use ColumnValue.ProtoReflect.Descriptor instead.

func (*ColumnValue) GetArrayValue 

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

func (*ColumnValue) GetHasArrayValue 

func (x *ColumnValue) GetHasArrayValue() bool

func (*ColumnValue) GetScalarValue 

func (x *ColumnValue) GetScalarValue() *TypedValue

func (*ColumnValue) GetValue 

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

func (*ColumnValue) ProtoMessage 

func (*ColumnValue) ProtoMessage()

func (*ColumnValue) ProtoReflect added in v5.1.0 

func (x *ColumnValue) ProtoReflect() protoreflect.Message

func (*ColumnValue) Reset 

func (x *ColumnValue) Reset()

func (*ColumnValue) String 

func (x *ColumnValue) String() string

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"`
	HasCatalog           bool   `protobuf:"varint,6,opt,name=has_catalog,json=hasCatalog,proto3" json:"has_catalog,omitempty"`
	HasSchemaPattern     bool   `protobuf:"varint,7,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3" json:"has_schema_pattern,omitempty"`
	HasTableNamePattern  bool   `protobuf:"varint,8,opt,name=has_table_name_pattern,json=hasTableNamePattern,proto3" json:"has_table_name_pattern,omitempty"`
	HasColumnNamePattern bool   `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use ColumnsRequest.ProtoReflect.Descriptor instead.

func (*ColumnsRequest) GetCatalog 

func (x *ColumnsRequest) GetCatalog() string

func (*ColumnsRequest) GetColumnNamePattern 

func (x *ColumnsRequest) GetColumnNamePattern() string

func (*ColumnsRequest) GetConnectionId 

func (x *ColumnsRequest) GetConnectionId() string

func (*ColumnsRequest) GetHasCatalog added in v5.1.0 

func (x *ColumnsRequest) GetHasCatalog() bool

func (*ColumnsRequest) GetHasColumnNamePattern added in v5.1.0 

func (x *ColumnsRequest) GetHasColumnNamePattern() bool

func (*ColumnsRequest) GetHasSchemaPattern added in v5.1.0 

func (x *ColumnsRequest) GetHasSchemaPattern() bool

func (*ColumnsRequest) GetHasTableNamePattern added in v5.1.0 

func (x *ColumnsRequest) GetHasTableNamePattern() bool

func (*ColumnsRequest) GetSchemaPattern 

func (x *ColumnsRequest) GetSchemaPattern() string

func (*ColumnsRequest) GetTableNamePattern 

func (x *ColumnsRequest) GetTableNamePattern() string

func (*ColumnsRequest) ProtoMessage 

func (*ColumnsRequest) ProtoMessage()

func (*ColumnsRequest) ProtoReflect added in v5.1.0 

func (x *ColumnsRequest) ProtoReflect() protoreflect.Message

func (*ColumnsRequest) Reset 

func (x *ColumnsRequest) Reset()

func (*ColumnsRequest) String 

func (x *ColumnsRequest) String() string

type CommitRequest 

type CommitRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Request to invoke a commit on a Connection

func (*CommitRequest) Descriptor deprecated 

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

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) GetConnectionId 

func (x *CommitRequest) GetConnectionId() string

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect added in v5.1.0 

func (x *CommitRequest) ProtoReflect() protoreflect.Message

func (*CommitRequest) Reset 

func (x *CommitRequest) Reset()

func (*CommitRequest) String 

func (x *CommitRequest) String() string

type CommitResponse 

type CommitResponse struct {
	// contains filtered or unexported fields
}

Response to a commit request

func (*CommitResponse) Descriptor deprecated 

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

Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect added in v5.1.0 

func (x *CommitResponse) ProtoReflect() protoreflect.Message

func (*CommitResponse) Reset 

func (x *CommitResponse) Reset()

func (*CommitResponse) String 

func (x *CommitResponse) String() string

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"` // field is a Boolean, need to discern null and default value
	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"` // field is a Boolean, need to discern null and default value
	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"`
	// contains filtered or unexported fields
}

Details about a connection

func (*ConnectionProperties) Descriptor deprecated 

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

Deprecated: Use ConnectionProperties.ProtoReflect.Descriptor instead.

func (*ConnectionProperties) GetAutoCommit 

func (x *ConnectionProperties) GetAutoCommit() bool

func (*ConnectionProperties) GetCatalog 

func (x *ConnectionProperties) GetCatalog() string

func (*ConnectionProperties) GetHasAutoCommit 

func (x *ConnectionProperties) GetHasAutoCommit() bool

func (*ConnectionProperties) GetHasReadOnly 

func (x *ConnectionProperties) GetHasReadOnly() bool

func (*ConnectionProperties) GetIsDirty 

func (x *ConnectionProperties) GetIsDirty() bool

func (*ConnectionProperties) GetReadOnly 

func (x *ConnectionProperties) GetReadOnly() bool

func (*ConnectionProperties) GetSchema 

func (x *ConnectionProperties) GetSchema() string

func (*ConnectionProperties) GetTransactionIsolation 

func (x *ConnectionProperties) GetTransactionIsolation() uint32

func (*ConnectionProperties) ProtoMessage 

func (*ConnectionProperties) ProtoMessage()

func (*ConnectionProperties) ProtoReflect added in v5.1.0 

func (x *ConnectionProperties) ProtoReflect() protoreflect.Message

func (*ConnectionProperties) Reset 

func (x *ConnectionProperties) Reset()

func (*ConnectionProperties) String 

func (x *ConnectionProperties) String() string

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"`
	// contains filtered or unexported fields
}

func (*ConnectionSyncRequest) Descriptor deprecated 

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

Deprecated: Use ConnectionSyncRequest.ProtoReflect.Descriptor instead.

func (*ConnectionSyncRequest) GetConnProps 

func (x *ConnectionSyncRequest) GetConnProps() *ConnectionProperties

func (*ConnectionSyncRequest) GetConnectionId 

func (x *ConnectionSyncRequest) GetConnectionId() string

func (*ConnectionSyncRequest) ProtoMessage 

func (*ConnectionSyncRequest) ProtoMessage()

func (*ConnectionSyncRequest) ProtoReflect added in v5.1.0 

func (x *ConnectionSyncRequest) ProtoReflect() protoreflect.Message

func (*ConnectionSyncRequest) Reset 

func (x *ConnectionSyncRequest) Reset()

func (*ConnectionSyncRequest) String 

func (x *ConnectionSyncRequest) String() string

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"`
	// contains filtered or unexported fields
}

Response to ConnectionSyncRequest

func (*ConnectionSyncResponse) Descriptor deprecated 

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

Deprecated: Use ConnectionSyncResponse.ProtoReflect.Descriptor instead.

func (*ConnectionSyncResponse) GetConnProps 

func (x *ConnectionSyncResponse) GetConnProps() *ConnectionProperties

func (*ConnectionSyncResponse) GetMetadata 

func (x *ConnectionSyncResponse) GetMetadata() *RpcMetadata

func (*ConnectionSyncResponse) ProtoMessage 

func (*ConnectionSyncResponse) ProtoMessage()

func (*ConnectionSyncResponse) ProtoReflect added in v5.1.0 

func (x *ConnectionSyncResponse) ProtoReflect() protoreflect.Message

func (*ConnectionSyncResponse) Reset 

func (x *ConnectionSyncResponse) Reset()

func (*ConnectionSyncResponse) String 

func (x *ConnectionSyncResponse) String() string

type CreateStatementRequest 

type CreateStatementRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Request for Meta#createStatement(Meta.ConnectionHandle)

func (*CreateStatementRequest) Descriptor deprecated 

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

Deprecated: Use CreateStatementRequest.ProtoReflect.Descriptor instead.

func (*CreateStatementRequest) GetConnectionId 

func (x *CreateStatementRequest) GetConnectionId() string

func (*CreateStatementRequest) ProtoMessage 

func (*CreateStatementRequest) ProtoMessage()

func (*CreateStatementRequest) ProtoReflect added in v5.1.0 

func (x *CreateStatementRequest) ProtoReflect() protoreflect.Message

func (*CreateStatementRequest) Reset 

func (x *CreateStatementRequest) Reset()

func (*CreateStatementRequest) String 

func (x *CreateStatementRequest) String() string

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"`
	// contains filtered or unexported fields
}

Response to CreateStatementRequest

func (*CreateStatementResponse) Descriptor deprecated 

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

Deprecated: Use CreateStatementResponse.ProtoReflect.Descriptor instead.

func (*CreateStatementResponse) GetConnectionId 

func (x *CreateStatementResponse) GetConnectionId() string

func (*CreateStatementResponse) GetMetadata 

func (x *CreateStatementResponse) GetMetadata() *RpcMetadata

func (*CreateStatementResponse) GetStatementId 

func (x *CreateStatementResponse) GetStatementId() uint32

func (*CreateStatementResponse) ProtoMessage 

func (*CreateStatementResponse) ProtoMessage()

func (*CreateStatementResponse) ProtoReflect added in v5.1.0 

func (x *CreateStatementResponse) ProtoReflect() protoreflect.Message

func (*CreateStatementResponse) Reset 

func (x *CreateStatementResponse) Reset()

func (*CreateStatementResponse) String 

func (x *CreateStatementResponse) String() string

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"`
	// contains filtered or unexported fields
}

Information necessary to convert an Iterable into a Calcite Cursor

func (*CursorFactory) Descriptor deprecated 

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

Deprecated: Use CursorFactory.ProtoReflect.Descriptor instead.

func (*CursorFactory) GetClassName 

func (x *CursorFactory) GetClassName() string

func (*CursorFactory) GetFieldNames 

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

func (*CursorFactory) GetStyle 

func (x *CursorFactory) GetStyle() CursorFactory_Style

func (*CursorFactory) ProtoMessage 

func (*CursorFactory) ProtoMessage()

func (*CursorFactory) ProtoReflect added in v5.1.0 

func (x *CursorFactory) ProtoReflect() protoreflect.Message

func (*CursorFactory) Reset 

func (x *CursorFactory) Reset()

func (*CursorFactory) String 

func (x *CursorFactory) String() string

type CursorFactory_Style 

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

func (CursorFactory_Style) Descriptor added in v5.1.0 

func (CursorFactory_Style) Descriptor() protoreflect.EnumDescriptor

func (CursorFactory_Style) Enum added in v5.1.0 

func (x CursorFactory_Style) Enum() *CursorFactory_Style

func (CursorFactory_Style) EnumDescriptor deprecated 

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

Deprecated: Use CursorFactory_Style.Descriptor instead.

func (CursorFactory_Style) Number added in v5.1.0 

func (x CursorFactory_Style) Number() protoreflect.EnumNumber

func (CursorFactory_Style) String 

func (x CursorFactory_Style) String() string

func (CursorFactory_Style) Type added in v5.1.0 

func (CursorFactory_Style) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

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

func (*DatabaseProperty) Descriptor deprecated 

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

Deprecated: Use DatabaseProperty.ProtoReflect.Descriptor instead.

func (*DatabaseProperty) GetFunctions 

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

func (*DatabaseProperty) GetName 

func (x *DatabaseProperty) GetName() string

func (*DatabaseProperty) ProtoMessage 

func (*DatabaseProperty) ProtoMessage()

func (*DatabaseProperty) ProtoReflect added in v5.1.0 

func (x *DatabaseProperty) ProtoReflect() protoreflect.Message

func (*DatabaseProperty) Reset 

func (x *DatabaseProperty) Reset()

func (*DatabaseProperty) String 

func (x *DatabaseProperty) String() string

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"`
	// contains filtered or unexported fields
}

func (*DatabasePropertyElement) Descriptor deprecated 

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

Deprecated: Use DatabasePropertyElement.ProtoReflect.Descriptor instead.

func (*DatabasePropertyElement) GetKey 

func (x *DatabasePropertyElement) GetKey() *DatabaseProperty

func (*DatabasePropertyElement) GetMetadata 

func (x *DatabasePropertyElement) GetMetadata() *RpcMetadata

func (*DatabasePropertyElement) GetValue 

func (x *DatabasePropertyElement) GetValue() *TypedValue

func (*DatabasePropertyElement) ProtoMessage 

func (*DatabasePropertyElement) ProtoMessage()

func (*DatabasePropertyElement) ProtoReflect added in v5.1.0 

func (x *DatabasePropertyElement) ProtoReflect() protoreflect.Message

func (*DatabasePropertyElement) Reset 

func (x *DatabasePropertyElement) Reset()

func (*DatabasePropertyElement) String 

func (x *DatabasePropertyElement) String() string

type DatabasePropertyRequest 

type DatabasePropertyRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Request for Meta#getDatabaseProperties()

func (*DatabasePropertyRequest) Descriptor deprecated 

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

Deprecated: Use DatabasePropertyRequest.ProtoReflect.Descriptor instead.

func (*DatabasePropertyRequest) GetConnectionId 

func (x *DatabasePropertyRequest) GetConnectionId() string

func (*DatabasePropertyRequest) ProtoMessage 

func (*DatabasePropertyRequest) ProtoMessage()

func (*DatabasePropertyRequest) ProtoReflect added in v5.1.0 

func (x *DatabasePropertyRequest) ProtoReflect() protoreflect.Message

func (*DatabasePropertyRequest) Reset 

func (x *DatabasePropertyRequest) Reset()

func (*DatabasePropertyRequest) String 

func (x *DatabasePropertyRequest) String() string

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"`
	// contains filtered or unexported fields
}

Response for Meta#getDatabaseProperties()

func (*DatabasePropertyResponse) Descriptor deprecated 

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

Deprecated: Use DatabasePropertyResponse.ProtoReflect.Descriptor instead.

func (*DatabasePropertyResponse) GetMetadata 

func (x *DatabasePropertyResponse) GetMetadata() *RpcMetadata

func (*DatabasePropertyResponse) GetProps 

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

func (*DatabasePropertyResponse) ProtoMessage 

func (*DatabasePropertyResponse) ProtoMessage()

func (*DatabasePropertyResponse) ProtoReflect added in v5.1.0 

func (x *DatabasePropertyResponse) ProtoReflect() protoreflect.Message

func (*DatabasePropertyResponse) Reset 

func (x *DatabasePropertyResponse) Reset()

func (*DatabasePropertyResponse) String 

func (x *DatabasePropertyResponse) String() string

type ErrorResponse 

type ErrorResponse struct {
	Exceptions    []string     `protobuf:"bytes,1,rep,name=exceptions,proto3" json:"exceptions,omitempty"`                             // exception stacktraces, many for linked exceptions.
	HasExceptions bool         `protobuf:"varint,7,opt,name=has_exceptions,json=hasExceptions,proto3" json:"has_exceptions,omitempty"` // are there stacktraces contained?
	ErrorMessage  string       `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`     // human readable description
	Severity      Severity     `protobuf:"varint,3,opt,name=severity,proto3,enum=Severity" json:"severity,omitempty"`
	ErrorCode     uint32       `protobuf:"varint,4,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"` // numeric identifier for error
	SqlState      string       `protobuf:"bytes,5,opt,name=sql_state,json=sqlState,proto3" json:"sql_state,omitempty"`     // five-character standard-defined value
	Metadata      *RpcMetadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ErrorResponse) Descriptor deprecated 

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

Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead.

func (*ErrorResponse) GetErrorCode 

func (x *ErrorResponse) GetErrorCode() uint32

func (*ErrorResponse) GetErrorMessage 

func (x *ErrorResponse) GetErrorMessage() string

func (*ErrorResponse) GetExceptions 

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

func (*ErrorResponse) GetHasExceptions 

func (x *ErrorResponse) GetHasExceptions() bool

func (*ErrorResponse) GetMetadata 

func (x *ErrorResponse) GetMetadata() *RpcMetadata

func (*ErrorResponse) GetSeverity 

func (x *ErrorResponse) GetSeverity() Severity

func (*ErrorResponse) GetSqlState 

func (x *ErrorResponse) GetSqlState() string

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) ProtoReflect added in v5.1.0 

func (x *ErrorResponse) ProtoReflect() protoreflect.Message

func (*ErrorResponse) Reset 

func (x *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (x *ErrorResponse) String() string

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"` // A batch of updates is a list<list<typevalue>>
	// contains filtered or unexported fields
}

func (*ExecuteBatchRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteBatchRequest.ProtoReflect.Descriptor instead.

func (*ExecuteBatchRequest) GetConnectionId 

func (x *ExecuteBatchRequest) GetConnectionId() string

func (*ExecuteBatchRequest) GetStatementId 

func (x *ExecuteBatchRequest) GetStatementId() uint32

func (*ExecuteBatchRequest) GetUpdates 

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

func (*ExecuteBatchRequest) ProtoMessage 

func (*ExecuteBatchRequest) ProtoMessage()

func (*ExecuteBatchRequest) ProtoReflect added in v5.1.0 

func (x *ExecuteBatchRequest) ProtoReflect() protoreflect.Message

func (*ExecuteBatchRequest) Reset 

func (x *ExecuteBatchRequest) Reset()

func (*ExecuteBatchRequest) String 

func (x *ExecuteBatchRequest) String() string

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"` // Did the request fail because of no-cached statement
	Metadata         *RpcMetadata `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Response to a batch update request

func (*ExecuteBatchResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteBatchResponse.ProtoReflect.Descriptor instead.

func (*ExecuteBatchResponse) GetConnectionId 

func (x *ExecuteBatchResponse) GetConnectionId() string

func (*ExecuteBatchResponse) GetMetadata 

func (x *ExecuteBatchResponse) GetMetadata() *RpcMetadata

func (*ExecuteBatchResponse) GetMissingStatement 

func (x *ExecuteBatchResponse) GetMissingStatement() bool

func (*ExecuteBatchResponse) GetStatementId 

func (x *ExecuteBatchResponse) GetStatementId() uint32

func (*ExecuteBatchResponse) GetUpdateCounts 

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

func (*ExecuteBatchResponse) ProtoMessage 

func (*ExecuteBatchResponse) ProtoMessage()

func (*ExecuteBatchResponse) ProtoReflect added in v5.1.0 

func (x *ExecuteBatchResponse) ProtoReflect() protoreflect.Message

func (*ExecuteBatchResponse) Reset 

func (x *ExecuteBatchResponse) Reset()

func (*ExecuteBatchResponse) String 

func (x *ExecuteBatchResponse) String() string

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           `` // Deprecated, use the signed int instead.
	/* 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"` // The maximum number of rows to return in the first Frame
	// contains filtered or unexported fields
}

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

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetDeprecatedFirstFrameMaxSize 

func (x *ExecuteRequest) GetDeprecatedFirstFrameMaxSize() uint64

func (*ExecuteRequest) GetFirstFrameMaxSize 

func (x *ExecuteRequest) GetFirstFrameMaxSize() int32

func (*ExecuteRequest) GetHasParameterValues 

func (x *ExecuteRequest) GetHasParameterValues() bool

func (*ExecuteRequest) GetParameterValues 

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

func (*ExecuteRequest) GetStatementHandle 

func (x *ExecuteRequest) GetStatementHandle() *StatementHandle

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect added in v5.1.0 

func (x *ExecuteRequest) ProtoReflect() protoreflect.Message

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

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"` // Did the request fail because of no-cached statement
	Metadata         *RpcMetadata         `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Response to PrepareAndExecuteRequest

func (*ExecuteResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetMetadata 

func (x *ExecuteResponse) GetMetadata() *RpcMetadata

func (*ExecuteResponse) GetMissingStatement 

func (x *ExecuteResponse) GetMissingStatement() bool

func (*ExecuteResponse) GetResults 

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

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect added in v5.1.0 

func (x *ExecuteResponse) ProtoReflect() protoreflect.Message

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

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"` // Maximum number of rows to be returned in the frame. Negative means no limit. Deprecated!
	FrameMaxSize     int32  `protobuf:"varint,5,opt,name=frame_max_size,json=frameMaxSize,proto3" json:"frame_max_size,omitempty"`
	// contains filtered or unexported fields
}

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

func (*FetchRequest) Descriptor deprecated 

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

Deprecated: Use FetchRequest.ProtoReflect.Descriptor instead.

func (*FetchRequest) GetConnectionId 

func (x *FetchRequest) GetConnectionId() string

func (*FetchRequest) GetFetchMaxRowCount 

func (x *FetchRequest) GetFetchMaxRowCount() uint32

func (*FetchRequest) GetFrameMaxSize 

func (x *FetchRequest) GetFrameMaxSize() int32

func (*FetchRequest) GetOffset 

func (x *FetchRequest) GetOffset() uint64

func (*FetchRequest) GetStatementId 

func (x *FetchRequest) GetStatementId() uint32

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) ProtoReflect added in v5.1.0 

func (x *FetchRequest) ProtoReflect() protoreflect.Message

func (*FetchRequest) Reset 

func (x *FetchRequest) Reset()

func (*FetchRequest) String 

func (x *FetchRequest) String() string

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"` // Did the request fail because of no-cached statement
	MissingResults   bool         `protobuf:"varint,3,opt,name=missing_results,json=missingResults,proto3" json:"missing_results,omitempty"`       // Did the request fail because of a cached-statement w/o ResultSet
	Metadata         *RpcMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Response to FetchRequest

func (*FetchResponse) Descriptor deprecated 

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

Deprecated: Use FetchResponse.ProtoReflect.Descriptor instead.

func (*FetchResponse) GetFrame 

func (x *FetchResponse) GetFrame() *Frame

func (*FetchResponse) GetMetadata 

func (x *FetchResponse) GetMetadata() *RpcMetadata

func (*FetchResponse) GetMissingResults 

func (x *FetchResponse) GetMissingResults() bool

func (*FetchResponse) GetMissingStatement 

func (x *FetchResponse) GetMissingStatement() bool

func (*FetchResponse) ProtoMessage 

func (*FetchResponse) ProtoMessage()

func (*FetchResponse) ProtoReflect added in v5.1.0 

func (x *FetchResponse) ProtoReflect() protoreflect.Message

func (*FetchResponse) Reset 

func (x *FetchResponse) Reset()

func (*FetchResponse) String 

func (x *FetchResponse) String() string

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"`
	// contains filtered or unexported fields
}

A collection of rows

func (*Frame) Descriptor deprecated 

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

Deprecated: Use Frame.ProtoReflect.Descriptor instead.

func (*Frame) GetDone 

func (x *Frame) GetDone() bool

func (*Frame) GetOffset 

func (x *Frame) GetOffset() uint64

func (*Frame) GetRows 

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

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) ProtoReflect added in v5.1.0 

func (x *Frame) ProtoReflect() protoreflect.Message

func (*Frame) Reset 

func (x *Frame) Reset()

func (*Frame) String 

func (x *Frame) String() string

type MetaDataOperation 

type MetaDataOperation int32

Enumeration corresponding to DatabaseMetaData operations 

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

func (MetaDataOperation) Descriptor added in v5.1.0 

func (MetaDataOperation) Descriptor() protoreflect.EnumDescriptor

func (MetaDataOperation) Enum added in v5.1.0 

func (x MetaDataOperation) Enum() *MetaDataOperation

func (MetaDataOperation) EnumDescriptor deprecated 

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

Deprecated: Use MetaDataOperation.Descriptor instead.

func (MetaDataOperation) Number added in v5.1.0 

func (x MetaDataOperation) Number() protoreflect.EnumNumber

func (MetaDataOperation) String 

func (x MetaDataOperation) String() string

func (MetaDataOperation) Type added in v5.1.0 

func (MetaDataOperation) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

Represents the breadth of arguments to DatabaseMetaData functions

func (*MetaDataOperationArgument) Descriptor deprecated 

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

Deprecated: Use MetaDataOperationArgument.ProtoReflect.Descriptor instead.

func (*MetaDataOperationArgument) GetBoolValue 

func (x *MetaDataOperationArgument) GetBoolValue() bool

func (*MetaDataOperationArgument) GetIntArrayValues 

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

func (*MetaDataOperationArgument) GetIntValue 

func (x *MetaDataOperationArgument) GetIntValue() int32

func (*MetaDataOperationArgument) GetStringArrayValues 

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

func (*MetaDataOperationArgument) GetStringValue 

func (x *MetaDataOperationArgument) GetStringValue() string

func (*MetaDataOperationArgument) GetType 

func (x *MetaDataOperationArgument) GetType() MetaDataOperationArgument_ArgumentType

func (*MetaDataOperationArgument) ProtoMessage 

func (*MetaDataOperationArgument) ProtoMessage()

func (*MetaDataOperationArgument) ProtoReflect added in v5.1.0 

func (x *MetaDataOperationArgument) ProtoReflect() protoreflect.Message

func (*MetaDataOperationArgument) Reset 

func (x *MetaDataOperationArgument) Reset()

func (*MetaDataOperationArgument) String 

func (x *MetaDataOperationArgument) String() string

type MetaDataOperationArgument_ArgumentType 

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

func (MetaDataOperationArgument_ArgumentType) Descriptor added in v5.1.0 

func (MetaDataOperationArgument_ArgumentType) Descriptor() protoreflect.EnumDescriptor

func (MetaDataOperationArgument_ArgumentType) Enum added in v5.1.0 

func (x MetaDataOperationArgument_ArgumentType) Enum() *MetaDataOperationArgument_ArgumentType

func (MetaDataOperationArgument_ArgumentType) EnumDescriptor deprecated 

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

Deprecated: Use MetaDataOperationArgument_ArgumentType.Descriptor instead.

func (MetaDataOperationArgument_ArgumentType) Number added in v5.1.0 

func (x MetaDataOperationArgument_ArgumentType) Number() protoreflect.EnumNumber

func (MetaDataOperationArgument_ArgumentType) String 

func (x MetaDataOperationArgument_ArgumentType) String() string

func (MetaDataOperationArgument_ArgumentType) Type added in v5.1.0 

func (MetaDataOperationArgument_ArgumentType) Type() protoreflect.EnumType

type MetadataProvider 

type MetadataProvider interface {
	GetMetadata() *RpcMetadata
}

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 */
	// contains filtered or unexported fields
}

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

func (*OpenConnectionRequest) Descriptor deprecated 

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

Deprecated: Use OpenConnectionRequest.ProtoReflect.Descriptor instead.

func (*OpenConnectionRequest) GetConnectionId 

func (x *OpenConnectionRequest) GetConnectionId() string

func (*OpenConnectionRequest) GetInfo 

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

func (*OpenConnectionRequest) ProtoMessage 

func (*OpenConnectionRequest) ProtoMessage()

func (*OpenConnectionRequest) ProtoReflect added in v5.1.0 

func (x *OpenConnectionRequest) ProtoReflect() protoreflect.Message

func (*OpenConnectionRequest) Reset 

func (x *OpenConnectionRequest) Reset()

func (*OpenConnectionRequest) String 

func (x *OpenConnectionRequest) String() string

type OpenConnectionResponse 

type OpenConnectionResponse struct {
	Metadata *RpcMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Response to OpenConnectionRequest {

func (*OpenConnectionResponse) Descriptor deprecated 

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

Deprecated: Use OpenConnectionResponse.ProtoReflect.Descriptor instead.

func (*OpenConnectionResponse) GetMetadata 

func (x *OpenConnectionResponse) GetMetadata() *RpcMetadata

func (*OpenConnectionResponse) ProtoMessage 

func (*OpenConnectionResponse) ProtoMessage()

func (*OpenConnectionResponse) ProtoReflect added in v5.1.0 

func (x *OpenConnectionResponse) ProtoReflect() protoreflect.Message

func (*OpenConnectionResponse) Reset 

func (x *OpenConnectionResponse) Reset()

func (*OpenConnectionResponse) String 

func (x *OpenConnectionResponse) String() string

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"`
	// contains filtered or unexported fields
}

Request to prepare and execute a collection of sql statements.

func (*PrepareAndExecuteBatchRequest) Descriptor deprecated 

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

Deprecated: Use PrepareAndExecuteBatchRequest.ProtoReflect.Descriptor instead.

func (*PrepareAndExecuteBatchRequest) GetConnectionId 

func (x *PrepareAndExecuteBatchRequest) GetConnectionId() string

func (*PrepareAndExecuteBatchRequest) GetSqlCommands 

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

func (*PrepareAndExecuteBatchRequest) GetStatementId 

func (x *PrepareAndExecuteBatchRequest) GetStatementId() uint32

func (*PrepareAndExecuteBatchRequest) ProtoMessage 

func (*PrepareAndExecuteBatchRequest) ProtoMessage()

func (*PrepareAndExecuteBatchRequest) ProtoReflect added in v5.1.0 

func (x *PrepareAndExecuteBatchRequest) ProtoReflect() protoreflect.Message

func (*PrepareAndExecuteBatchRequest) Reset 

func (x *PrepareAndExecuteBatchRequest) Reset()

func (*PrepareAndExecuteBatchRequest) String 

func (x *PrepareAndExecuteBatchRequest) String() string

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"` // Deprecated
	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"`                  // The maximum number of rows that will be allowed for this query
	FirstFrameMaxSize int32  `protobuf:"varint,6,opt,name=first_frame_max_size,json=firstFrameMaxSize,proto3" json:"first_frame_max_size,omitempty"` // The maximum number of rows that will be returned in the
	// contains filtered or unexported fields
}

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

func (*PrepareAndExecuteRequest) Descriptor deprecated 

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

Deprecated: Use PrepareAndExecuteRequest.ProtoReflect.Descriptor instead.

func (*PrepareAndExecuteRequest) GetConnectionId 

func (x *PrepareAndExecuteRequest) GetConnectionId() string

func (*PrepareAndExecuteRequest) GetFirstFrameMaxSize 

func (x *PrepareAndExecuteRequest) GetFirstFrameMaxSize() int32

func (*PrepareAndExecuteRequest) GetMaxRowCount 

func (x *PrepareAndExecuteRequest) GetMaxRowCount() uint64

func (*PrepareAndExecuteRequest) GetMaxRowsTotal 

func (x *PrepareAndExecuteRequest) GetMaxRowsTotal() int64

func (*PrepareAndExecuteRequest) GetSql 

func (x *PrepareAndExecuteRequest) GetSql() string

func (*PrepareAndExecuteRequest) GetStatementId 

func (x *PrepareAndExecuteRequest) GetStatementId() uint32

func (*PrepareAndExecuteRequest) ProtoMessage 

func (*PrepareAndExecuteRequest) ProtoMessage()

func (*PrepareAndExecuteRequest) ProtoReflect added in v5.1.0 

func (x *PrepareAndExecuteRequest) ProtoReflect() protoreflect.Message

func (*PrepareAndExecuteRequest) Reset 

func (x *PrepareAndExecuteRequest) Reset()

func (*PrepareAndExecuteRequest) String 

func (x *PrepareAndExecuteRequest) String() string

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"`    // Deprecated
	MaxRowsTotal int64  `protobuf:"varint,4,opt,name=max_rows_total,json=maxRowsTotal,proto3" json:"max_rows_total,omitempty"` // The maximum number of rows that will be allowed for this query
	// contains filtered or unexported fields
}

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

func (*PrepareRequest) Descriptor deprecated 

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

Deprecated: Use PrepareRequest.ProtoReflect.Descriptor instead.

func (*PrepareRequest) GetConnectionId 

func (x *PrepareRequest) GetConnectionId() string

func (*PrepareRequest) GetMaxRowCount 

func (x *PrepareRequest) GetMaxRowCount() uint64

func (*PrepareRequest) GetMaxRowsTotal 

func (x *PrepareRequest) GetMaxRowsTotal() int64

func (*PrepareRequest) GetSql 

func (x *PrepareRequest) GetSql() string

func (*PrepareRequest) ProtoMessage 

func (*PrepareRequest) ProtoMessage()

func (*PrepareRequest) ProtoReflect added in v5.1.0 

func (x *PrepareRequest) ProtoReflect() protoreflect.Message

func (*PrepareRequest) Reset 

func (x *PrepareRequest) Reset()

func (*PrepareRequest) String 

func (x *PrepareRequest) String() string

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"`
	// contains filtered or unexported fields
}

Response to PrepareRequest

func (*PrepareResponse) Descriptor deprecated 

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

Deprecated: Use PrepareResponse.ProtoReflect.Descriptor instead.

func (*PrepareResponse) GetMetadata 

func (x *PrepareResponse) GetMetadata() *RpcMetadata

func (*PrepareResponse) GetStatement 

func (x *PrepareResponse) GetStatement() *StatementHandle

func (*PrepareResponse) ProtoMessage 

func (*PrepareResponse) ProtoMessage()

func (*PrepareResponse) ProtoReflect added in v5.1.0 

func (x *PrepareResponse) ProtoReflect() protoreflect.Message

func (*PrepareResponse) Reset 

func (x *PrepareResponse) Reset()

func (*PrepareResponse) String 

func (x *PrepareResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*QueryState) Descriptor deprecated 

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

Deprecated: Use QueryState.ProtoReflect.Descriptor instead.

func (*QueryState) GetArgs 

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

func (*QueryState) GetHasArgs 

func (x *QueryState) GetHasArgs() bool

func (*QueryState) GetHasOp 

func (x *QueryState) GetHasOp() bool

func (*QueryState) GetHasSql 

func (x *QueryState) GetHasSql() bool

func (*QueryState) GetOp 

func (x *QueryState) GetOp() MetaDataOperation

func (*QueryState) GetSql 

func (x *QueryState) GetSql() string

func (*QueryState) GetType 

func (x *QueryState) GetType() StateType

func (*QueryState) ProtoMessage 

func (*QueryState) ProtoMessage()

func (*QueryState) ProtoReflect added in v5.1.0 

func (x *QueryState) ProtoReflect() protoreflect.Message

func (*QueryState) Reset 

func (x *QueryState) Reset()

func (*QueryState) String 

func (x *QueryState) String() string

type Rep 

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

func (Rep) Descriptor added in v5.1.0 

func (Rep) Descriptor() protoreflect.EnumDescriptor

func (Rep) Enum added in v5.1.0 

func (x Rep) Enum() *Rep

func (Rep) EnumDescriptor deprecated 

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

Deprecated: Use Rep.Descriptor instead.

func (Rep) Number added in v5.1.0 

func (x Rep) Number() protoreflect.EnumNumber

func (Rep) String 

func (x Rep) String() string

func (Rep) Type added in v5.1.0 

func (Rep) Type() protoreflect.EnumType

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"` // -1 for normal result sets, else this response contains a dummy result set
	// with no signature nor other data.
	Metadata *RpcMetadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Response that contains a result set.

func (*ResultSetResponse) Descriptor deprecated 

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

Deprecated: Use ResultSetResponse.ProtoReflect.Descriptor instead.

func (*ResultSetResponse) GetConnectionId 

func (x *ResultSetResponse) GetConnectionId() string

func (*ResultSetResponse) GetFirstFrame 

func (x *ResultSetResponse) GetFirstFrame() *Frame

func (*ResultSetResponse) GetMetadata 

func (x *ResultSetResponse) GetMetadata() *RpcMetadata

func (*ResultSetResponse) GetOwnStatement 

func (x *ResultSetResponse) GetOwnStatement() bool

func (*ResultSetResponse) GetSignature 

func (x *ResultSetResponse) GetSignature() *Signature

func (*ResultSetResponse) GetStatementId 

func (x *ResultSetResponse) GetStatementId() uint32

func (*ResultSetResponse) GetUpdateCount 

func (x *ResultSetResponse) GetUpdateCount() uint64

func (*ResultSetResponse) ProtoMessage 

func (*ResultSetResponse) ProtoMessage()

func (*ResultSetResponse) ProtoReflect added in v5.1.0 

func (x *ResultSetResponse) ProtoReflect() protoreflect.Message

func (*ResultSetResponse) Reset 

func (x *ResultSetResponse) Reset()

func (*ResultSetResponse) String 

func (x *ResultSetResponse) String() string

type RollbackRequest 

type RollbackRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Request to invoke rollback on a Connection

func (*RollbackRequest) Descriptor deprecated 

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

Deprecated: Use RollbackRequest.ProtoReflect.Descriptor instead.

func (*RollbackRequest) GetConnectionId 

func (x *RollbackRequest) GetConnectionId() string

func (*RollbackRequest) ProtoMessage 

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) ProtoReflect added in v5.1.0 

func (x *RollbackRequest) ProtoReflect() protoreflect.Message

func (*RollbackRequest) Reset 

func (x *RollbackRequest) Reset()

func (*RollbackRequest) String 

func (x *RollbackRequest) String() string

type RollbackResponse 

type RollbackResponse struct {
	// contains filtered or unexported fields
}

Response to a rollback request

func (*RollbackResponse) Descriptor deprecated 

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

Deprecated: Use RollbackResponse.ProtoReflect.Descriptor instead.

func (*RollbackResponse) ProtoMessage 

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) ProtoReflect added in v5.1.0 

func (x *RollbackResponse) ProtoReflect() protoreflect.Message

func (*RollbackResponse) Reset 

func (x *RollbackResponse) Reset()

func (*RollbackResponse) String 

func (x *RollbackResponse) String() string

type Row 

type Row struct {
	Value []*ColumnValue `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A row is a collection of values

func (*Row) Descriptor deprecated 

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetValue 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect added in v5.1.0 

func (x *Row) ProtoReflect() protoreflect.Message

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) String 

func (x *Row) String() string

type RpcMetadata 

type RpcMetadata struct {
	ServerAddress string `protobuf:"bytes,1,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"` // The host:port of the server
	// contains filtered or unexported fields
}

Generic metadata for the server to return with each response.

func (*RpcMetadata) Descriptor deprecated 

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

Deprecated: Use RpcMetadata.ProtoReflect.Descriptor instead.

func (*RpcMetadata) GetServerAddress 

func (x *RpcMetadata) GetServerAddress() string

func (*RpcMetadata) ProtoMessage 

func (*RpcMetadata) ProtoMessage()

func (*RpcMetadata) ProtoReflect added in v5.1.0 

func (x *RpcMetadata) ProtoReflect() protoreflect.Message

func (*RpcMetadata) Reset 

func (x *RpcMetadata) Reset()

func (*RpcMetadata) String 

func (x *RpcMetadata) String() string

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"`
	HasCatalog       bool   `protobuf:"varint,4,opt,name=has_catalog,json=hasCatalog,proto3" json:"has_catalog,omitempty"`
	HasSchemaPattern bool   `protobuf:"varint,5,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3" json:"has_schema_pattern,omitempty"`
	// contains filtered or unexported fields
}

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

func (*SchemasRequest) Descriptor deprecated 

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

Deprecated: Use SchemasRequest.ProtoReflect.Descriptor instead.

func (*SchemasRequest) GetCatalog 

func (x *SchemasRequest) GetCatalog() string

func (*SchemasRequest) GetConnectionId 

func (x *SchemasRequest) GetConnectionId() string

func (*SchemasRequest) GetHasCatalog added in v5.1.0 

func (x *SchemasRequest) GetHasCatalog() bool

func (*SchemasRequest) GetHasSchemaPattern added in v5.1.0 

func (x *SchemasRequest) GetHasSchemaPattern() bool

func (*SchemasRequest) GetSchemaPattern 

func (x *SchemasRequest) GetSchemaPattern() string

func (*SchemasRequest) ProtoMessage 

func (*SchemasRequest) ProtoMessage()

func (*SchemasRequest) ProtoReflect added in v5.1.0 

func (x *SchemasRequest) ProtoReflect() protoreflect.Message

func (*SchemasRequest) Reset 

func (x *SchemasRequest) Reset()

func (*SchemasRequest) String 

func (x *SchemasRequest) String() string

type Severity 

type Severity int32

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

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

func (Severity) Descriptor added in v5.1.0 

func (Severity) Descriptor() protoreflect.EnumDescriptor

func (Severity) Enum added in v5.1.0 

func (x Severity) Enum() *Severity

func (Severity) EnumDescriptor deprecated 

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

Deprecated: Use Severity.Descriptor instead.

func (Severity) Number added in v5.1.0 

func (x Severity) Number() protoreflect.EnumNumber

func (Severity) String 

func (x Severity) String() string

func (Severity) Type added in v5.1.0 

func (Severity) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

Results of preparing a statement

func (*Signature) Descriptor deprecated 

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

Deprecated: Use Signature.ProtoReflect.Descriptor instead.

func (*Signature) GetColumns 

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

func (*Signature) GetCursorFactory 

func (x *Signature) GetCursorFactory() *CursorFactory

func (*Signature) GetParameters 

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

func (*Signature) GetSql 

func (x *Signature) GetSql() string

func (*Signature) GetStatementType 

func (x *Signature) GetStatementType() StatementType

func (*Signature) ProtoMessage 

func (*Signature) ProtoMessage()

func (*Signature) ProtoReflect added in v5.1.0 

func (x *Signature) ProtoReflect() protoreflect.Message

func (*Signature) Reset 

func (x *Signature) Reset()

func (*Signature) String 

func (x *Signature) String() string

type StateType 

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

func (StateType) Descriptor added in v5.1.0 

func (StateType) Descriptor() protoreflect.EnumDescriptor

func (StateType) Enum added in v5.1.0 

func (x StateType) Enum() *StateType

func (StateType) EnumDescriptor deprecated 

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

Deprecated: Use StateType.Descriptor instead.

func (StateType) Number added in v5.1.0 

func (x StateType) Number() protoreflect.EnumNumber

func (StateType) String 

func (x StateType) String() string

func (StateType) Type added in v5.1.0 

func (StateType) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

Statement handle

func (*StatementHandle) Descriptor deprecated 

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

Deprecated: Use StatementHandle.ProtoReflect.Descriptor instead.

func (*StatementHandle) GetConnectionId 

func (x *StatementHandle) GetConnectionId() string

func (*StatementHandle) GetId 

func (x *StatementHandle) GetId() uint32

func (*StatementHandle) GetSignature 

func (x *StatementHandle) GetSignature() *Signature

func (*StatementHandle) ProtoMessage 

func (*StatementHandle) ProtoMessage()

func (*StatementHandle) ProtoReflect added in v5.1.0 

func (x *StatementHandle) ProtoReflect() protoreflect.Message

func (*StatementHandle) Reset 

func (x *StatementHandle) Reset()

func (*StatementHandle) String 

func (x *StatementHandle) String() string

type StatementType 

type StatementType int32

Has to be consistent with Meta.StatementType 

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

func (StatementType) Descriptor added in v5.1.0 

func (StatementType) Descriptor() protoreflect.EnumDescriptor

func (StatementType) Enum added in v5.1.0 

func (x StatementType) Enum() *StatementType

func (StatementType) EnumDescriptor deprecated 

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

Deprecated: Use StatementType.Descriptor instead.

func (StatementType) Number added in v5.1.0 

func (x StatementType) Number() protoreflect.EnumNumber

func (StatementType) String 

func (x StatementType) String() string

func (StatementType) Type added in v5.1.0 

func (StatementType) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*SyncResultsRequest) Descriptor deprecated 

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

Deprecated: Use SyncResultsRequest.ProtoReflect.Descriptor instead.

func (*SyncResultsRequest) GetConnectionId 

func (x *SyncResultsRequest) GetConnectionId() string

func (*SyncResultsRequest) GetOffset 

func (x *SyncResultsRequest) GetOffset() uint64

func (*SyncResultsRequest) GetState 

func (x *SyncResultsRequest) GetState() *QueryState

func (*SyncResultsRequest) GetStatementId 

func (x *SyncResultsRequest) GetStatementId() uint32

func (*SyncResultsRequest) ProtoMessage 

func (*SyncResultsRequest) ProtoMessage()

func (*SyncResultsRequest) ProtoReflect added in v5.1.0 

func (x *SyncResultsRequest) ProtoReflect() protoreflect.Message

func (*SyncResultsRequest) Reset 

func (x *SyncResultsRequest) Reset()

func (*SyncResultsRequest) String 

func (x *SyncResultsRequest) String() string

type SyncResultsResponse 

type SyncResultsResponse struct {
	MissingStatement bool         `protobuf:"varint,1,opt,name=missing_statement,json=missingStatement,proto3" json:"missing_statement,omitempty"` // Server doesn't have the statement with the ID from the request
	MoreResults      bool         `protobuf:"varint,2,opt,name=more_results,json=moreResults,proto3" json:"more_results,omitempty"`                // Should the client fetch() to get more results
	Metadata         *RpcMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncResultsResponse) Descriptor deprecated 

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

Deprecated: Use SyncResultsResponse.ProtoReflect.Descriptor instead.

func (*SyncResultsResponse) GetMetadata 

func (x *SyncResultsResponse) GetMetadata() *RpcMetadata

func (*SyncResultsResponse) GetMissingStatement 

func (x *SyncResultsResponse) GetMissingStatement() bool

func (*SyncResultsResponse) GetMoreResults 

func (x *SyncResultsResponse) GetMoreResults() bool

func (*SyncResultsResponse) ProtoMessage 

func (*SyncResultsResponse) ProtoMessage()

func (*SyncResultsResponse) ProtoReflect added in v5.1.0 

func (x *SyncResultsResponse) ProtoReflect() protoreflect.Message

func (*SyncResultsResponse) Reset 

func (x *SyncResultsResponse) Reset()

func (*SyncResultsResponse) String 

func (x *SyncResultsResponse) String() string

type TableTypesRequest 

type TableTypesRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Request for Meta#getTableTypes()

func (*TableTypesRequest) Descriptor deprecated 

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

Deprecated: Use TableTypesRequest.ProtoReflect.Descriptor instead.

func (*TableTypesRequest) GetConnectionId 

func (x *TableTypesRequest) GetConnectionId() string

func (*TableTypesRequest) ProtoMessage 

func (*TableTypesRequest) ProtoMessage()

func (*TableTypesRequest) ProtoReflect added in v5.1.0 

func (x *TableTypesRequest) ProtoReflect() protoreflect.Message

func (*TableTypesRequest) Reset 

func (x *TableTypesRequest) Reset()

func (*TableTypesRequest) String 

func (x *TableTypesRequest) String() string

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"` // Having an empty type_list is distinct from a null type_list
	ConnectionId        string   `protobuf:"bytes,7,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	HasCatalog          bool     `protobuf:"varint,8,opt,name=has_catalog,json=hasCatalog,proto3" json:"has_catalog,omitempty"`
	HasSchemaPattern    bool     `protobuf:"varint,9,opt,name=has_schema_pattern,json=hasSchemaPattern,proto3" json:"has_schema_pattern,omitempty"`
	HasTableNamePattern bool     `protobuf:"varint,10,opt,name=has_table_name_pattern,json=hasTableNamePattern,proto3" json:"has_table_name_pattern,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use TablesRequest.ProtoReflect.Descriptor instead.

func (*TablesRequest) GetCatalog 

func (x *TablesRequest) GetCatalog() string

func (*TablesRequest) GetConnectionId 

func (x *TablesRequest) GetConnectionId() string

func (*TablesRequest) GetHasCatalog added in v5.1.0 

func (x *TablesRequest) GetHasCatalog() bool

func (*TablesRequest) GetHasSchemaPattern added in v5.1.0 

func (x *TablesRequest) GetHasSchemaPattern() bool

func (*TablesRequest) GetHasTableNamePattern added in v5.1.0 

func (x *TablesRequest) GetHasTableNamePattern() bool

func (*TablesRequest) GetHasTypeList 

func (x *TablesRequest) GetHasTypeList() bool

func (*TablesRequest) GetSchemaPattern 

func (x *TablesRequest) GetSchemaPattern() string

func (*TablesRequest) GetTableNamePattern 

func (x *TablesRequest) GetTableNamePattern() string

func (*TablesRequest) GetTypeList 

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

func (*TablesRequest) ProtoMessage 

func (*TablesRequest) ProtoMessage()

func (*TablesRequest) ProtoReflect added in v5.1.0 

func (x *TablesRequest) ProtoReflect() protoreflect.Message

func (*TablesRequest) Reset 

func (x *TablesRequest) Reset()

func (*TablesRequest) String 

func (x *TablesRequest) String() string

type TypeInfoRequest 

type TypeInfoRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

Request for Meta#getTypeInfo()

func (*TypeInfoRequest) Descriptor deprecated 

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

Deprecated: Use TypeInfoRequest.ProtoReflect.Descriptor instead.

func (*TypeInfoRequest) GetConnectionId 

func (x *TypeInfoRequest) GetConnectionId() string

func (*TypeInfoRequest) ProtoMessage 

func (*TypeInfoRequest) ProtoMessage()

func (*TypeInfoRequest) ProtoReflect added in v5.1.0 

func (x *TypeInfoRequest) ProtoReflect() protoreflect.Message

func (*TypeInfoRequest) Reset 

func (x *TypeInfoRequest) Reset()

func (*TypeInfoRequest) String 

func (x *TypeInfoRequest) String() string

type TypedValue 

type TypedValue struct {
	Type        Rep    `protobuf:"varint,1,opt,name=type,proto3,enum=Rep" json:"type,omitempty"`                           // The actual type that was serialized in the general attribute below
	BoolValue   bool   `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3" json:"bool_value,omitempty"`         // boolean
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`    // char/varchar
	NumberValue int64  `protobuf:"zigzag64,4,opt,name=number_value,json=numberValue,proto3" json:"number_value,omitempty"` // var-len encoding lets us shove anything from byte to long
	// includes numeric types and date/time types.
	BytesValue     []byte        `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue,proto3" json:"bytes_value,omitempty"`                    // binary/varbinary
	DoubleValue    float64       `protobuf:"fixed64,6,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"`               // big numbers
	Null           bool          `protobuf:"varint,7,opt,name=null,proto3" json:"null,omitempty"`                                                 // a null object
	ArrayValue     []*TypedValue `protobuf:"bytes,8,rep,name=array_value,json=arrayValue,proto3" json:"array_value,omitempty"`                    // The Array
	ComponentType  Rep           `protobuf:"varint,9,opt,name=component_type,json=componentType,proto3,enum=Rep" json:"component_type,omitempty"` // If an Array, the representation for the array values
	ImplicitlyNull bool          `protobuf:"varint,10,opt,name=implicitly_null,json=implicitlyNull,proto3" json:"implicitly_null,omitempty"`      // Differentiate between explicitly null (user-set) and implicitly null
	// contains filtered or unexported fields
}

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

func (*TypedValue) Descriptor deprecated 

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

Deprecated: Use TypedValue.ProtoReflect.Descriptor instead.

func (*TypedValue) GetArrayValue 

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

func (*TypedValue) GetBoolValue 

func (x *TypedValue) GetBoolValue() bool

func (*TypedValue) GetBytesValue 

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

func (*TypedValue) GetComponentType 

func (x *TypedValue) GetComponentType() Rep

func (*TypedValue) GetDoubleValue 

func (x *TypedValue) GetDoubleValue() float64

func (*TypedValue) GetImplicitlyNull 

func (x *TypedValue) GetImplicitlyNull() bool

func (*TypedValue) GetNull 

func (x *TypedValue) GetNull() bool

func (*TypedValue) GetNumberValue 

func (x *TypedValue) GetNumberValue() int64

func (*TypedValue) GetStringValue 

func (x *TypedValue) GetStringValue() string

func (*TypedValue) GetType 

func (x *TypedValue) GetType() Rep

func (*TypedValue) ProtoMessage 

func (*TypedValue) ProtoMessage()

func (*TypedValue) ProtoReflect added in v5.1.0 

func (x *TypedValue) ProtoReflect() protoreflect.Message

func (*TypedValue) Reset 

func (x *TypedValue) Reset()

func (*TypedValue) String 

func (x *TypedValue) String() string

type UpdateBatch 

type UpdateBatch struct {
	ParameterValues []*TypedValue `protobuf:"bytes,1,rep,name=parameter_values,json=parameterValues,proto3" json:"parameter_values,omitempty"`
	// contains filtered or unexported fields
}

Each command is a list of TypedValues

func (*UpdateBatch) Descriptor deprecated 

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

Deprecated: Use UpdateBatch.ProtoReflect.Descriptor instead.

func (*UpdateBatch) GetParameterValues 

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

func (*UpdateBatch) ProtoMessage 

func (*UpdateBatch) ProtoMessage()

func (*UpdateBatch) ProtoReflect added in v5.1.0 

func (x *UpdateBatch) ProtoReflect() protoreflect.Message

func (*UpdateBatch) Reset 

func (x *UpdateBatch) Reset()

func (*UpdateBatch) String 

func (x *UpdateBatch) String() string

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"`
	// contains filtered or unexported fields
}

Message which encapsulates another message to support a single RPC endpoint

func (*WireMessage) Descriptor deprecated 

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

Deprecated: Use WireMessage.ProtoReflect.Descriptor instead.

func (*WireMessage) GetName 

func (x *WireMessage) GetName() string

func (*WireMessage) GetWrappedMessage 

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

func (*WireMessage) ProtoMessage 

func (*WireMessage) ProtoMessage()

func (*WireMessage) ProtoReflect added in v5.1.0 

func (x *WireMessage) ProtoReflect() protoreflect.Message

func (*WireMessage) Reset 

func (x *WireMessage) Reset()

func (*WireMessage) String 

func (x *WireMessage) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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