message

package
v5.4.0 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2025 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 {
	// contains filtered or unexported fields
}

Metadata for a parameter

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) SetClassName added in v5.4.0 

func (x *AvaticaParameter) SetClassName(v string)

func (*AvaticaParameter) SetName added in v5.4.0 

func (x *AvaticaParameter) SetName(v string)

func (*AvaticaParameter) SetParameterType added in v5.4.0 

func (x *AvaticaParameter) SetParameterType(v uint32)

func (*AvaticaParameter) SetPrecision added in v5.4.0 

func (x *AvaticaParameter) SetPrecision(v uint32)

func (*AvaticaParameter) SetScale added in v5.4.0 

func (x *AvaticaParameter) SetScale(v uint32)

func (*AvaticaParameter) SetSigned added in v5.4.0 

func (x *AvaticaParameter) SetSigned(v bool)

func (*AvaticaParameter) SetTypeName added in v5.4.0 

func (x *AvaticaParameter) SetTypeName(v string)

func (*AvaticaParameter) String 

func (x *AvaticaParameter) String() string

type AvaticaParameter_builder added in v5.4.0 

type AvaticaParameter_builder struct {
	Signed        bool
	Precision     uint32
	Scale         uint32
	ParameterType uint32
	TypeName      string
	ClassName     string
	Name          string
	// contains filtered or unexported fields
}

func (AvaticaParameter_builder) Build added in v5.4.0 

func (b0 AvaticaParameter_builder) Build() *AvaticaParameter

type AvaticaType 

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

Base class for a column type

func (*AvaticaType) ClearComponent added in v5.4.0 

func (x *AvaticaType) ClearComponent()

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) HasComponent added in v5.4.0 

func (x *AvaticaType) HasComponent() bool

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) SetColumns added in v5.4.0 

func (x *AvaticaType) SetColumns(v []*ColumnMetaData)

func (*AvaticaType) SetComponent added in v5.4.0 

func (x *AvaticaType) SetComponent(v *AvaticaType)

func (*AvaticaType) SetId added in v5.4.0 

func (x *AvaticaType) SetId(v uint32)

func (*AvaticaType) SetName added in v5.4.0 

func (x *AvaticaType) SetName(v string)

func (*AvaticaType) SetRep added in v5.4.0 

func (x *AvaticaType) SetRep(v Rep)

func (*AvaticaType) String 

func (x *AvaticaType) String() string

type AvaticaType_builder added in v5.4.0 

type AvaticaType_builder struct {
	Id        uint32
	Name      string
	Rep       Rep
	Columns   []*ColumnMetaData
	Component *AvaticaType
	// contains filtered or unexported fields
}

func (AvaticaType_builder) Build added in v5.4.0 

func (b0 AvaticaType_builder) Build() *AvaticaType

type CatalogsRequest 

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

Request for Meta#getCatalogs()

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) SetConnectionId added in v5.4.0 

func (x *CatalogsRequest) SetConnectionId(v string)

func (*CatalogsRequest) String 

func (x *CatalogsRequest) String() string

type CatalogsRequest_builder added in v5.4.0 

type CatalogsRequest_builder struct {
	ConnectionId string
	// contains filtered or unexported fields
}

func (CatalogsRequest_builder) Build added in v5.4.0 

func (b0 CatalogsRequest_builder) Build() *CatalogsRequest

type CloseConnectionRequest 

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

Request for Meta#closeConnection(Meta.ConnectionHandle)

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) SetConnectionId added in v5.4.0 

func (x *CloseConnectionRequest) SetConnectionId(v string)

func (*CloseConnectionRequest) String 

func (x *CloseConnectionRequest) String() string

type CloseConnectionRequest_builder added in v5.4.0 

type CloseConnectionRequest_builder struct {
	ConnectionId string
	// contains filtered or unexported fields
}

func (CloseConnectionRequest_builder) Build added in v5.4.0 

func (b0 CloseConnectionRequest_builder) Build() *CloseConnectionRequest

type CloseConnectionResponse 

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

Response to CloseConnectionRequest {

func (*CloseConnectionResponse) ClearMetadata added in v5.4.0 

func (x *CloseConnectionResponse) ClearMetadata()

func (*CloseConnectionResponse) GetMetadata 

func (x *CloseConnectionResponse) GetMetadata() *RpcMetadata

func (*CloseConnectionResponse) HasMetadata added in v5.4.0 

func (x *CloseConnectionResponse) HasMetadata() bool

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) SetMetadata added in v5.4.0 

func (x *CloseConnectionResponse) SetMetadata(v *RpcMetadata)

func (*CloseConnectionResponse) String 

func (x *CloseConnectionResponse) String() string

type CloseConnectionResponse_builder added in v5.4.0 

type CloseConnectionResponse_builder struct {
	Metadata *RpcMetadata
	// contains filtered or unexported fields
}

func (CloseConnectionResponse_builder) Build added in v5.4.0 

func (b0 CloseConnectionResponse_builder) Build() *CloseConnectionResponse

type CloseStatementRequest 

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

Request for Meta#closeStatement(Meta.StatementHandle)

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) SetConnectionId added in v5.4.0 

func (x *CloseStatementRequest) SetConnectionId(v string)

func (*CloseStatementRequest) SetStatementId added in v5.4.0 

func (x *CloseStatementRequest) SetStatementId(v uint32)

func (*CloseStatementRequest) String 

func (x *CloseStatementRequest) String() string

type CloseStatementRequest_builder added in v5.4.0 

type CloseStatementRequest_builder struct {
	ConnectionId string
	StatementId  uint32
	// contains filtered or unexported fields
}

func (CloseStatementRequest_builder) Build added in v5.4.0 

func (b0 CloseStatementRequest_builder) Build() *CloseStatementRequest

type CloseStatementResponse 

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

Response to CloseStatementRequest

func (*CloseStatementResponse) ClearMetadata added in v5.4.0 

func (x *CloseStatementResponse) ClearMetadata()

func (*CloseStatementResponse) GetMetadata 

func (x *CloseStatementResponse) GetMetadata() *RpcMetadata

func (*CloseStatementResponse) HasMetadata added in v5.4.0 

func (x *CloseStatementResponse) HasMetadata() bool

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) SetMetadata added in v5.4.0 

func (x *CloseStatementResponse) SetMetadata(v *RpcMetadata)

func (*CloseStatementResponse) String 

func (x *CloseStatementResponse) String() string

type CloseStatementResponse_builder added in v5.4.0 

type CloseStatementResponse_builder struct {
	Metadata *RpcMetadata
	// contains filtered or unexported fields
}

func (CloseStatementResponse_builder) Build added in v5.4.0 

func (b0 CloseStatementResponse_builder) Build() *CloseStatementResponse

type ColumnMetaData 

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

func (*ColumnMetaData) ClearType added in v5.4.0 

func (x *ColumnMetaData) ClearType()

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) HasType added in v5.4.0 

func (x *ColumnMetaData) HasType() 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) SetAutoIncrement added in v5.4.0 

func (x *ColumnMetaData) SetAutoIncrement(v bool)

func (*ColumnMetaData) SetCaseSensitive added in v5.4.0 

func (x *ColumnMetaData) SetCaseSensitive(v bool)

func (*ColumnMetaData) SetCatalogName added in v5.4.0 

func (x *ColumnMetaData) SetCatalogName(v string)

func (*ColumnMetaData) SetColumnClassName added in v5.4.0 

func (x *ColumnMetaData) SetColumnClassName(v string)

func (*ColumnMetaData) SetColumnName added in v5.4.0 

func (x *ColumnMetaData) SetColumnName(v string)

func (*ColumnMetaData) SetCurrency added in v5.4.0 

func (x *ColumnMetaData) SetCurrency(v bool)

func (*ColumnMetaData) SetDefinitelyWritable added in v5.4.0 

func (x *ColumnMetaData) SetDefinitelyWritable(v bool)

func (*ColumnMetaData) SetDisplaySize added in v5.4.0 

func (x *ColumnMetaData) SetDisplaySize(v uint32)

func (*ColumnMetaData) SetLabel added in v5.4.0 

func (x *ColumnMetaData) SetLabel(v string)

func (*ColumnMetaData) SetNullable added in v5.4.0 

func (x *ColumnMetaData) SetNullable(v uint32)

func (*ColumnMetaData) SetOrdinal added in v5.4.0 

func (x *ColumnMetaData) SetOrdinal(v uint32)

func (*ColumnMetaData) SetPrecision added in v5.4.0 

func (x *ColumnMetaData) SetPrecision(v uint32)

func (*ColumnMetaData) SetReadOnly added in v5.4.0 

func (x *ColumnMetaData) SetReadOnly(v bool)

func (*ColumnMetaData) SetScale added in v5.4.0 

func (x *ColumnMetaData) SetScale(v uint32)

func (*ColumnMetaData) SetSchemaName added in v5.4.0 

func (x *ColumnMetaData) SetSchemaName(v string)

func (*ColumnMetaData) SetSearchable added in v5.4.0 

func (x *ColumnMetaData) SetSearchable(v bool)

func (*ColumnMetaData) SetSigned added in v5.4.0 

func (x *ColumnMetaData) SetSigned(v bool)

func (*ColumnMetaData) SetTableName added in v5.4.0 

func (x *ColumnMetaData) SetTableName(v string)

func (*ColumnMetaData) SetType added in v5.4.0 

func (x *ColumnMetaData) SetType(v *AvaticaType)

func (*ColumnMetaData) SetWritable added in v5.4.0 

func (x *ColumnMetaData) SetWritable(v bool)

func (*ColumnMetaData) String 

func (x *ColumnMetaData) String() string

type ColumnMetaData_builder added in v5.4.0 

type ColumnMetaData_builder struct {
	Ordinal            uint32
	AutoIncrement      bool
	CaseSensitive      bool
	Searchable         bool
	Currency           bool
	Nullable           uint32
	Signed             bool
	DisplaySize        uint32
	Label              string
	ColumnName         string
	SchemaName         string
	Precision          uint32
	Scale              uint32
	TableName          string
	CatalogName        string
	ReadOnly           bool
	Writable           bool
	DefinitelyWritable bool
	ColumnClassName    string
	Type               *AvaticaType
	// contains filtered or unexported fields
}

func (ColumnMetaData_builder) Build added in v5.4.0 

func (b0 ColumnMetaData_builder) Build() *ColumnMetaData

type ColumnValue 

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

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

func (*ColumnValue) ClearScalarValue added in v5.4.0 

func (x *ColumnValue) ClearScalarValue()

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) HasScalarValue added in v5.4.0 

func (x *ColumnValue) HasScalarValue() bool

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) SetArrayValue added in v5.4.0 

func (x *ColumnValue) SetArrayValue(v []*TypedValue)

func (*ColumnValue) SetHasArrayValue added in v5.4.0 

func (x *ColumnValue) SetHasArrayValue(v bool)

func (*ColumnValue) SetScalarValue added in v5.4.0 

func (x *ColumnValue) SetScalarValue(v *TypedValue)

func (*ColumnValue) SetValue added in v5.4.0 

func (x *ColumnValue) SetValue(v []*TypedValue)

func (*ColumnValue) String 

func (x *ColumnValue) String() string

type ColumnValue_builder added in v5.4.0 

type ColumnValue_builder struct {
	Value         []*TypedValue
	ArrayValue    []*TypedValue
	HasArrayValue bool
	ScalarValue   *TypedValue
	// contains filtered or unexported fields
}

func (ColumnValue_builder) Build added in v5.4.0 

func (b0 ColumnValue_builder) Build() *ColumnValue

type ColumnsRequest 

type ColumnsRequest struct {
	// 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) 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) SetCatalog added in v5.4.0 

func (x *ColumnsRequest) SetCatalog(v string)

func (*ColumnsRequest) SetColumnNamePattern added in v5.4.0 

func (x *ColumnsRequest) SetColumnNamePattern(v string)

func (*ColumnsRequest) SetConnectionId added in v5.4.0 

func (x *ColumnsRequest) SetConnectionId(v string)

func (*ColumnsRequest) SetHasCatalog added in v5.4.0 

func (x *ColumnsRequest) SetHasCatalog(v bool)

func (*ColumnsRequest) SetHasColumnNamePattern added in v5.4.0 

func (x *ColumnsRequest) SetHasColumnNamePattern(v bool)

func (*ColumnsRequest) SetHasSchemaPattern added in v5.4.0 

func (x *ColumnsRequest) SetHasSchemaPattern(v bool)

func (*ColumnsRequest) SetHasTableNamePattern added in v5.4.0 

func (x *ColumnsRequest) SetHasTableNamePattern(v bool)

func (*ColumnsRequest) SetSchemaPattern added in v5.4.0 

func (x *ColumnsRequest) SetSchemaPattern(v string)

func (*ColumnsRequest) SetTableNamePattern added in v5.4.0 

func (x *ColumnsRequest) SetTableNamePattern(v string)

func (*ColumnsRequest) String 

func (x *ColumnsRequest) String() string

type ColumnsRequest_builder added in v5.4.0 

type ColumnsRequest_builder struct {
	Catalog              string
	SchemaPattern        string
	TableNamePattern     string
	ColumnNamePattern    string
	ConnectionId         string
	HasCatalog           bool
	HasSchemaPattern     bool
	HasTableNamePattern  bool
	HasColumnNamePattern bool
	// contains filtered or unexported fields
}

func (ColumnsRequest_builder) Build added in v5.4.0 

func (b0 ColumnsRequest_builder) Build() *ColumnsRequest

type CommitRequest 

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

Request to invoke a commit on a Connection

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) SetConnectionId added in v5.4.0 

func (x *CommitRequest) SetConnectionId(v string)

func (*CommitRequest) String 

func (x *CommitRequest) String() string

type CommitRequest_builder added in v5.4.0 

type CommitRequest_builder struct {
	ConnectionId string
	// contains filtered or unexported fields
}

func (CommitRequest_builder) Build added in v5.4.0 

func (b0 CommitRequest_builder) Build() *CommitRequest

type CommitResponse 

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

Response to a commit request

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 CommitResponse_builder added in v5.4.0 

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

func (CommitResponse_builder) Build added in v5.4.0 

func (b0 CommitResponse_builder) Build() *CommitResponse

type ConnectionProperties 

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

Details about a connection

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) SetAutoCommit added in v5.4.0 

func (x *ConnectionProperties) SetAutoCommit(v bool)

func (*ConnectionProperties) SetCatalog added in v5.4.0 

func (x *ConnectionProperties) SetCatalog(v string)

func (*ConnectionProperties) SetHasAutoCommit added in v5.4.0 

func (x *ConnectionProperties) SetHasAutoCommit(v bool)

func (*ConnectionProperties) SetHasReadOnly added in v5.4.0 

func (x *ConnectionProperties) SetHasReadOnly(v bool)

func (*ConnectionProperties) SetIsDirty added in v5.4.0 

func (x *ConnectionProperties) SetIsDirty(v bool)

func (*ConnectionProperties) SetReadOnly added in v5.4.0 

func (x *ConnectionProperties) SetReadOnly(v bool)

func (*ConnectionProperties) SetSchema added in v5.4.0 

func (x *ConnectionProperties) SetSchema(v string)

func (*ConnectionProperties) SetTransactionIsolation added in v5.4.0 

func (x *ConnectionProperties) SetTransactionIsolation(v uint32)

func (*ConnectionProperties) String 

func (x *ConnectionProperties) String() string

type ConnectionProperties_builder added in v5.4.0 

type ConnectionProperties_builder struct {
	IsDirty              bool
	AutoCommit           bool
	HasAutoCommit        bool
	ReadOnly             bool
	HasReadOnly          bool
	TransactionIsolation uint32
	Catalog              string
	Schema               string
	// contains filtered or unexported fields
}

func (ConnectionProperties_builder) Build added in v5.4.0 

func (b0 ConnectionProperties_builder) Build() *ConnectionProperties

type ConnectionSyncRequest 

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

func (*ConnectionSyncRequest) ClearConnProps added in v5.4.0 

func (x *ConnectionSyncRequest) ClearConnProps()

func (*ConnectionSyncRequest) GetConnProps 

func (x *ConnectionSyncRequest) GetConnProps() *ConnectionProperties

func (*ConnectionSyncRequest) GetConnectionId 

func (x *ConnectionSyncRequest) GetConnectionId() string

func (*ConnectionSyncRequest) HasConnProps added in v5.4.0 

func (x *ConnectionSyncRequest) HasConnProps() bool

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) SetConnProps added in v5.4.0 

func (x *ConnectionSyncRequest) SetConnProps(v *ConnectionProperties)

func (*ConnectionSyncRequest) SetConnectionId added in v5.4.0 

func (x *ConnectionSyncRequest) SetConnectionId(v string)

func (*ConnectionSyncRequest) String 

func (x *ConnectionSyncRequest) String() string

type ConnectionSyncRequest_builder added in v5.4.0 

type ConnectionSyncRequest_builder struct {
	ConnectionId string
	ConnProps    *ConnectionProperties
	// contains filtered or unexported fields
}

func (ConnectionSyncRequest_builder) Build added in v5.4.0 

func (b0 ConnectionSyncRequest_builder) Build() *ConnectionSyncRequest

type ConnectionSyncResponse 

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

Response to ConnectionSyncRequest

func (*ConnectionSyncResponse) ClearConnProps added in v5.4.0 

func (x *ConnectionSyncResponse) ClearConnProps()

func (*ConnectionSyncResponse) ClearMetadata added in v5.4.0 

func (x *ConnectionSyncResponse) ClearMetadata()

func (*ConnectionSyncResponse) GetConnProps 

func (x *ConnectionSyncResponse) GetConnProps() *ConnectionProperties

func (*ConnectionSyncResponse) GetMetadata 

func (x *ConnectionSyncResponse) GetMetadata() *RpcMetadata

func (*ConnectionSyncResponse) HasConnProps added in v5.4.0 

func (x *ConnectionSyncResponse) HasConnProps() bool

func (*ConnectionSyncResponse) HasMetadata added in v5.4.0 

func (x *ConnectionSyncResponse) HasMetadata() bool

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) SetConnProps added in v5.4.0 

func (x *ConnectionSyncResponse) SetConnProps(v *ConnectionProperties)

func (*ConnectionSyncResponse) SetMetadata added in v5.4.0 

func (x *ConnectionSyncResponse) SetMetadata(v *RpcMetadata)

func (*ConnectionSyncResponse) String 

func (x *ConnectionSyncResponse) String() string

type ConnectionSyncResponse_builder added in v5.4.0 

type ConnectionSyncResponse_builder struct {
	ConnProps *ConnectionProperties
	Metadata  *RpcMetadata
	// contains filtered or unexported fields
}

func (ConnectionSyncResponse_builder) Build added in v5.4.0 

func (b0 ConnectionSyncResponse_builder) Build() *ConnectionSyncResponse

type CreateStatementRequest 

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

Request for Meta#createStatement(Meta.ConnectionHandle)

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) SetConnectionId added in v5.4.0 

func (x *CreateStatementRequest) SetConnectionId(v string)

func (*CreateStatementRequest) String 

func (x *CreateStatementRequest) String() string

type CreateStatementRequest_builder added in v5.4.0 

type CreateStatementRequest_builder struct {
	ConnectionId string
	// contains filtered or unexported fields
}

func (CreateStatementRequest_builder) Build added in v5.4.0 

func (b0 CreateStatementRequest_builder) Build() *CreateStatementRequest

type CreateStatementResponse 

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

Response to CreateStatementRequest

func (*CreateStatementResponse) ClearMetadata added in v5.4.0 

func (x *CreateStatementResponse) ClearMetadata()

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) HasMetadata added in v5.4.0 

func (x *CreateStatementResponse) HasMetadata() bool

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) SetConnectionId added in v5.4.0 

func (x *CreateStatementResponse) SetConnectionId(v string)

func (*CreateStatementResponse) SetMetadata added in v5.4.0 

func (x *CreateStatementResponse) SetMetadata(v *RpcMetadata)

func (*CreateStatementResponse) SetStatementId added in v5.4.0 

func (x *CreateStatementResponse) SetStatementId(v uint32)

func (*CreateStatementResponse) String 

func (x *CreateStatementResponse) String() string

type CreateStatementResponse_builder added in v5.4.0 

type CreateStatementResponse_builder struct {
	ConnectionId string
	StatementId  uint32
	Metadata     *RpcMetadata
	// contains filtered or unexported fields
}

func (CreateStatementResponse_builder) Build added in v5.4.0 

func (b0 CreateStatementResponse_builder) Build() *CreateStatementResponse

type CursorFactory 

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

Information necessary to convert an Iterable into a Calcite Cursor

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) SetClassName added in v5.4.0 

func (x *CursorFactory) SetClassName(v string)

func (*CursorFactory) SetFieldNames added in v5.4.0 

func (x *CursorFactory) SetFieldNames(v []string)

func (*CursorFactory) SetStyle added in v5.4.0 

func (x *CursorFactory) SetStyle(v CursorFactory_Style)

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) 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 CursorFactory_builder added in v5.4.0 

type CursorFactory_builder struct {
	Style      CursorFactory_Style
	ClassName  string
	FieldNames []string
	// contains filtered or unexported fields
}

func (CursorFactory_builder) Build added in v5.4.0 

func (b0 CursorFactory_builder) Build() *CursorFactory

type DatabaseProperty 

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

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

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) SetFunctions added in v5.4.0 

func (x *DatabaseProperty) SetFunctions(v []string)

func (*DatabaseProperty) SetName added in v5.4.0 

func (x *DatabaseProperty) SetName(v string)

func (*DatabaseProperty) String 

func (x *DatabaseProperty) String() string

type DatabasePropertyElement 

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

func (*DatabasePropertyElement) ClearKey added in v5.4.0 

func (x *DatabasePropertyElement) ClearKey()

func (*DatabasePropertyElement) ClearMetadata added in v5.4.0 

func (x *DatabasePropertyElement) ClearMetadata()

func (*DatabasePropertyElement) ClearValue added in v5.4.0 

func (x *DatabasePropertyElement) ClearValue()

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) HasKey added in v5.4.0 

func (x *DatabasePropertyElement) HasKey() bool

func (*DatabasePropertyElement) HasMetadata added in v5.4.0 

func (x *DatabasePropertyElement) HasMetadata() bool

func (*DatabasePropertyElement) HasValue added in v5.4.0 

func (x *DatabasePropertyElement) HasValue() bool

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) SetKey added in v5.4.0 

func (x *DatabasePropertyElement) SetKey(v *DatabaseProperty)

func (*DatabasePropertyElement) SetMetadata added in v5.4.0 

func (x *DatabasePropertyElement) SetMetadata(v *RpcMetadata)

func (*DatabasePropertyElement) SetValue added in v5.4.0 

func (x *DatabasePropertyElement) SetValue(v *TypedValue)

func (*DatabasePropertyElement) String 

func (x *DatabasePropertyElement) String() string

type DatabasePropertyElement_builder added in v5.4.0 

type DatabasePropertyElement_builder struct {
	Key      *DatabaseProperty
	Value    *TypedValue
	Metadata *RpcMetadata
	// contains filtered or unexported fields
}

func (DatabasePropertyElement_builder) Build added in v5.4.0 

func (b0 DatabasePropertyElement_builder) Build() *DatabasePropertyElement

type DatabasePropertyRequest 

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

Request for Meta#getDatabaseProperties()

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) SetConnectionId added in v5.4.0 

func (x *DatabasePropertyRequest) SetConnectionId(v string)

func (*DatabasePropertyRequest) String 

func (x *DatabasePropertyRequest) String() string

type DatabasePropertyRequest_builder added in v5.4.0 

type DatabasePropertyRequest_builder struct {
	ConnectionId string
	// contains filtered or unexported fields
}

func (DatabasePropertyRequest_builder) Build added in v5.4.0 

func (b0 DatabasePropertyRequest_builder) Build() *DatabasePropertyRequest

type DatabasePropertyResponse 

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

Response for Meta#getDatabaseProperties()

func (*DatabasePropertyResponse) ClearMetadata added in v5.4.0 

func (x *DatabasePropertyResponse) ClearMetadata()

func (*DatabasePropertyResponse) GetMetadata 

func (x *DatabasePropertyResponse) GetMetadata() *RpcMetadata

func (*DatabasePropertyResponse) GetProps 

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

func (*DatabasePropertyResponse) HasMetadata added in v5.4.0 

func (x *DatabasePropertyResponse) HasMetadata() bool

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) SetMetadata added in v5.4.0 

func (x *DatabasePropertyResponse) SetMetadata(v *RpcMetadata)

func (*DatabasePropertyResponse) SetProps added in v5.4.0 

func (x *DatabasePropertyResponse) SetProps(v []*DatabasePropertyElement)

func (*DatabasePropertyResponse) String 

func (x *DatabasePropertyResponse) String() string

type DatabasePropertyResponse_builder added in v5.4.0 

type DatabasePropertyResponse_builder struct {
	Props    []*DatabasePropertyElement
	Metadata *RpcMetadata
	// contains filtered or unexported fields
}

func (DatabasePropertyResponse_builder) Build added in v5.4.0 

func (b0 DatabasePropertyResponse_builder) Build() *DatabasePropertyResponse

type DatabaseProperty_builder added in v5.4.0 

type DatabaseProperty_builder struct {
	Name      string
	Functions []string
	// contains filtered or unexported fields
}

func (DatabaseProperty_builder) Build added in v5.4.0 

func (b0 DatabaseProperty_builder) Build() *DatabaseProperty

type ErrorResponse 

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

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

func (*ErrorResponse) ClearMetadata added in v5.4.0 

func (x *ErrorResponse) ClearMetadata()

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) HasMetadata added in v5.4.0 

func (x *ErrorResponse) HasMetadata() bool

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) SetErrorCode added in v5.4.0 

func (x *ErrorResponse) SetErrorCode(v uint32)

func (*ErrorResponse) SetErrorMessage added in v5.4.0 

func (x *ErrorResponse) SetErrorMessage(v string)

func (*ErrorResponse) SetExceptions added in v5.4.0 

func (x *ErrorResponse) SetExceptions(v []string)

func (*ErrorResponse) SetHasExceptions added in v5.4.0 

func (x *ErrorResponse) SetHasExceptions(v bool)

func (*ErrorResponse) SetMetadata added in v5.4.0 

func (x *ErrorResponse) SetMetadata(v *RpcMetadata)

func (*ErrorResponse) SetSeverity added in v5.4.0 

func (x *ErrorResponse) SetSeverity(v Severity)

func (*ErrorResponse) SetSqlState added in v5.4.0 

func (x *ErrorResponse) SetSqlState(v string)

func (*ErrorResponse) String 

func (x *ErrorResponse) String() string

type ErrorResponse_builder added in v5.4.0 

type ErrorResponse_builder struct {
	Exceptions    []string
	HasExceptions bool
	ErrorMessage  string
	Severity      Severity
	ErrorCode     uint32
	SqlState      string
	Metadata      *RpcMetadata
	// contains filtered or unexported fields
}

func (ErrorResponse_builder) Build added in v5.4.0 

func (b0 ErrorResponse_builder) Build() *ErrorResponse

type ExecuteBatchRequest 

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

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) SetConnectionId added in v5.4.0 

func (x *ExecuteBatchRequest) SetConnectionId(v string)

func (*ExecuteBatchRequest) SetStatementId added in v5.4.0 

func (x *ExecuteBatchRequest) SetStatementId(v uint32)

func (*ExecuteBatchRequest) SetUpdates added in v5.4.0 

func (x *ExecuteBatchRequest) SetUpdates(v []*UpdateBatch)

func (*ExecuteBatchRequest) String 

func (x *ExecuteBatchRequest) String() string

type ExecuteBatchRequest_builder added in v5.4.0 

type ExecuteBatchRequest_builder struct {
	ConnectionId string
	StatementId  uint32
	Updates      []*UpdateBatch
	// contains filtered or unexported fields
}

func (ExecuteBatchRequest_builder) Build added in v5.4.0 

func (b0 ExecuteBatchRequest_builder) Build() *ExecuteBatchRequest

type ExecuteBatchResponse 

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

Response to a batch update request

func (*ExecuteBatchResponse) ClearMetadata added in v5.4.0 

func (x *ExecuteBatchResponse) ClearMetadata()

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) HasMetadata added in v5.4.0 

func (x *ExecuteBatchResponse) HasMetadata() bool

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) SetConnectionId added in v5.4.0 

func (x *ExecuteBatchResponse) SetConnectionId(v string)

func (*ExecuteBatchResponse) SetMetadata added in v5.4.0 

func (x *ExecuteBatchResponse) SetMetadata(v *RpcMetadata)

func (*ExecuteBatchResponse) SetMissingStatement added in v5.4.0 

func (x *ExecuteBatchResponse) SetMissingStatement(v bool)

func (*ExecuteBatchResponse) SetStatementId added in v5.4.0 

func (x *ExecuteBatchResponse) SetStatementId(v uint32)

func (*ExecuteBatchResponse) SetUpdateCounts added in v5.4.0 

func (x *ExecuteBatchResponse) SetUpdateCounts(v []uint64)

func (*ExecuteBatchResponse) String 

func (x *ExecuteBatchResponse) String() string

type ExecuteBatchResponse_builder added in v5.4.0 

type ExecuteBatchResponse_builder struct {
	ConnectionId     string
	StatementId      uint32
	UpdateCounts     []uint64
	MissingStatement bool
	Metadata         *RpcMetadata
	// contains filtered or unexported fields
}

func (ExecuteBatchResponse_builder) Build added in v5.4.0 

func (b0 ExecuteBatchResponse_builder) Build() *ExecuteBatchResponse

type ExecuteRequest 

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

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

func (*ExecuteRequest) ClearStatementHandle added in v5.4.0 

func (x *ExecuteRequest) ClearStatementHandle()

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) HasStatementHandle added in v5.4.0 

func (x *ExecuteRequest) HasStatementHandle() bool

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) SetDeprecatedFirstFrameMaxSize added in v5.4.0 

func (x *ExecuteRequest) SetDeprecatedFirstFrameMaxSize(v uint64)

func (*ExecuteRequest) SetFirstFrameMaxSize added in v5.4.0 

func (x *ExecuteRequest) SetFirstFrameMaxSize(v int32)

func (*ExecuteRequest) SetHasParameterValues added in v5.4.0 

func (x *ExecuteRequest) SetHasParameterValues(v bool)

func (*ExecuteRequest) SetParameterValues added in v5.4.0 

func (x *ExecuteRequest) SetParameterValues(v []*TypedValue)

func (*ExecuteRequest) SetStatementHandle added in v5.4.0 

func (x *ExecuteRequest) SetStatementHandle(v *StatementHandle)

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type ExecuteRequest_builder added in v5.4.0 

type ExecuteRequest_builder struct {
	StatementHandle             *StatementHandle
	ParameterValues             []*TypedValue
	DeprecatedFirstFrameMaxSize uint64
	HasParameterValues          bool
	FirstFrameMaxSize           int32
	// contains filtered or unexported fields
}

func (ExecuteRequest_builder) Build added in v5.4.0 

func (b0 ExecuteRequest_builder) Build() *ExecuteRequest

type ExecuteResponse 

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

Response to PrepareAndExecuteRequest

func (*ExecuteResponse) ClearMetadata added in v5.4.0 

func (x *ExecuteResponse) ClearMetadata()

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) HasMetadata added in v5.4.0 

func (x *ExecuteResponse) HasMetadata() bool

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) SetMetadata added in v5.4.0 

func (x *ExecuteResponse) SetMetadata(v *RpcMetadata)

func (*ExecuteResponse) SetMissingStatement added in v5.4.0 

func (x *ExecuteResponse) SetMissingStatement(v bool)

func (*ExecuteResponse) SetResults added in v5.4.0 

func (x *ExecuteResponse) SetResults(v []*ResultSetResponse)

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type ExecuteResponse_builder added in v5.4.0 

type ExecuteResponse_builder struct {
	Results          []*ResultSetResponse
	MissingStatement bool
	Metadata         *RpcMetadata
	// contains filtered or unexported fields
}

func (ExecuteResponse_builder) Build added in v5.4.0 

func (b0 ExecuteResponse_builder) Build() *ExecuteResponse

type FetchRequest 

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

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

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) SetConnectionId added in v5.4.0 

func (x *FetchRequest) SetConnectionId(v string)

func (*FetchRequest) SetFetchMaxRowCount added in v5.4.0 

func (x *FetchRequest) SetFetchMaxRowCount(v uint32)

func (*FetchRequest) SetFrameMaxSize added in v5.4.0 

func (x *FetchRequest) SetFrameMaxSize(v int32)

func (*FetchRequest) SetOffset added in v5.4.0 

func (x *FetchRequest) SetOffset(v uint64)

func (*FetchRequest) SetStatementId added in v5.4.0 

func (x *FetchRequest) SetStatementId(v uint32)

func (*FetchRequest) String 

func (x *FetchRequest) String() string

type FetchRequest_builder added in v5.4.0 

type FetchRequest_builder struct {
	ConnectionId     string
	StatementId      uint32
	Offset           uint64
	FetchMaxRowCount uint32
	FrameMaxSize     int32
	// contains filtered or unexported fields
}

func (FetchRequest_builder) Build added in v5.4.0 

func (b0 FetchRequest_builder) Build() *FetchRequest

type FetchResponse 

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

Response to FetchRequest

func (*FetchResponse) ClearFrame added in v5.4.0 

func (x *FetchResponse) ClearFrame()

func (*FetchResponse) ClearMetadata added in v5.4.0 

func (x *FetchResponse) ClearMetadata()

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) HasFrame added in v5.4.0 

func (x *FetchResponse) HasFrame() bool

func (*FetchResponse) HasMetadata added in v5.4.0 

func (x *FetchResponse) HasMetadata() 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) SetFrame added in v5.4.0 

func (x *FetchResponse) SetFrame(v *Frame)

func (*FetchResponse) SetMetadata added in v5.4.0 

func (x *FetchResponse) SetMetadata(v *RpcMetadata)

func (*FetchResponse) SetMissingResults added in v5.4.0 

func (x *FetchResponse) SetMissingResults(v bool)

func (*FetchResponse) SetMissingStatement added in v5.4.0 

func (x *FetchResponse) SetMissingStatement(v bool)

func (*FetchResponse) String 

func (x *FetchResponse) String() string

type FetchResponse_builder added in v5.4.0 

type FetchResponse_builder struct {
	Frame            *Frame
	MissingStatement bool
	MissingResults   bool
	Metadata         *RpcMetadata
	// contains filtered or unexported fields
}

func (FetchResponse_builder) Build added in v5.4.0 

func (b0 FetchResponse_builder) Build() *FetchResponse

type Frame 

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

A collection of rows

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) SetDone added in v5.4.0 

func (x *Frame) SetDone(v bool)

func (*Frame) SetOffset added in v5.4.0 

func (x *Frame) SetOffset(v uint64)

func (*Frame) SetRows added in v5.4.0 

func (x *Frame) SetRows(v []*Row)

func (*Frame) String 

func (x *Frame) String() string

type Frame_builder added in v5.4.0 

type Frame_builder struct {
	Offset uint64
	Done   bool
	Rows   []*Row
	// contains filtered or unexported fields
}

func (Frame_builder) Build added in v5.4.0 

func (b0 Frame_builder) Build() *Frame

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

Represents the breadth of arguments to DatabaseMetaData functions

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) SetBoolValue added in v5.4.0 

func (x *MetaDataOperationArgument) SetBoolValue(v bool)

func (*MetaDataOperationArgument) SetIntArrayValues added in v5.4.0 

func (x *MetaDataOperationArgument) SetIntArrayValues(v []int32)

func (*MetaDataOperationArgument) SetIntValue added in v5.4.0 

func (x *MetaDataOperationArgument) SetIntValue(v int32)

func (*MetaDataOperationArgument) SetStringArrayValues added in v5.4.0 

func (x *MetaDataOperationArgument) SetStringArrayValues(v []string)

func (*MetaDataOperationArgument) SetStringValue added in v5.4.0 

func (x *MetaDataOperationArgument) SetStringValue(v string)

func (*MetaDataOperationArgument) SetType added in v5.4.0 

func (x *MetaDataOperationArgument) SetType(v MetaDataOperationArgument_ArgumentType)

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) 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 MetaDataOperationArgument_builder added in v5.4.0 

type MetaDataOperationArgument_builder struct {
	StringValue       string
	BoolValue         bool
	IntValue          int32
	StringArrayValues []string
	IntArrayValues    []int32
	Type              MetaDataOperationArgument_ArgumentType
	// contains filtered or unexported fields
}

func (MetaDataOperationArgument_builder) Build added in v5.4.0 

func (b0 MetaDataOperationArgument_builder) Build() *MetaDataOperationArgument

type MetadataProvider 

type MetadataProvider interface {
	GetMetadata() *RpcMetadata
}

type OpenConnectionRequest 

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

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

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) SetConnectionId added in v5.4.0 

func (x *OpenConnectionRequest) SetConnectionId(v string)

func (*OpenConnectionRequest) SetInfo added in v5.4.0 

func (x *OpenConnectionRequest) SetInfo(v map[string]string)

func (*OpenConnectionRequest) String 

func (x *OpenConnectionRequest) String() string

type OpenConnectionRequest_builder added in v5.4.0 

type OpenConnectionRequest_builder struct {
	ConnectionId string
	Info         map[string]string
	// contains filtered or unexported fields
}

func (OpenConnectionRequest_builder) Build added in v5.4.0 

func (b0 OpenConnectionRequest_builder) Build() *OpenConnectionRequest

type OpenConnectionResponse 

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

Response to OpenConnectionRequest {

func (*OpenConnectionResponse) ClearMetadata added in v5.4.0 

func (x *OpenConnectionResponse) ClearMetadata()

func (*OpenConnectionResponse) GetMetadata 

func (x *OpenConnectionResponse) GetMetadata() *RpcMetadata

func (*OpenConnectionResponse) HasMetadata added in v5.4.0 

func (x *OpenConnectionResponse) HasMetadata() bool

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) SetMetadata added in v5.4.0 

func (x *OpenConnectionResponse) SetMetadata(v *RpcMetadata)

func (*OpenConnectionResponse) String 

func (x *OpenConnectionResponse) String() string

type OpenConnectionResponse_builder added in v5.4.0 

type OpenConnectionResponse_builder struct {
	Metadata *RpcMetadata
	// contains filtered or unexported fields
}

func (OpenConnectionResponse_builder) Build added in v5.4.0 

func (b0 OpenConnectionResponse_builder) Build() *OpenConnectionResponse

type PrepareAndExecuteBatchRequest 

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

Request to prepare and execute a collection of sql statements.

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) SetConnectionId added in v5.4.0 

func (x *PrepareAndExecuteBatchRequest) SetConnectionId(v string)

func (*PrepareAndExecuteBatchRequest) SetSqlCommands added in v5.4.0 

func (x *PrepareAndExecuteBatchRequest) SetSqlCommands(v []string)

func (*PrepareAndExecuteBatchRequest) SetStatementId added in v5.4.0 

func (x *PrepareAndExecuteBatchRequest) SetStatementId(v uint32)

func (*PrepareAndExecuteBatchRequest) String 

func (x *PrepareAndExecuteBatchRequest) String() string

type PrepareAndExecuteBatchRequest_builder added in v5.4.0 

type PrepareAndExecuteBatchRequest_builder struct {
	ConnectionId string
	StatementId  uint32
	SqlCommands  []string
	// contains filtered or unexported fields
}

func (PrepareAndExecuteBatchRequest_builder) Build added in v5.4.0 

func (b0 PrepareAndExecuteBatchRequest_builder) Build() *PrepareAndExecuteBatchRequest

type PrepareAndExecuteRequest 

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

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

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) SetConnectionId added in v5.4.0 

func (x *PrepareAndExecuteRequest) SetConnectionId(v string)

func (*PrepareAndExecuteRequest) SetFirstFrameMaxSize added in v5.4.0 

func (x *PrepareAndExecuteRequest) SetFirstFrameMaxSize(v int32)

func (*PrepareAndExecuteRequest) SetMaxRowCount added in v5.4.0 

func (x *PrepareAndExecuteRequest) SetMaxRowCount(v uint64)

func (*PrepareAndExecuteRequest) SetMaxRowsTotal added in v5.4.0 

func (x *PrepareAndExecuteRequest) SetMaxRowsTotal(v int64)

func (*PrepareAndExecuteRequest) SetSql added in v5.4.0 

func (x *PrepareAndExecuteRequest) SetSql(v string)

func (*PrepareAndExecuteRequest) SetStatementId added in v5.4.0 

func (x *PrepareAndExecuteRequest) SetStatementId(v uint32)

func (*PrepareAndExecuteRequest) String 

func (x *PrepareAndExecuteRequest) String() string

type PrepareAndExecuteRequest_builder added in v5.4.0 

type PrepareAndExecuteRequest_builder struct {
	ConnectionId      string
	Sql               string
	MaxRowCount       uint64
	StatementId       uint32
	MaxRowsTotal      int64
	FirstFrameMaxSize int32
	// contains filtered or unexported fields
}

func (PrepareAndExecuteRequest_builder) Build added in v5.4.0 

func (b0 PrepareAndExecuteRequest_builder) Build() *PrepareAndExecuteRequest

type PrepareRequest 

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

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

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) SetConnectionId added in v5.4.0 

func (x *PrepareRequest) SetConnectionId(v string)

func (*PrepareRequest) SetMaxRowCount added in v5.4.0 

func (x *PrepareRequest) SetMaxRowCount(v uint64)

func (*PrepareRequest) SetMaxRowsTotal added in v5.4.0 

func (x *PrepareRequest) SetMaxRowsTotal(v int64)

func (*PrepareRequest) SetSql added in v5.4.0 

func (x *PrepareRequest) SetSql(v string)

func (*PrepareRequest) String 

func (x *PrepareRequest) String() string

type PrepareRequest_builder added in v5.4.0 

type PrepareRequest_builder struct {
	ConnectionId string
	Sql          string
	MaxRowCount  uint64
	MaxRowsTotal int64
	// contains filtered or unexported fields
}

func (PrepareRequest_builder) Build added in v5.4.0 

func (b0 PrepareRequest_builder) Build() *PrepareRequest

type PrepareResponse 

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

Response to PrepareRequest

func (*PrepareResponse) ClearMetadata added in v5.4.0 

func (x *PrepareResponse) ClearMetadata()

func (*PrepareResponse) ClearStatement added in v5.4.0 

func (x *PrepareResponse) ClearStatement()

func (*PrepareResponse) GetMetadata 

func (x *PrepareResponse) GetMetadata() *RpcMetadata

func (*PrepareResponse) GetStatement 

func (x *PrepareResponse) GetStatement() *StatementHandle

func (*PrepareResponse) HasMetadata added in v5.4.0 

func (x *PrepareResponse) HasMetadata() bool

func (*PrepareResponse) HasStatement added in v5.4.0 

func (x *PrepareResponse) HasStatement() bool

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) SetMetadata added in v5.4.0 

func (x *PrepareResponse) SetMetadata(v *RpcMetadata)

func (*PrepareResponse) SetStatement added in v5.4.0 

func (x *PrepareResponse) SetStatement(v *StatementHandle)

func (*PrepareResponse) String 

func (x *PrepareResponse) String() string

type PrepareResponse_builder added in v5.4.0 

type PrepareResponse_builder struct {
	Statement *StatementHandle
	Metadata  *RpcMetadata
	// contains filtered or unexported fields
}

func (PrepareResponse_builder) Build added in v5.4.0 

func (b0 PrepareResponse_builder) Build() *PrepareResponse

type QueryState 

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

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) SetArgs added in v5.4.0 

func (x *QueryState) SetArgs(v []*MetaDataOperationArgument)

func (*QueryState) SetHasArgs added in v5.4.0 

func (x *QueryState) SetHasArgs(v bool)

func (*QueryState) SetHasOp added in v5.4.0 

func (x *QueryState) SetHasOp(v bool)

func (*QueryState) SetHasSql added in v5.4.0 

func (x *QueryState) SetHasSql(v bool)

func (*QueryState) SetOp added in v5.4.0 

func (x *QueryState) SetOp(v MetaDataOperation)

func (*QueryState) SetSql added in v5.4.0 

func (x *QueryState) SetSql(v string)

func (*QueryState) SetType added in v5.4.0 

func (x *QueryState) SetType(v StateType)

func (*QueryState) String 

func (x *QueryState) String() string

type QueryState_builder added in v5.4.0 

type QueryState_builder struct {
	Type    StateType
	Sql     string
	Op      MetaDataOperation
	Args    []*MetaDataOperationArgument
	HasArgs bool
	HasSql  bool
	HasOp   bool
	// contains filtered or unexported fields
}

func (QueryState_builder) Build added in v5.4.0 

func (b0 QueryState_builder) Build() *QueryState

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

Response that contains a result set.

func (*ResultSetResponse) ClearFirstFrame added in v5.4.0 

func (x *ResultSetResponse) ClearFirstFrame()

func (*ResultSetResponse) ClearMetadata added in v5.4.0 

func (x *ResultSetResponse) ClearMetadata()

func (*ResultSetResponse) ClearSignature added in v5.4.0 

func (x *ResultSetResponse) ClearSignature()

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) HasFirstFrame added in v5.4.0 

func (x *ResultSetResponse) HasFirstFrame() bool

func (*ResultSetResponse) HasMetadata added in v5.4.0 

func (x *ResultSetResponse) HasMetadata() bool

func (*ResultSetResponse) HasSignature added in v5.4.0 

func (x *ResultSetResponse) HasSignature() bool

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) SetConnectionId added in v5.4.0 

func (x *ResultSetResponse) SetConnectionId(v string)

func (*ResultSetResponse) SetFirstFrame added in v5.4.0 

func (x *ResultSetResponse) SetFirstFrame(v *Frame)

func (*ResultSetResponse) SetMetadata added in v5.4.0 

func (x *ResultSetResponse) SetMetadata(v *RpcMetadata)

func (*ResultSetResponse) SetOwnStatement added in v5.4.0 

func (x *ResultSetResponse) SetOwnStatement(v bool)

func (*ResultSetResponse) SetSignature added in v5.4.0 

func (x *ResultSetResponse) SetSignature(v *Signature)

func (*ResultSetResponse) SetStatementId added in v5.4.0 

func (x *ResultSetResponse) SetStatementId(v uint32)

func (*ResultSetResponse) SetUpdateCount added in v5.4.0 

func (x *ResultSetResponse) SetUpdateCount(v uint64)

func (*ResultSetResponse) String 

func (x *ResultSetResponse) String() string

type ResultSetResponse_builder added in v5.4.0 

type ResultSetResponse_builder struct {
	ConnectionId string
	StatementId  uint32
	OwnStatement bool
	Signature    *Signature
	FirstFrame   *Frame
	UpdateCount  uint64
	// with no signature nor other data.
	Metadata *RpcMetadata
	// contains filtered or unexported fields
}

func (ResultSetResponse_builder) Build added in v5.4.0 

func (b0 ResultSetResponse_builder) Build() *ResultSetResponse

type RollbackRequest 

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

Request to invoke rollback on a Connection

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) SetConnectionId added in v5.4.0 

func (x *RollbackRequest) SetConnectionId(v string)

func (*RollbackRequest) String 

func (x *RollbackRequest) String() string

type RollbackRequest_builder added in v5.4.0 

type RollbackRequest_builder struct {
	ConnectionId string
	// contains filtered or unexported fields
}

func (RollbackRequest_builder) Build added in v5.4.0 

func (b0 RollbackRequest_builder) Build() *RollbackRequest

type RollbackResponse 

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

Response to a rollback request

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 RollbackResponse_builder added in v5.4.0 

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

func (RollbackResponse_builder) Build added in v5.4.0 

func (b0 RollbackResponse_builder) Build() *RollbackResponse

type Row 

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

A row is a collection of values

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) SetValue added in v5.4.0 

func (x *Row) SetValue(v []*ColumnValue)

func (*Row) String 

func (x *Row) String() string

type Row_builder added in v5.4.0 

type Row_builder struct {
	Value []*ColumnValue
	// contains filtered or unexported fields
}

func (Row_builder) Build added in v5.4.0 

func (b0 Row_builder) Build() *Row

type RpcMetadata 

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

Generic metadata for the server to return with each response.

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) SetServerAddress added in v5.4.0 

func (x *RpcMetadata) SetServerAddress(v string)

func (*RpcMetadata) String 

func (x *RpcMetadata) String() string

type RpcMetadata_builder added in v5.4.0 

type RpcMetadata_builder struct {
	ServerAddress string
	// contains filtered or unexported fields
}

func (RpcMetadata_builder) Build added in v5.4.0 

func (b0 RpcMetadata_builder) Build() *RpcMetadata

type SchemasRequest 

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

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

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) SetCatalog added in v5.4.0 

func (x *SchemasRequest) SetCatalog(v string)

func (*SchemasRequest) SetConnectionId added in v5.4.0 

func (x *SchemasRequest) SetConnectionId(v string)

func (*SchemasRequest) SetHasCatalog added in v5.4.0 

func (x *SchemasRequest) SetHasCatalog(v bool)

func (*SchemasRequest) SetHasSchemaPattern added in v5.4.0 

func (x *SchemasRequest) SetHasSchemaPattern(v bool)

func (*SchemasRequest) SetSchemaPattern added in v5.4.0 

func (x *SchemasRequest) SetSchemaPattern(v string)

func (*SchemasRequest) String 

func (x *SchemasRequest) String() string

type SchemasRequest_builder added in v5.4.0 

type SchemasRequest_builder struct {
	Catalog          string
	SchemaPattern    string
	ConnectionId     string
	HasCatalog       bool
	HasSchemaPattern bool
	// contains filtered or unexported fields
}

func (SchemasRequest_builder) Build added in v5.4.0 

func (b0 SchemasRequest_builder) Build() *SchemasRequest

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

Results of preparing a statement

func (*Signature) ClearCursorFactory added in v5.4.0 

func (x *Signature) ClearCursorFactory()

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) HasCursorFactory added in v5.4.0 

func (x *Signature) HasCursorFactory() bool

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) SetColumns added in v5.4.0 

func (x *Signature) SetColumns(v []*ColumnMetaData)

func (*Signature) SetCursorFactory added in v5.4.0 

func (x *Signature) SetCursorFactory(v *CursorFactory)

func (*Signature) SetParameters added in v5.4.0 

func (x *Signature) SetParameters(v []*AvaticaParameter)

func (*Signature) SetSql added in v5.4.0 

func (x *Signature) SetSql(v string)

func (*Signature) SetStatementType added in v5.4.0 

func (x *Signature) SetStatementType(v StatementType)

func (*Signature) String 

func (x *Signature) String() string

type Signature_builder added in v5.4.0 

type Signature_builder struct {
	Columns       []*ColumnMetaData
	Sql           string
	Parameters    []*AvaticaParameter
	CursorFactory *CursorFactory
	StatementType StatementType
	// contains filtered or unexported fields
}

func (Signature_builder) Build added in v5.4.0 

func (b0 Signature_builder) Build() *Signature

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

Statement handle

func (*StatementHandle) ClearSignature added in v5.4.0 

func (x *StatementHandle) ClearSignature()

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) HasSignature added in v5.4.0 

func (x *StatementHandle) HasSignature() bool

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) SetConnectionId added in v5.4.0 

func (x *StatementHandle) SetConnectionId(v string)

func (*StatementHandle) SetId added in v5.4.0 

func (x *StatementHandle) SetId(v uint32)

func (*StatementHandle) SetSignature added in v5.4.0 

func (x *StatementHandle) SetSignature(v *Signature)

func (*StatementHandle) String 

func (x *StatementHandle) String() string

type StatementHandle_builder added in v5.4.0 

type StatementHandle_builder struct {
	ConnectionId string
	Id           uint32
	Signature    *Signature
	// contains filtered or unexported fields
}

func (StatementHandle_builder) Build added in v5.4.0 

func (b0 StatementHandle_builder) Build() *StatementHandle

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

func (*SyncResultsRequest) ClearState added in v5.4.0 

func (x *SyncResultsRequest) ClearState()

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) HasState added in v5.4.0 

func (x *SyncResultsRequest) HasState() bool

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) SetConnectionId added in v5.4.0 

func (x *SyncResultsRequest) SetConnectionId(v string)

func (*SyncResultsRequest) SetOffset added in v5.4.0 

func (x *SyncResultsRequest) SetOffset(v uint64)

func (*SyncResultsRequest) SetState added in v5.4.0 

func (x *SyncResultsRequest) SetState(v *QueryState)

func (*SyncResultsRequest) SetStatementId added in v5.4.0 

func (x *SyncResultsRequest) SetStatementId(v uint32)

func (*SyncResultsRequest) String 

func (x *SyncResultsRequest) String() string

type SyncResultsRequest_builder added in v5.4.0 

type SyncResultsRequest_builder struct {
	ConnectionId string
	StatementId  uint32
	State        *QueryState
	Offset       uint64
	// contains filtered or unexported fields
}

func (SyncResultsRequest_builder) Build added in v5.4.0 

func (b0 SyncResultsRequest_builder) Build() *SyncResultsRequest

type SyncResultsResponse 

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

func (*SyncResultsResponse) ClearMetadata added in v5.4.0 

func (x *SyncResultsResponse) ClearMetadata()

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) HasMetadata added in v5.4.0 

func (x *SyncResultsResponse) HasMetadata() 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) SetMetadata added in v5.4.0 

func (x *SyncResultsResponse) SetMetadata(v *RpcMetadata)

func (*SyncResultsResponse) SetMissingStatement added in v5.4.0 

func (x *SyncResultsResponse) SetMissingStatement(v bool)

func (*SyncResultsResponse) SetMoreResults added in v5.4.0 

func (x *SyncResultsResponse) SetMoreResults(v bool)

func (*SyncResultsResponse) String 

func (x *SyncResultsResponse) String() string

type SyncResultsResponse_builder added in v5.4.0 

type SyncResultsResponse_builder struct {
	MissingStatement bool
	MoreResults      bool
	Metadata         *RpcMetadata
	// contains filtered or unexported fields
}

func (SyncResultsResponse_builder) Build added in v5.4.0 

func (b0 SyncResultsResponse_builder) Build() *SyncResultsResponse

type TableTypesRequest 

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

Request for Meta#getTableTypes()

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) SetConnectionId added in v5.4.0 

func (x *TableTypesRequest) SetConnectionId(v string)

func (*TableTypesRequest) String 

func (x *TableTypesRequest) String() string

type TableTypesRequest_builder added in v5.4.0 

type TableTypesRequest_builder struct {
	ConnectionId string
	// contains filtered or unexported fields
}

func (TableTypesRequest_builder) Build added in v5.4.0 

func (b0 TableTypesRequest_builder) Build() *TableTypesRequest

type TablesRequest 

type TablesRequest struct {
	// 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) 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) SetCatalog added in v5.4.0 

func (x *TablesRequest) SetCatalog(v string)

func (*TablesRequest) SetConnectionId added in v5.4.0 

func (x *TablesRequest) SetConnectionId(v string)

func (*TablesRequest) SetHasCatalog added in v5.4.0 

func (x *TablesRequest) SetHasCatalog(v bool)

func (*TablesRequest) SetHasSchemaPattern added in v5.4.0 

func (x *TablesRequest) SetHasSchemaPattern(v bool)

func (*TablesRequest) SetHasTableNamePattern added in v5.4.0 

func (x *TablesRequest) SetHasTableNamePattern(v bool)

func (*TablesRequest) SetHasTypeList added in v5.4.0 

func (x *TablesRequest) SetHasTypeList(v bool)

func (*TablesRequest) SetSchemaPattern added in v5.4.0 

func (x *TablesRequest) SetSchemaPattern(v string)

func (*TablesRequest) SetTableNamePattern added in v5.4.0 

func (x *TablesRequest) SetTableNamePattern(v string)

func (*TablesRequest) SetTypeList added in v5.4.0 

func (x *TablesRequest) SetTypeList(v []string)

func (*TablesRequest) String 

func (x *TablesRequest) String() string

type TablesRequest_builder added in v5.4.0 

type TablesRequest_builder struct {
	Catalog             string
	SchemaPattern       string
	TableNamePattern    string
	TypeList            []string
	HasTypeList         bool
	ConnectionId        string
	HasCatalog          bool
	HasSchemaPattern    bool
	HasTableNamePattern bool
	// contains filtered or unexported fields
}

func (TablesRequest_builder) Build added in v5.4.0 

func (b0 TablesRequest_builder) Build() *TablesRequest

type TypeInfoRequest 

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

Request for Meta#getTypeInfo()

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) SetConnectionId added in v5.4.0 

func (x *TypeInfoRequest) SetConnectionId(v string)

func (*TypeInfoRequest) String 

func (x *TypeInfoRequest) String() string

type TypeInfoRequest_builder added in v5.4.0 

type TypeInfoRequest_builder struct {
	ConnectionId string
	// contains filtered or unexported fields
}

func (TypeInfoRequest_builder) Build added in v5.4.0 

func (b0 TypeInfoRequest_builder) Build() *TypeInfoRequest

type TypedValue 

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

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

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) SetArrayValue added in v5.4.0 

func (x *TypedValue) SetArrayValue(v []*TypedValue)

func (*TypedValue) SetBoolValue added in v5.4.0 

func (x *TypedValue) SetBoolValue(v bool)

func (*TypedValue) SetBytesValue added in v5.4.0 

func (x *TypedValue) SetBytesValue(v []byte)

func (*TypedValue) SetComponentType added in v5.4.0 

func (x *TypedValue) SetComponentType(v Rep)

func (*TypedValue) SetDoubleValue added in v5.4.0 

func (x *TypedValue) SetDoubleValue(v float64)

func (*TypedValue) SetImplicitlyNull added in v5.4.0 

func (x *TypedValue) SetImplicitlyNull(v bool)

func (*TypedValue) SetNull added in v5.4.0 

func (x *TypedValue) SetNull(v bool)

func (*TypedValue) SetNumberValue added in v5.4.0 

func (x *TypedValue) SetNumberValue(v int64)

func (*TypedValue) SetStringValue added in v5.4.0 

func (x *TypedValue) SetStringValue(v string)

func (*TypedValue) SetType added in v5.4.0 

func (x *TypedValue) SetType(v Rep)

func (*TypedValue) String 

func (x *TypedValue) String() string

type TypedValue_builder added in v5.4.0 

type TypedValue_builder struct {
	Type        Rep
	BoolValue   bool
	StringValue string
	NumberValue int64
	// includes numeric types and date/time types.
	BytesValue     []byte
	DoubleValue    float64
	Null           bool
	ArrayValue     []*TypedValue
	ComponentType  Rep
	ImplicitlyNull bool
	// contains filtered or unexported fields
}

func (TypedValue_builder) Build added in v5.4.0 

func (b0 TypedValue_builder) Build() *TypedValue

type UpdateBatch 

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

Each command is a list of TypedValues

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) SetParameterValues added in v5.4.0 

func (x *UpdateBatch) SetParameterValues(v []*TypedValue)

func (*UpdateBatch) String 

func (x *UpdateBatch) String() string

type UpdateBatch_builder added in v5.4.0 

type UpdateBatch_builder struct {
	ParameterValues []*TypedValue
	// contains filtered or unexported fields
}

func (UpdateBatch_builder) Build added in v5.4.0 

func (b0 UpdateBatch_builder) Build() *UpdateBatch

type WireMessage 

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

Message which encapsulates another message to support a single RPC endpoint

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) SetName added in v5.4.0 

func (x *WireMessage) SetName(v string)

func (*WireMessage) SetWrappedMessage added in v5.4.0 

func (x *WireMessage) SetWrappedMessage(v []byte)

func (*WireMessage) String 

func (x *WireMessage) String() string

type WireMessage_builder added in v5.4.0 

type WireMessage_builder struct {
	Name           string
	WrappedMessage []byte
	// contains filtered or unexported fields
}

func (WireMessage_builder) Build added in v5.4.0 

func (b0 WireMessage_builder) Build() *WireMessage

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.