Documentation ¶
Index ¶
- Constants
- Variables
- type BitToUserHandshake
- func (*BitToUserHandshake) Descriptor() ([]byte, []int)deprecated
- func (x *BitToUserHandshake) GetAuthenticationMechanisms() []string
- func (x *BitToUserHandshake) GetEncrypted() bool
- func (x *BitToUserHandshake) GetErrorId() string
- func (x *BitToUserHandshake) GetErrorMessage() string
- func (x *BitToUserHandshake) GetMaxWrappedSize() int32
- func (x *BitToUserHandshake) GetRpcVersion() int32
- func (x *BitToUserHandshake) GetServerInfos() *RpcEndpointInfos
- func (x *BitToUserHandshake) GetStatus() HandshakeStatus
- func (x *BitToUserHandshake) GetSupportedMethods() []RpcType
- func (*BitToUserHandshake) ProtoMessage()
- func (x *BitToUserHandshake) ProtoReflect() protoreflect.Message
- func (x *BitToUserHandshake) Reset()
- func (x *BitToUserHandshake) String() string
- type CatalogMetadata
- func (*CatalogMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CatalogMetadata) GetCatalogName() string
- func (x *CatalogMetadata) GetConnect() string
- func (x *CatalogMetadata) GetDescription() string
- func (*CatalogMetadata) ProtoMessage()
- func (x *CatalogMetadata) ProtoReflect() protoreflect.Message
- func (x *CatalogMetadata) Reset()
- func (x *CatalogMetadata) String() string
- type CollateSupport
- func (CollateSupport) Descriptor() protoreflect.EnumDescriptor
- func (x CollateSupport) Enum() *CollateSupport
- func (CollateSupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x CollateSupport) Number() protoreflect.EnumNumber
- func (x CollateSupport) String() string
- func (CollateSupport) Type() protoreflect.EnumType
- func (x *CollateSupport) UnmarshalJSON(b []byte) errordeprecated
- type ColumnMetadata
- func (*ColumnMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ColumnMetadata) GetCatalogName() string
- func (x *ColumnMetadata) GetCharMaxLength() int32
- func (x *ColumnMetadata) GetCharOctetLength() int32
- func (x *ColumnMetadata) GetColumnName() string
- func (x *ColumnMetadata) GetColumnSize() int32
- func (x *ColumnMetadata) GetDataType() string
- func (x *ColumnMetadata) GetDateTimePrecision() int32
- func (x *ColumnMetadata) GetDefaultValue() string
- func (x *ColumnMetadata) GetIntervalPrecision() int32
- func (x *ColumnMetadata) GetIntervalType() string
- func (x *ColumnMetadata) GetIsNullable() bool
- func (x *ColumnMetadata) GetNumericPrecision() int32
- func (x *ColumnMetadata) GetNumericPrecisionRadix() int32
- func (x *ColumnMetadata) GetNumericScale() int32
- func (x *ColumnMetadata) GetOrdinalPosition() int32
- func (x *ColumnMetadata) GetSchemaName() string
- func (x *ColumnMetadata) GetTableName() string
- func (*ColumnMetadata) ProtoMessage()
- func (x *ColumnMetadata) ProtoReflect() protoreflect.Message
- func (x *ColumnMetadata) Reset()
- func (x *ColumnMetadata) String() string
- type ColumnSearchability
- func (ColumnSearchability) Descriptor() protoreflect.EnumDescriptor
- func (x ColumnSearchability) Enum() *ColumnSearchability
- func (ColumnSearchability) EnumDescriptor() ([]byte, []int)deprecated
- func (x ColumnSearchability) Number() protoreflect.EnumNumber
- func (x ColumnSearchability) String() string
- func (ColumnSearchability) Type() protoreflect.EnumType
- func (x *ColumnSearchability) UnmarshalJSON(b []byte) errordeprecated
- type ColumnUpdatability
- func (ColumnUpdatability) Descriptor() protoreflect.EnumDescriptor
- func (x ColumnUpdatability) Enum() *ColumnUpdatability
- func (ColumnUpdatability) EnumDescriptor() ([]byte, []int)deprecated
- func (x ColumnUpdatability) Number() protoreflect.EnumNumber
- func (x ColumnUpdatability) String() string
- func (ColumnUpdatability) Type() protoreflect.EnumType
- func (x *ColumnUpdatability) UnmarshalJSON(b []byte) errordeprecated
- type ConvertSupport
- func (*ConvertSupport) Descriptor() ([]byte, []int)deprecated
- func (x *ConvertSupport) GetFrom() common.MinorType
- func (x *ConvertSupport) GetTo() common.MinorType
- func (*ConvertSupport) ProtoMessage()
- func (x *ConvertSupport) ProtoReflect() protoreflect.Message
- func (x *ConvertSupport) Reset()
- func (x *ConvertSupport) String() string
- type CorrelationNamesSupport
- func (CorrelationNamesSupport) Descriptor() protoreflect.EnumDescriptor
- func (x CorrelationNamesSupport) Enum() *CorrelationNamesSupport
- func (CorrelationNamesSupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x CorrelationNamesSupport) Number() protoreflect.EnumNumber
- func (x CorrelationNamesSupport) String() string
- func (CorrelationNamesSupport) Type() protoreflect.EnumType
- func (x *CorrelationNamesSupport) UnmarshalJSON(b []byte) errordeprecated
- type CreatePreparedStatementReq
- func (*CreatePreparedStatementReq) Descriptor() ([]byte, []int)deprecated
- func (x *CreatePreparedStatementReq) GetSqlQuery() string
- func (*CreatePreparedStatementReq) ProtoMessage()
- func (x *CreatePreparedStatementReq) ProtoReflect() protoreflect.Message
- func (x *CreatePreparedStatementReq) Reset()
- func (x *CreatePreparedStatementReq) String() string
- type CreatePreparedStatementResp
- func (*CreatePreparedStatementResp) Descriptor() ([]byte, []int)deprecated
- func (x *CreatePreparedStatementResp) GetError() *shared.DrillPBError
- func (x *CreatePreparedStatementResp) GetPreparedStatement() *PreparedStatement
- func (x *CreatePreparedStatementResp) GetStatus() RequestStatus
- func (*CreatePreparedStatementResp) ProtoMessage()
- func (x *CreatePreparedStatementResp) ProtoReflect() protoreflect.Message
- func (x *CreatePreparedStatementResp) Reset()
- func (x *CreatePreparedStatementResp) String() string
- type DateTimeLiteralsSupport
- func (DateTimeLiteralsSupport) Descriptor() protoreflect.EnumDescriptor
- func (x DateTimeLiteralsSupport) Enum() *DateTimeLiteralsSupport
- func (DateTimeLiteralsSupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x DateTimeLiteralsSupport) Number() protoreflect.EnumNumber
- func (x DateTimeLiteralsSupport) String() string
- func (DateTimeLiteralsSupport) Type() protoreflect.EnumType
- func (x *DateTimeLiteralsSupport) UnmarshalJSON(b []byte) errordeprecated
- type GetCatalogsReq
- type GetCatalogsResp
- func (*GetCatalogsResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetCatalogsResp) GetCatalogs() []*CatalogMetadata
- func (x *GetCatalogsResp) GetError() *shared.DrillPBError
- func (x *GetCatalogsResp) GetStatus() RequestStatus
- func (*GetCatalogsResp) ProtoMessage()
- func (x *GetCatalogsResp) ProtoReflect() protoreflect.Message
- func (x *GetCatalogsResp) Reset()
- func (x *GetCatalogsResp) String() string
- type GetColumnsReq
- func (*GetColumnsReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetColumnsReq) GetCatalogNameFilter() *LikeFilter
- func (x *GetColumnsReq) GetColumnNameFilter() *LikeFilter
- func (x *GetColumnsReq) GetSchemaNameFilter() *LikeFilter
- func (x *GetColumnsReq) GetTableNameFilter() *LikeFilter
- func (*GetColumnsReq) ProtoMessage()
- func (x *GetColumnsReq) ProtoReflect() protoreflect.Message
- func (x *GetColumnsReq) Reset()
- func (x *GetColumnsReq) String() string
- type GetColumnsResp
- func (*GetColumnsResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetColumnsResp) GetColumns() []*ColumnMetadata
- func (x *GetColumnsResp) GetError() *shared.DrillPBError
- func (x *GetColumnsResp) GetStatus() RequestStatus
- func (*GetColumnsResp) ProtoMessage()
- func (x *GetColumnsResp) ProtoReflect() protoreflect.Message
- func (x *GetColumnsResp) Reset()
- func (x *GetColumnsResp) String() string
- type GetQueryPlanFragments
- func (*GetQueryPlanFragments) Descriptor() ([]byte, []int)deprecated
- func (x *GetQueryPlanFragments) GetQuery() string
- func (x *GetQueryPlanFragments) GetSplitPlan() bool
- func (x *GetQueryPlanFragments) GetType() shared.QueryType
- func (*GetQueryPlanFragments) ProtoMessage()
- func (x *GetQueryPlanFragments) ProtoReflect() protoreflect.Message
- func (x *GetQueryPlanFragments) Reset()
- func (x *GetQueryPlanFragments) String() string
- type GetSchemasReq
- func (*GetSchemasReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemasReq) GetCatalogNameFilter() *LikeFilter
- func (x *GetSchemasReq) GetSchemaNameFilter() *LikeFilter
- func (*GetSchemasReq) ProtoMessage()
- func (x *GetSchemasReq) ProtoReflect() protoreflect.Message
- func (x *GetSchemasReq) Reset()
- func (x *GetSchemasReq) String() string
- type GetSchemasResp
- func (*GetSchemasResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemasResp) GetError() *shared.DrillPBError
- func (x *GetSchemasResp) GetSchemas() []*SchemaMetadata
- func (x *GetSchemasResp) GetStatus() RequestStatus
- func (*GetSchemasResp) ProtoMessage()
- func (x *GetSchemasResp) ProtoReflect() protoreflect.Message
- func (x *GetSchemasResp) Reset()
- func (x *GetSchemasResp) String() string
- type GetServerMetaReq
- type GetServerMetaResp
- func (*GetServerMetaResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetServerMetaResp) GetError() *shared.DrillPBError
- func (x *GetServerMetaResp) GetServerMeta() *ServerMeta
- func (x *GetServerMetaResp) GetStatus() RequestStatus
- func (*GetServerMetaResp) ProtoMessage()
- func (x *GetServerMetaResp) ProtoReflect() protoreflect.Message
- func (x *GetServerMetaResp) Reset()
- func (x *GetServerMetaResp) String() string
- type GetTablesReq
- func (*GetTablesReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetTablesReq) GetCatalogNameFilter() *LikeFilter
- func (x *GetTablesReq) GetSchemaNameFilter() *LikeFilter
- func (x *GetTablesReq) GetTableNameFilter() *LikeFilter
- func (x *GetTablesReq) GetTableTypeFilter() []string
- func (*GetTablesReq) ProtoMessage()
- func (x *GetTablesReq) ProtoReflect() protoreflect.Message
- func (x *GetTablesReq) Reset()
- func (x *GetTablesReq) String() string
- type GetTablesResp
- func (*GetTablesResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetTablesResp) GetError() *shared.DrillPBError
- func (x *GetTablesResp) GetStatus() RequestStatus
- func (x *GetTablesResp) GetTables() []*TableMetadata
- func (*GetTablesResp) ProtoMessage()
- func (x *GetTablesResp) ProtoReflect() protoreflect.Message
- func (x *GetTablesResp) Reset()
- func (x *GetTablesResp) String() string
- type GroupBySupport
- func (GroupBySupport) Descriptor() protoreflect.EnumDescriptor
- func (x GroupBySupport) Enum() *GroupBySupport
- func (GroupBySupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x GroupBySupport) Number() protoreflect.EnumNumber
- func (x GroupBySupport) String() string
- func (GroupBySupport) Type() protoreflect.EnumType
- func (x *GroupBySupport) UnmarshalJSON(b []byte) errordeprecated
- type HandshakeStatus
- func (HandshakeStatus) Descriptor() protoreflect.EnumDescriptor
- func (x HandshakeStatus) Enum() *HandshakeStatus
- func (HandshakeStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x HandshakeStatus) Number() protoreflect.EnumNumber
- func (x HandshakeStatus) String() string
- func (HandshakeStatus) Type() protoreflect.EnumType
- func (x *HandshakeStatus) UnmarshalJSON(b []byte) errordeprecated
- type IdentifierCasing
- func (IdentifierCasing) Descriptor() protoreflect.EnumDescriptor
- func (x IdentifierCasing) Enum() *IdentifierCasing
- func (IdentifierCasing) EnumDescriptor() ([]byte, []int)deprecated
- func (x IdentifierCasing) Number() protoreflect.EnumNumber
- func (x IdentifierCasing) String() string
- func (IdentifierCasing) Type() protoreflect.EnumType
- func (x *IdentifierCasing) UnmarshalJSON(b []byte) errordeprecated
- type LikeFilter
- type NullCollation
- func (NullCollation) Descriptor() protoreflect.EnumDescriptor
- func (x NullCollation) Enum() *NullCollation
- func (NullCollation) EnumDescriptor() ([]byte, []int)deprecated
- func (x NullCollation) Number() protoreflect.EnumNumber
- func (x NullCollation) String() string
- func (NullCollation) Type() protoreflect.EnumType
- func (x *NullCollation) UnmarshalJSON(b []byte) errordeprecated
- type OrderBySupport
- func (OrderBySupport) Descriptor() protoreflect.EnumDescriptor
- func (x OrderBySupport) Enum() *OrderBySupport
- func (OrderBySupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x OrderBySupport) Number() protoreflect.EnumNumber
- func (x OrderBySupport) String() string
- func (OrderBySupport) Type() protoreflect.EnumType
- func (x *OrderBySupport) UnmarshalJSON(b []byte) errordeprecated
- type OuterJoinSupport
- func (OuterJoinSupport) Descriptor() protoreflect.EnumDescriptor
- func (x OuterJoinSupport) Enum() *OuterJoinSupport
- func (OuterJoinSupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x OuterJoinSupport) Number() protoreflect.EnumNumber
- func (x OuterJoinSupport) String() string
- func (OuterJoinSupport) Type() protoreflect.EnumType
- func (x *OuterJoinSupport) UnmarshalJSON(b []byte) errordeprecated
- type PreparedStatement
- func (*PreparedStatement) Descriptor() ([]byte, []int)deprecated
- func (x *PreparedStatement) GetColumns() []*ResultColumnMetadata
- func (x *PreparedStatement) GetServerHandle() *PreparedStatementHandle
- func (*PreparedStatement) ProtoMessage()
- func (x *PreparedStatement) ProtoReflect() protoreflect.Message
- func (x *PreparedStatement) Reset()
- func (x *PreparedStatement) String() string
- type PreparedStatementHandle
- func (*PreparedStatementHandle) Descriptor() ([]byte, []int)deprecated
- func (x *PreparedStatementHandle) GetServerInfo() []byte
- func (*PreparedStatementHandle) ProtoMessage()
- func (x *PreparedStatementHandle) ProtoReflect() protoreflect.Message
- func (x *PreparedStatementHandle) Reset()
- func (x *PreparedStatementHandle) String() string
- type Property
- type QueryPlanFragments
- func (*QueryPlanFragments) Descriptor() ([]byte, []int)deprecated
- func (x *QueryPlanFragments) GetError() *shared.DrillPBError
- func (x *QueryPlanFragments) GetFragments() []*control.PlanFragment
- func (x *QueryPlanFragments) GetQueryId() *shared.QueryId
- func (x *QueryPlanFragments) GetStatus() shared.QueryResult_QueryState
- func (*QueryPlanFragments) ProtoMessage()
- func (x *QueryPlanFragments) ProtoReflect() protoreflect.Message
- func (x *QueryPlanFragments) Reset()
- func (x *QueryPlanFragments) String() string
- type QueryResultsMode
- func (QueryResultsMode) Descriptor() protoreflect.EnumDescriptor
- func (x QueryResultsMode) Enum() *QueryResultsMode
- func (QueryResultsMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x QueryResultsMode) Number() protoreflect.EnumNumber
- func (x QueryResultsMode) String() string
- func (QueryResultsMode) Type() protoreflect.EnumType
- func (x *QueryResultsMode) UnmarshalJSON(b []byte) errordeprecated
- type RequestResults
- func (*RequestResults) Descriptor() ([]byte, []int)deprecated
- func (x *RequestResults) GetMaximumResponses() int32
- func (x *RequestResults) GetQueryId() *shared.QueryId
- func (*RequestResults) ProtoMessage()
- func (x *RequestResults) ProtoReflect() protoreflect.Message
- func (x *RequestResults) Reset()
- func (x *RequestResults) String() string
- type RequestStatus
- func (RequestStatus) Descriptor() protoreflect.EnumDescriptor
- func (x RequestStatus) Enum() *RequestStatus
- func (RequestStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x RequestStatus) Number() protoreflect.EnumNumber
- func (x RequestStatus) String() string
- func (RequestStatus) Type() protoreflect.EnumType
- func (x *RequestStatus) UnmarshalJSON(b []byte) errordeprecated
- type ResultColumnMetadata
- func (*ResultColumnMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ResultColumnMetadata) GetAutoIncrement() bool
- func (x *ResultColumnMetadata) GetCaseSensitivity() bool
- func (x *ResultColumnMetadata) GetCatalogName() string
- func (x *ResultColumnMetadata) GetClassName() string
- func (x *ResultColumnMetadata) GetColumnName() string
- func (x *ResultColumnMetadata) GetDataType() string
- func (x *ResultColumnMetadata) GetDisplaySize() int32
- func (x *ResultColumnMetadata) GetIsAliased() bool
- func (x *ResultColumnMetadata) GetIsCurrency() bool
- func (x *ResultColumnMetadata) GetIsNullable() bool
- func (x *ResultColumnMetadata) GetLabel() string
- func (x *ResultColumnMetadata) GetPrecision() int32
- func (x *ResultColumnMetadata) GetScale() int32
- func (x *ResultColumnMetadata) GetSchemaName() string
- func (x *ResultColumnMetadata) GetSearchability() ColumnSearchability
- func (x *ResultColumnMetadata) GetSigned() bool
- func (x *ResultColumnMetadata) GetSortable() bool
- func (x *ResultColumnMetadata) GetTableName() string
- func (x *ResultColumnMetadata) GetUpdatability() ColumnUpdatability
- func (*ResultColumnMetadata) ProtoMessage()
- func (x *ResultColumnMetadata) ProtoReflect() protoreflect.Message
- func (x *ResultColumnMetadata) Reset()
- func (x *ResultColumnMetadata) String() string
- type RpcEndpointInfos
- func (*RpcEndpointInfos) Descriptor() ([]byte, []int)deprecated
- func (x *RpcEndpointInfos) GetApplication() string
- func (x *RpcEndpointInfos) GetBuildNumber() uint32
- func (x *RpcEndpointInfos) GetMajorVersion() uint32
- func (x *RpcEndpointInfos) GetMinorVersion() uint32
- func (x *RpcEndpointInfos) GetName() string
- func (x *RpcEndpointInfos) GetPatchVersion() uint32
- func (x *RpcEndpointInfos) GetVersion() string
- func (x *RpcEndpointInfos) GetVersionQualifier() string
- func (*RpcEndpointInfos) ProtoMessage()
- func (x *RpcEndpointInfos) ProtoReflect() protoreflect.Message
- func (x *RpcEndpointInfos) Reset()
- func (x *RpcEndpointInfos) String() string
- type RpcType
- func (RpcType) Descriptor() protoreflect.EnumDescriptor
- func (x RpcType) Enum() *RpcType
- func (RpcType) EnumDescriptor() ([]byte, []int)deprecated
- func (x RpcType) Number() protoreflect.EnumNumber
- func (x RpcType) String() string
- func (RpcType) Type() protoreflect.EnumType
- func (x *RpcType) UnmarshalJSON(b []byte) errordeprecated
- type RunQuery
- func (*RunQuery) Descriptor() ([]byte, []int)deprecated
- func (x *RunQuery) GetAutolimitRowcount() int32
- func (x *RunQuery) GetFragments() []*control.PlanFragment
- func (x *RunQuery) GetPlan() string
- func (x *RunQuery) GetPreparedStatementHandle() *PreparedStatementHandle
- func (x *RunQuery) GetResultsMode() QueryResultsMode
- func (x *RunQuery) GetType() shared.QueryType
- func (*RunQuery) ProtoMessage()
- func (x *RunQuery) ProtoReflect() protoreflect.Message
- func (x *RunQuery) Reset()
- func (x *RunQuery) String() string
- type SaslSupport
- func (SaslSupport) Descriptor() protoreflect.EnumDescriptor
- func (x SaslSupport) Enum() *SaslSupport
- func (SaslSupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x SaslSupport) Number() protoreflect.EnumNumber
- func (x SaslSupport) String() string
- func (SaslSupport) Type() protoreflect.EnumType
- func (x *SaslSupport) UnmarshalJSON(b []byte) errordeprecated
- type SchemaMetadata
- func (*SchemaMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *SchemaMetadata) GetCatalogName() string
- func (x *SchemaMetadata) GetMutable() string
- func (x *SchemaMetadata) GetOwner() string
- func (x *SchemaMetadata) GetSchemaName() string
- func (x *SchemaMetadata) GetType() string
- func (*SchemaMetadata) ProtoMessage()
- func (x *SchemaMetadata) ProtoReflect() protoreflect.Message
- func (x *SchemaMetadata) Reset()
- func (x *SchemaMetadata) String() string
- type ServerMeta
- func (*ServerMeta) Descriptor() ([]byte, []int)deprecated
- func (x *ServerMeta) GetAllTablesSelectable() bool
- func (x *ServerMeta) GetBlobIncludedInMaxRowSize() bool
- func (x *ServerMeta) GetCatalogAtStart() bool
- func (x *ServerMeta) GetCatalogSeparator() string
- func (x *ServerMeta) GetCatalogTerm() string
- func (x *ServerMeta) GetCollateSupport() []CollateSupport
- func (x *ServerMeta) GetColumnAliasingSupported() bool
- func (x *ServerMeta) GetConvertSupport() []*ConvertSupport
- func (x *ServerMeta) GetCorrelationNamesSupport() CorrelationNamesSupport
- func (x *ServerMeta) GetCurrentSchema() string
- func (x *ServerMeta) GetDateTimeFunctions() []string
- func (x *ServerMeta) GetDateTimeLiteralsSupport() []DateTimeLiteralsSupport
- func (x *ServerMeta) GetGroupBySupport() GroupBySupport
- func (x *ServerMeta) GetIdentifierCasing() IdentifierCasing
- func (x *ServerMeta) GetIdentifierQuoteString() string
- func (x *ServerMeta) GetLikeEscapeClauseSupported() bool
- func (x *ServerMeta) GetMaxBinaryLiteralLength() uint32
- func (x *ServerMeta) GetMaxCatalogNameLength() uint32
- func (x *ServerMeta) GetMaxCharLiteralLength() uint32
- func (x *ServerMeta) GetMaxColumnNameLength() uint32
- func (x *ServerMeta) GetMaxColumnsInGroupBy() uint32
- func (x *ServerMeta) GetMaxColumnsInOrderBy() uint32
- func (x *ServerMeta) GetMaxColumnsInSelect() uint32
- func (x *ServerMeta) GetMaxCursorNameLength() uint32
- func (x *ServerMeta) GetMaxLogicalLobSize() uint32
- func (x *ServerMeta) GetMaxRowSize() uint32
- func (x *ServerMeta) GetMaxSchemaNameLength() uint32
- func (x *ServerMeta) GetMaxStatementLength() uint32
- func (x *ServerMeta) GetMaxStatements() uint32
- func (x *ServerMeta) GetMaxTableNameLength() uint32
- func (x *ServerMeta) GetMaxTablesInSelect() uint32
- func (x *ServerMeta) GetMaxUserNameLength() uint32
- func (x *ServerMeta) GetNullCollation() NullCollation
- func (x *ServerMeta) GetNullPlusNonNullEqualsNull() bool
- func (x *ServerMeta) GetNumericFunctions() []string
- func (x *ServerMeta) GetOrderBySupport() []OrderBySupport
- func (x *ServerMeta) GetOuterJoinSupport() []OuterJoinSupport
- func (x *ServerMeta) GetQuotedIdentifierCasing() IdentifierCasing
- func (x *ServerMeta) GetReadOnly() bool
- func (x *ServerMeta) GetSchemaTerm() string
- func (x *ServerMeta) GetSearchEscapeString() string
- func (x *ServerMeta) GetSelectForUpdateSupported() bool
- func (x *ServerMeta) GetSpecialCharacters() string
- func (x *ServerMeta) GetSqlKeywords() []string
- func (x *ServerMeta) GetStringFunctions() []string
- func (x *ServerMeta) GetSubquerySupport() []SubQuerySupport
- func (x *ServerMeta) GetSystemFunctions() []string
- func (x *ServerMeta) GetTableTerm() string
- func (x *ServerMeta) GetTransactionSupported() bool
- func (x *ServerMeta) GetUnionSupport() []UnionSupport
- func (*ServerMeta) ProtoMessage()
- func (x *ServerMeta) ProtoReflect() protoreflect.Message
- func (x *ServerMeta) Reset()
- func (x *ServerMeta) String() string
- type SubQuerySupport
- func (SubQuerySupport) Descriptor() protoreflect.EnumDescriptor
- func (x SubQuerySupport) Enum() *SubQuerySupport
- func (SubQuerySupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubQuerySupport) Number() protoreflect.EnumNumber
- func (x SubQuerySupport) String() string
- func (SubQuerySupport) Type() protoreflect.EnumType
- func (x *SubQuerySupport) UnmarshalJSON(b []byte) errordeprecated
- type TableMetadata
- func (*TableMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TableMetadata) GetCatalogName() string
- func (x *TableMetadata) GetSchemaName() string
- func (x *TableMetadata) GetTableName() string
- func (x *TableMetadata) GetType() string
- func (*TableMetadata) ProtoMessage()
- func (x *TableMetadata) ProtoReflect() protoreflect.Message
- func (x *TableMetadata) Reset()
- func (x *TableMetadata) String() string
- type UnionSupport
- func (UnionSupport) Descriptor() protoreflect.EnumDescriptor
- func (x UnionSupport) Enum() *UnionSupport
- func (UnionSupport) EnumDescriptor() ([]byte, []int)deprecated
- func (x UnionSupport) Number() protoreflect.EnumNumber
- func (x UnionSupport) String() string
- func (UnionSupport) Type() protoreflect.EnumType
- func (x *UnionSupport) UnmarshalJSON(b []byte) errordeprecated
- type UserProperties
- type UserToBitHandshake
- func (*UserToBitHandshake) Descriptor() ([]byte, []int)deprecated
- func (x *UserToBitHandshake) GetChannel() shared.RpcChannel
- func (x *UserToBitHandshake) GetClientInfos() *RpcEndpointInfos
- func (x *UserToBitHandshake) GetCredentials() *shared.UserCredentials
- func (x *UserToBitHandshake) GetProperties() *UserProperties
- func (x *UserToBitHandshake) GetRpcVersion() int32
- func (x *UserToBitHandshake) GetSaslSupport() SaslSupport
- func (x *UserToBitHandshake) GetSupportComplexTypes() bool
- func (x *UserToBitHandshake) GetSupportListening() bool
- func (x *UserToBitHandshake) GetSupportTimeout() bool
- func (*UserToBitHandshake) ProtoMessage()
- func (x *UserToBitHandshake) ProtoReflect() protoreflect.Message
- func (x *UserToBitHandshake) Reset()
- func (x *UserToBitHandshake) String() string
Constants ¶
const ( Default_UserToBitHandshake_Channel = shared.RpcChannel_USER Default_UserToBitHandshake_SupportComplexTypes = bool(false) Default_UserToBitHandshake_SupportTimeout = bool(false) )
Default values for UserToBitHandshake fields.
const (
Default_GetQueryPlanFragments_SplitPlan = bool(false)
)
Default values for GetQueryPlanFragments fields.
Variables ¶
var ( RpcType_name = map[int32]string{ 0: "HANDSHAKE", 1: "ACK", 2: "GOODBYE", 3: "RUN_QUERY", 4: "CANCEL_QUERY", 5: "REQUEST_RESULTS", 11: "RESUME_PAUSED_QUERY", 12: "GET_QUERY_PLAN_FRAGMENTS", 14: "GET_CATALOGS", 15: "GET_SCHEMAS", 16: "GET_TABLES", 17: "GET_COLUMNS", 22: "CREATE_PREPARED_STATEMENT", 8: "GET_SERVER_META", 6: "QUERY_DATA", 7: "QUERY_HANDLE", 13: "QUERY_PLAN_FRAGMENTS", 18: "CATALOGS", 19: "SCHEMAS", 20: "TABLES", 21: "COLUMNS", 23: "PREPARED_STATEMENT", 9: "SERVER_META", 10: "QUERY_RESULT", 24: "SASL_MESSAGE", } RpcType_value = map[string]int32{ "HANDSHAKE": 0, "ACK": 1, "GOODBYE": 2, "RUN_QUERY": 3, "CANCEL_QUERY": 4, "REQUEST_RESULTS": 5, "RESUME_PAUSED_QUERY": 11, "GET_QUERY_PLAN_FRAGMENTS": 12, "GET_CATALOGS": 14, "GET_SCHEMAS": 15, "GET_TABLES": 16, "GET_COLUMNS": 17, "CREATE_PREPARED_STATEMENT": 22, "GET_SERVER_META": 8, "QUERY_DATA": 6, "QUERY_HANDLE": 7, "QUERY_PLAN_FRAGMENTS": 13, "CATALOGS": 18, "SCHEMAS": 19, "TABLES": 20, "COLUMNS": 21, "PREPARED_STATEMENT": 23, "SERVER_META": 9, "QUERY_RESULT": 10, "SASL_MESSAGE": 24, } )
Enum value maps for RpcType.
var ( SaslSupport_name = map[int32]string{ 0: "UNKNOWN_SASL_SUPPORT", 1: "SASL_AUTH", 2: "SASL_PRIVACY", } SaslSupport_value = map[string]int32{ "UNKNOWN_SASL_SUPPORT": 0, "SASL_AUTH": 1, "SASL_PRIVACY": 2, } )
Enum value maps for SaslSupport.
var ( QueryResultsMode_name = map[int32]string{ 1: "STREAM_FULL", } QueryResultsMode_value = map[string]int32{ "STREAM_FULL": 1, } )
Enum value maps for QueryResultsMode.
var ( HandshakeStatus_name = map[int32]string{ 1: "SUCCESS", 2: "RPC_VERSION_MISMATCH", 3: "AUTH_FAILED", 4: "UNKNOWN_FAILURE", 5: "AUTH_REQUIRED", } HandshakeStatus_value = map[string]int32{ "SUCCESS": 1, "RPC_VERSION_MISMATCH": 2, "AUTH_FAILED": 3, "UNKNOWN_FAILURE": 4, "AUTH_REQUIRED": 5, } )
Enum value maps for HandshakeStatus.
var ( RequestStatus_name = map[int32]string{ 0: "UNKNOWN_STATUS", 1: "OK", 2: "FAILED", 3: "TIMEOUT", } RequestStatus_value = map[string]int32{ "UNKNOWN_STATUS": 0, "OK": 1, "FAILED": 2, "TIMEOUT": 3, } )
Enum value maps for RequestStatus.
var ( ColumnSearchability_name = map[int32]string{ 0: "UNKNOWN_SEARCHABILITY", 1: "NONE", 2: "CHAR", 3: "NUMBER", 4: "ALL", } ColumnSearchability_value = map[string]int32{ "UNKNOWN_SEARCHABILITY": 0, "NONE": 1, "CHAR": 2, "NUMBER": 3, "ALL": 4, } )
Enum value maps for ColumnSearchability.
var ( ColumnUpdatability_name = map[int32]string{ 0: "UNKNOWN_UPDATABILITY", 1: "READ_ONLY", 2: "WRITABLE", } ColumnUpdatability_value = map[string]int32{ "UNKNOWN_UPDATABILITY": 0, "READ_ONLY": 1, "WRITABLE": 2, } )
Enum value maps for ColumnUpdatability.
var ( CollateSupport_name = map[int32]string{ 0: "CS_UNKNOWN", 1: "CS_GROUP_BY", } CollateSupport_value = map[string]int32{ "CS_UNKNOWN": 0, "CS_GROUP_BY": 1, } )
Enum value maps for CollateSupport.
var ( CorrelationNamesSupport_name = map[int32]string{ 1: "CN_NONE", 2: "CN_DIFFERENT_NAMES", 3: "CN_ANY", } CorrelationNamesSupport_value = map[string]int32{ "CN_NONE": 1, "CN_DIFFERENT_NAMES": 2, "CN_ANY": 3, } )
Enum value maps for CorrelationNamesSupport.
var ( DateTimeLiteralsSupport_name = map[int32]string{ 0: "DL_UNKNOWN", 1: "DL_DATE", 2: "DL_TIME", 3: "DL_TIMESTAMP", 4: "DL_INTERVAL_YEAR", 5: "DL_INTERVAL_MONTH", 6: "DL_INTERVAL_DAY", 7: "DL_INTERVAL_HOUR", 8: "DL_INTERVAL_MINUTE", 9: "DL_INTERVAL_SECOND", 10: "DL_INTERVAL_YEAR_TO_MONTH", 11: "DL_INTERVAL_DAY_TO_HOUR", 12: "DL_INTERVAL_DAY_TO_MINUTE", 13: "DL_INTERVAL_DAY_TO_SECOND", 14: "DL_INTERVAL_HOUR_TO_MINUTE", 15: "DL_INTERVAL_HOUR_TO_SECOND", 16: "DL_INTERVAL_MINUTE_TO_SECOND", } DateTimeLiteralsSupport_value = map[string]int32{ "DL_UNKNOWN": 0, "DL_DATE": 1, "DL_TIME": 2, "DL_TIMESTAMP": 3, "DL_INTERVAL_YEAR": 4, "DL_INTERVAL_MONTH": 5, "DL_INTERVAL_DAY": 6, "DL_INTERVAL_HOUR": 7, "DL_INTERVAL_MINUTE": 8, "DL_INTERVAL_SECOND": 9, "DL_INTERVAL_YEAR_TO_MONTH": 10, "DL_INTERVAL_DAY_TO_HOUR": 11, "DL_INTERVAL_DAY_TO_MINUTE": 12, "DL_INTERVAL_DAY_TO_SECOND": 13, "DL_INTERVAL_HOUR_TO_MINUTE": 14, "DL_INTERVAL_HOUR_TO_SECOND": 15, "DL_INTERVAL_MINUTE_TO_SECOND": 16, } )
Enum value maps for DateTimeLiteralsSupport.
var ( GroupBySupport_name = map[int32]string{ 1: "GB_NONE", 2: "GB_SELECT_ONLY", 3: "GB_BEYOND_SELECT", 4: "GB_UNRELATED", } GroupBySupport_value = map[string]int32{ "GB_NONE": 1, "GB_SELECT_ONLY": 2, "GB_BEYOND_SELECT": 3, "GB_UNRELATED": 4, } )
Enum value maps for GroupBySupport.
var ( IdentifierCasing_name = map[int32]string{ 0: "IC_UNKNOWN", 1: "IC_STORES_LOWER", 2: "IC_STORES_MIXED", 3: "IC_STORES_UPPER", 4: "IC_SUPPORTS_MIXED", } IdentifierCasing_value = map[string]int32{ "IC_UNKNOWN": 0, "IC_STORES_LOWER": 1, "IC_STORES_MIXED": 2, "IC_STORES_UPPER": 3, "IC_SUPPORTS_MIXED": 4, } )
Enum value maps for IdentifierCasing.
var ( NullCollation_name = map[int32]string{ 0: "NC_UNKNOWN", 1: "NC_AT_START", 2: "NC_AT_END", 3: "NC_HIGH", 4: "NC_LOW", } NullCollation_value = map[string]int32{ "NC_UNKNOWN": 0, "NC_AT_START": 1, "NC_AT_END": 2, "NC_HIGH": 3, "NC_LOW": 4, } )
Enum value maps for NullCollation.
var ( OrderBySupport_name = map[int32]string{ 0: "OB_UNKNOWN", 1: "OB_UNRELATED", 2: "OB_EXPRESSION", } OrderBySupport_value = map[string]int32{ "OB_UNKNOWN": 0, "OB_UNRELATED": 1, "OB_EXPRESSION": 2, } )
Enum value maps for OrderBySupport.
var ( OuterJoinSupport_name = map[int32]string{ 0: "OJ_UNKNOWN", 1: "OJ_LEFT", 2: "OJ_RIGHT", 3: "OJ_FULL", 4: "OJ_NESTED", 5: "OJ_NOT_ORDERED", 6: "OJ_INNER", 7: "OJ_ALL_COMPARISON_OPS", } OuterJoinSupport_value = map[string]int32{ "OJ_UNKNOWN": 0, "OJ_LEFT": 1, "OJ_RIGHT": 2, "OJ_FULL": 3, "OJ_NESTED": 4, "OJ_NOT_ORDERED": 5, "OJ_INNER": 6, "OJ_ALL_COMPARISON_OPS": 7, } )
Enum value maps for OuterJoinSupport.
var ( SubQuerySupport_name = map[int32]string{ 0: "SQ_UNKNOWN", 1: "SQ_CORRELATED", 2: "SQ_IN_COMPARISON", 3: "SQ_IN_EXISTS", 4: "SQ_IN_INSERT", 5: "SQ_IN_QUANTIFIED", } SubQuerySupport_value = map[string]int32{ "SQ_UNKNOWN": 0, "SQ_CORRELATED": 1, "SQ_IN_COMPARISON": 2, "SQ_IN_EXISTS": 3, "SQ_IN_INSERT": 4, "SQ_IN_QUANTIFIED": 5, } )
Enum value maps for SubQuerySupport.
var ( UnionSupport_name = map[int32]string{ 0: "U_UNKNOWN", 1: "U_UNION", 2: "U_UNION_ALL", } UnionSupport_value = map[string]int32{ "U_UNKNOWN": 0, "U_UNION": 1, "U_UNION_ALL": 2, } )
Enum value maps for UnionSupport.
var File_User_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BitToUserHandshake ¶
type BitToUserHandshake struct { RpcVersion *int32 `protobuf:"varint,2,opt,name=rpc_version,json=rpcVersion" json:"rpc_version,omitempty"` Status *HandshakeStatus `protobuf:"varint,3,opt,name=status,enum=exec.user.HandshakeStatus" json:"status,omitempty"` ErrorId *string `protobuf:"bytes,4,opt,name=errorId" json:"errorId,omitempty"` ErrorMessage *string `protobuf:"bytes,5,opt,name=errorMessage" json:"errorMessage,omitempty"` ServerInfos *RpcEndpointInfos `protobuf:"bytes,6,opt,name=server_infos,json=serverInfos" json:"server_infos,omitempty"` AuthenticationMechanisms []string `protobuf:"bytes,7,rep,name=authenticationMechanisms" json:"authenticationMechanisms,omitempty"` SupportedMethods []RpcType `` /* 126-byte string literal not displayed */ Encrypted *bool `protobuf:"varint,9,opt,name=encrypted" json:"encrypted,omitempty"` MaxWrappedSize *int32 `protobuf:"varint,10,opt,name=maxWrappedSize" json:"maxWrappedSize,omitempty"` // contains filtered or unexported fields }
func (*BitToUserHandshake) Descriptor
deprecated
func (*BitToUserHandshake) Descriptor() ([]byte, []int)
Deprecated: Use BitToUserHandshake.ProtoReflect.Descriptor instead.
func (*BitToUserHandshake) GetAuthenticationMechanisms ¶
func (x *BitToUserHandshake) GetAuthenticationMechanisms() []string
func (*BitToUserHandshake) GetEncrypted ¶
func (x *BitToUserHandshake) GetEncrypted() bool
func (*BitToUserHandshake) GetErrorId ¶
func (x *BitToUserHandshake) GetErrorId() string
func (*BitToUserHandshake) GetErrorMessage ¶
func (x *BitToUserHandshake) GetErrorMessage() string
func (*BitToUserHandshake) GetMaxWrappedSize ¶
func (x *BitToUserHandshake) GetMaxWrappedSize() int32
func (*BitToUserHandshake) GetRpcVersion ¶
func (x *BitToUserHandshake) GetRpcVersion() int32
func (*BitToUserHandshake) GetServerInfos ¶
func (x *BitToUserHandshake) GetServerInfos() *RpcEndpointInfos
func (*BitToUserHandshake) GetStatus ¶
func (x *BitToUserHandshake) GetStatus() HandshakeStatus
func (*BitToUserHandshake) GetSupportedMethods ¶
func (x *BitToUserHandshake) GetSupportedMethods() []RpcType
func (*BitToUserHandshake) ProtoMessage ¶
func (*BitToUserHandshake) ProtoMessage()
func (*BitToUserHandshake) ProtoReflect ¶
func (x *BitToUserHandshake) ProtoReflect() protoreflect.Message
func (*BitToUserHandshake) Reset ¶
func (x *BitToUserHandshake) Reset()
func (*BitToUserHandshake) String ¶
func (x *BitToUserHandshake) String() string
type CatalogMetadata ¶
type CatalogMetadata struct { CatalogName *string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName" json:"catalog_name,omitempty"` Description *string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"` Connect *string `protobuf:"bytes,3,opt,name=connect" json:"connect,omitempty"` // contains filtered or unexported fields }
Message encapsulating metadata for a Catalog.
func (*CatalogMetadata) Descriptor
deprecated
func (*CatalogMetadata) Descriptor() ([]byte, []int)
Deprecated: Use CatalogMetadata.ProtoReflect.Descriptor instead.
func (*CatalogMetadata) GetCatalogName ¶
func (x *CatalogMetadata) GetCatalogName() string
func (*CatalogMetadata) GetConnect ¶
func (x *CatalogMetadata) GetConnect() string
func (*CatalogMetadata) GetDescription ¶
func (x *CatalogMetadata) GetDescription() string
func (*CatalogMetadata) ProtoMessage ¶
func (*CatalogMetadata) ProtoMessage()
func (*CatalogMetadata) ProtoReflect ¶
func (x *CatalogMetadata) ProtoReflect() protoreflect.Message
func (*CatalogMetadata) Reset ¶
func (x *CatalogMetadata) Reset()
func (*CatalogMetadata) String ¶
func (x *CatalogMetadata) String() string
type CollateSupport ¶
type CollateSupport int32
const ( CollateSupport_CS_UNKNOWN CollateSupport = 0 // Unknown support (for forward compatibility) CollateSupport_CS_GROUP_BY CollateSupport = 1 // COLLATE clause can be added after each grouping column )
func (CollateSupport) Descriptor ¶
func (CollateSupport) Descriptor() protoreflect.EnumDescriptor
func (CollateSupport) Enum ¶
func (x CollateSupport) Enum() *CollateSupport
func (CollateSupport) EnumDescriptor
deprecated
func (CollateSupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use CollateSupport.Descriptor instead.
func (CollateSupport) Number ¶
func (x CollateSupport) Number() protoreflect.EnumNumber
func (CollateSupport) String ¶
func (x CollateSupport) String() string
func (CollateSupport) Type ¶
func (CollateSupport) Type() protoreflect.EnumType
func (*CollateSupport) UnmarshalJSON
deprecated
func (x *CollateSupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type ColumnMetadata ¶
type ColumnMetadata struct { CatalogName *string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName" json:"catalog_name,omitempty"` SchemaName *string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName" json:"schema_name,omitempty"` TableName *string `protobuf:"bytes,3,opt,name=table_name,json=tableName" json:"table_name,omitempty"` ColumnName *string `protobuf:"bytes,4,opt,name=column_name,json=columnName" json:"column_name,omitempty"` OrdinalPosition *int32 `protobuf:"varint,5,opt,name=ordinal_position,json=ordinalPosition" json:"ordinal_position,omitempty"` DefaultValue *string `protobuf:"bytes,6,opt,name=default_value,json=defaultValue" json:"default_value,omitempty"` IsNullable *bool `protobuf:"varint,7,opt,name=is_nullable,json=isNullable" json:"is_nullable,omitempty"` DataType *string `protobuf:"bytes,8,opt,name=data_type,json=dataType" json:"data_type,omitempty"` CharMaxLength *int32 `protobuf:"varint,9,opt,name=char_max_length,json=charMaxLength" json:"char_max_length,omitempty"` CharOctetLength *int32 `protobuf:"varint,10,opt,name=char_octet_length,json=charOctetLength" json:"char_octet_length,omitempty"` NumericPrecision *int32 `protobuf:"varint,11,opt,name=numeric_precision,json=numericPrecision" json:"numeric_precision,omitempty"` NumericPrecisionRadix *int32 `protobuf:"varint,12,opt,name=numeric_precision_radix,json=numericPrecisionRadix" json:"numeric_precision_radix,omitempty"` NumericScale *int32 `protobuf:"varint,13,opt,name=numeric_scale,json=numericScale" json:"numeric_scale,omitempty"` DateTimePrecision *int32 `protobuf:"varint,14,opt,name=date_time_precision,json=dateTimePrecision" json:"date_time_precision,omitempty"` IntervalType *string `protobuf:"bytes,15,opt,name=interval_type,json=intervalType" json:"interval_type,omitempty"` IntervalPrecision *int32 `protobuf:"varint,16,opt,name=interval_precision,json=intervalPrecision" json:"interval_precision,omitempty"` ColumnSize *int32 `protobuf:"varint,17,opt,name=column_size,json=columnSize" json:"column_size,omitempty"` // contains filtered or unexported fields }
Message encapsulating metadata for a Column.
func (*ColumnMetadata) Descriptor
deprecated
func (*ColumnMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ColumnMetadata.ProtoReflect.Descriptor instead.
func (*ColumnMetadata) GetCatalogName ¶
func (x *ColumnMetadata) GetCatalogName() string
func (*ColumnMetadata) GetCharMaxLength ¶
func (x *ColumnMetadata) GetCharMaxLength() int32
func (*ColumnMetadata) GetCharOctetLength ¶
func (x *ColumnMetadata) GetCharOctetLength() int32
func (*ColumnMetadata) GetColumnName ¶
func (x *ColumnMetadata) GetColumnName() string
func (*ColumnMetadata) GetColumnSize ¶
func (x *ColumnMetadata) GetColumnSize() int32
func (*ColumnMetadata) GetDataType ¶
func (x *ColumnMetadata) GetDataType() string
func (*ColumnMetadata) GetDateTimePrecision ¶
func (x *ColumnMetadata) GetDateTimePrecision() int32
func (*ColumnMetadata) GetDefaultValue ¶
func (x *ColumnMetadata) GetDefaultValue() string
func (*ColumnMetadata) GetIntervalPrecision ¶
func (x *ColumnMetadata) GetIntervalPrecision() int32
func (*ColumnMetadata) GetIntervalType ¶
func (x *ColumnMetadata) GetIntervalType() string
func (*ColumnMetadata) GetIsNullable ¶
func (x *ColumnMetadata) GetIsNullable() bool
func (*ColumnMetadata) GetNumericPrecision ¶
func (x *ColumnMetadata) GetNumericPrecision() int32
func (*ColumnMetadata) GetNumericPrecisionRadix ¶
func (x *ColumnMetadata) GetNumericPrecisionRadix() int32
func (*ColumnMetadata) GetNumericScale ¶
func (x *ColumnMetadata) GetNumericScale() int32
func (*ColumnMetadata) GetOrdinalPosition ¶
func (x *ColumnMetadata) GetOrdinalPosition() int32
func (*ColumnMetadata) GetSchemaName ¶
func (x *ColumnMetadata) GetSchemaName() string
func (*ColumnMetadata) GetTableName ¶
func (x *ColumnMetadata) GetTableName() string
func (*ColumnMetadata) ProtoMessage ¶
func (*ColumnMetadata) ProtoMessage()
func (*ColumnMetadata) ProtoReflect ¶
func (x *ColumnMetadata) ProtoReflect() protoreflect.Message
func (*ColumnMetadata) Reset ¶
func (x *ColumnMetadata) Reset()
func (*ColumnMetadata) String ¶
func (x *ColumnMetadata) String() string
type ColumnSearchability ¶
type ColumnSearchability int32
How a column can be used in WHERE clause
const ( ColumnSearchability_UNKNOWN_SEARCHABILITY ColumnSearchability = 0 ColumnSearchability_NONE ColumnSearchability = 1 // can't be used in WHERE clause ColumnSearchability_CHAR ColumnSearchability = 2 // can be used in WHERE clause but only with LIKE predicate ColumnSearchability_NUMBER ColumnSearchability = 3 // can be used in a WHERE clause with all the comparison operators except LIKE ColumnSearchability_ALL ColumnSearchability = 4 // can be used in a WHERE clause with all the comparison operators )
func (ColumnSearchability) Descriptor ¶
func (ColumnSearchability) Descriptor() protoreflect.EnumDescriptor
func (ColumnSearchability) Enum ¶
func (x ColumnSearchability) Enum() *ColumnSearchability
func (ColumnSearchability) EnumDescriptor
deprecated
func (ColumnSearchability) EnumDescriptor() ([]byte, []int)
Deprecated: Use ColumnSearchability.Descriptor instead.
func (ColumnSearchability) Number ¶
func (x ColumnSearchability) Number() protoreflect.EnumNumber
func (ColumnSearchability) String ¶
func (x ColumnSearchability) String() string
func (ColumnSearchability) Type ¶
func (ColumnSearchability) Type() protoreflect.EnumType
func (*ColumnSearchability) UnmarshalJSON
deprecated
func (x *ColumnSearchability) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type ColumnUpdatability ¶
type ColumnUpdatability int32
Whether a column can be updatable.
const ( ColumnUpdatability_UNKNOWN_UPDATABILITY ColumnUpdatability = 0 ColumnUpdatability_READ_ONLY ColumnUpdatability = 1 ColumnUpdatability_WRITABLE ColumnUpdatability = 2 )
func (ColumnUpdatability) Descriptor ¶
func (ColumnUpdatability) Descriptor() protoreflect.EnumDescriptor
func (ColumnUpdatability) Enum ¶
func (x ColumnUpdatability) Enum() *ColumnUpdatability
func (ColumnUpdatability) EnumDescriptor
deprecated
func (ColumnUpdatability) EnumDescriptor() ([]byte, []int)
Deprecated: Use ColumnUpdatability.Descriptor instead.
func (ColumnUpdatability) Number ¶
func (x ColumnUpdatability) Number() protoreflect.EnumNumber
func (ColumnUpdatability) String ¶
func (x ColumnUpdatability) String() string
func (ColumnUpdatability) Type ¶
func (ColumnUpdatability) Type() protoreflect.EnumType
func (*ColumnUpdatability) UnmarshalJSON
deprecated
func (x *ColumnUpdatability) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type ConvertSupport ¶
type ConvertSupport struct { From *common.MinorType `protobuf:"varint,1,req,name=from,enum=common.MinorType" json:"from,omitempty"` To *common.MinorType `protobuf:"varint,2,req,name=to,enum=common.MinorType" json:"to,omitempty"` // contains filtered or unexported fields }
func (*ConvertSupport) Descriptor
deprecated
func (*ConvertSupport) Descriptor() ([]byte, []int)
Deprecated: Use ConvertSupport.ProtoReflect.Descriptor instead.
func (*ConvertSupport) GetFrom ¶
func (x *ConvertSupport) GetFrom() common.MinorType
func (*ConvertSupport) GetTo ¶
func (x *ConvertSupport) GetTo() common.MinorType
func (*ConvertSupport) ProtoMessage ¶
func (*ConvertSupport) ProtoMessage()
func (*ConvertSupport) ProtoReflect ¶
func (x *ConvertSupport) ProtoReflect() protoreflect.Message
func (*ConvertSupport) Reset ¶
func (x *ConvertSupport) Reset()
func (*ConvertSupport) String ¶
func (x *ConvertSupport) String() string
type CorrelationNamesSupport ¶
type CorrelationNamesSupport int32
const ( CorrelationNamesSupport_CN_NONE CorrelationNamesSupport = 1 // Correlation names are not supported CorrelationNamesSupport_CN_DIFFERENT_NAMES CorrelationNamesSupport = 2 // Correlation names are supported, but names have to // be different from the tables they represent CorrelationNamesSupport_CN_ANY CorrelationNamesSupport = 3 // Correlation names are supported without restriction )
func (CorrelationNamesSupport) Descriptor ¶
func (CorrelationNamesSupport) Descriptor() protoreflect.EnumDescriptor
func (CorrelationNamesSupport) Enum ¶
func (x CorrelationNamesSupport) Enum() *CorrelationNamesSupport
func (CorrelationNamesSupport) EnumDescriptor
deprecated
func (CorrelationNamesSupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use CorrelationNamesSupport.Descriptor instead.
func (CorrelationNamesSupport) Number ¶
func (x CorrelationNamesSupport) Number() protoreflect.EnumNumber
func (CorrelationNamesSupport) String ¶
func (x CorrelationNamesSupport) String() string
func (CorrelationNamesSupport) Type ¶
func (CorrelationNamesSupport) Type() protoreflect.EnumType
func (*CorrelationNamesSupport) UnmarshalJSON
deprecated
func (x *CorrelationNamesSupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type CreatePreparedStatementReq ¶
type CreatePreparedStatementReq struct { SqlQuery *string `protobuf:"bytes,1,opt,name=sql_query,json=sqlQuery" json:"sql_query,omitempty"` // contains filtered or unexported fields }
Request message to create a prepared statement. Currently prepared statement only accepts a SQL query. Query parameter support is not included in current implementation.
func (*CreatePreparedStatementReq) Descriptor
deprecated
func (*CreatePreparedStatementReq) Descriptor() ([]byte, []int)
Deprecated: Use CreatePreparedStatementReq.ProtoReflect.Descriptor instead.
func (*CreatePreparedStatementReq) GetSqlQuery ¶
func (x *CreatePreparedStatementReq) GetSqlQuery() string
func (*CreatePreparedStatementReq) ProtoMessage ¶
func (*CreatePreparedStatementReq) ProtoMessage()
func (*CreatePreparedStatementReq) ProtoReflect ¶
func (x *CreatePreparedStatementReq) ProtoReflect() protoreflect.Message
func (*CreatePreparedStatementReq) Reset ¶
func (x *CreatePreparedStatementReq) Reset()
func (*CreatePreparedStatementReq) String ¶
func (x *CreatePreparedStatementReq) String() string
type CreatePreparedStatementResp ¶
type CreatePreparedStatementResp struct { Status *RequestStatus `protobuf:"varint,1,opt,name=status,enum=exec.user.RequestStatus" json:"status,omitempty"` PreparedStatement *PreparedStatement `protobuf:"bytes,2,opt,name=prepared_statement,json=preparedStatement" json:"prepared_statement,omitempty"` Error *shared.DrillPBError `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"` // contains filtered or unexported fields }
Response message for CreatePreparedStatementReq.
func (*CreatePreparedStatementResp) Descriptor
deprecated
func (*CreatePreparedStatementResp) Descriptor() ([]byte, []int)
Deprecated: Use CreatePreparedStatementResp.ProtoReflect.Descriptor instead.
func (*CreatePreparedStatementResp) GetError ¶
func (x *CreatePreparedStatementResp) GetError() *shared.DrillPBError
func (*CreatePreparedStatementResp) GetPreparedStatement ¶
func (x *CreatePreparedStatementResp) GetPreparedStatement() *PreparedStatement
func (*CreatePreparedStatementResp) GetStatus ¶
func (x *CreatePreparedStatementResp) GetStatus() RequestStatus
func (*CreatePreparedStatementResp) ProtoMessage ¶
func (*CreatePreparedStatementResp) ProtoMessage()
func (*CreatePreparedStatementResp) ProtoReflect ¶
func (x *CreatePreparedStatementResp) ProtoReflect() protoreflect.Message
func (*CreatePreparedStatementResp) Reset ¶
func (x *CreatePreparedStatementResp) Reset()
func (*CreatePreparedStatementResp) String ¶
func (x *CreatePreparedStatementResp) String() string
type DateTimeLiteralsSupport ¶
type DateTimeLiteralsSupport int32
const ( DateTimeLiteralsSupport_DL_UNKNOWN DateTimeLiteralsSupport = 0 // Unknown support (for forward compatibility) DateTimeLiteralsSupport_DL_DATE DateTimeLiteralsSupport = 1 // DATE literal is supported DateTimeLiteralsSupport_DL_TIME DateTimeLiteralsSupport = 2 // TIME literal is supported DateTimeLiteralsSupport_DL_TIMESTAMP DateTimeLiteralsSupport = 3 // TIMESTAMP literal is supported DateTimeLiteralsSupport_DL_INTERVAL_YEAR DateTimeLiteralsSupport = 4 // INTERVAL YEAR literal is supported DateTimeLiteralsSupport_DL_INTERVAL_MONTH DateTimeLiteralsSupport = 5 // INTERVAL MONTH literal is supported DateTimeLiteralsSupport_DL_INTERVAL_DAY DateTimeLiteralsSupport = 6 // INTERVAL DAY literal is supported DateTimeLiteralsSupport_DL_INTERVAL_HOUR DateTimeLiteralsSupport = 7 // INTERVAL HOUR literal is supported DateTimeLiteralsSupport_DL_INTERVAL_MINUTE DateTimeLiteralsSupport = 8 // INTERVAL MINUTE literal is supported DateTimeLiteralsSupport_DL_INTERVAL_SECOND DateTimeLiteralsSupport = 9 // INTERVAL SECOND literal is supported DateTimeLiteralsSupport_DL_INTERVAL_YEAR_TO_MONTH DateTimeLiteralsSupport = 10 // INTERVAL YEAR TO MONTH literal is supported DateTimeLiteralsSupport_DL_INTERVAL_DAY_TO_HOUR DateTimeLiteralsSupport = 11 // INTERVAL DAY TO HOUR literal is supported DateTimeLiteralsSupport_DL_INTERVAL_DAY_TO_MINUTE DateTimeLiteralsSupport = 12 // INTERVAL DAY TO MINUTE literal is supported DateTimeLiteralsSupport_DL_INTERVAL_DAY_TO_SECOND DateTimeLiteralsSupport = 13 // INTERVAL DAY TO SECOND literal is supported DateTimeLiteralsSupport_DL_INTERVAL_HOUR_TO_MINUTE DateTimeLiteralsSupport = 14 // INTERVAL HOUR TO MINUTE literal is supported DateTimeLiteralsSupport_DL_INTERVAL_HOUR_TO_SECOND DateTimeLiteralsSupport = 15 // INTERVAL HOUR TO SECOND literal is supported DateTimeLiteralsSupport_DL_INTERVAL_MINUTE_TO_SECOND DateTimeLiteralsSupport = 16 // INTERVAL MINUTE TO SECOND literal is supported )
func (DateTimeLiteralsSupport) Descriptor ¶
func (DateTimeLiteralsSupport) Descriptor() protoreflect.EnumDescriptor
func (DateTimeLiteralsSupport) Enum ¶
func (x DateTimeLiteralsSupport) Enum() *DateTimeLiteralsSupport
func (DateTimeLiteralsSupport) EnumDescriptor
deprecated
func (DateTimeLiteralsSupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use DateTimeLiteralsSupport.Descriptor instead.
func (DateTimeLiteralsSupport) Number ¶
func (x DateTimeLiteralsSupport) Number() protoreflect.EnumNumber
func (DateTimeLiteralsSupport) String ¶
func (x DateTimeLiteralsSupport) String() string
func (DateTimeLiteralsSupport) Type ¶
func (DateTimeLiteralsSupport) Type() protoreflect.EnumType
func (*DateTimeLiteralsSupport) UnmarshalJSON
deprecated
func (x *DateTimeLiteralsSupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type GetCatalogsReq ¶
type GetCatalogsReq struct { CatalogNameFilter *LikeFilter `protobuf:"bytes,1,opt,name=catalog_name_filter,json=catalogNameFilter" json:"catalog_name_filter,omitempty"` // contains filtered or unexported fields }
Request message for getting the metadata for catalogs satisfying the given optional filter.
func (*GetCatalogsReq) Descriptor
deprecated
func (*GetCatalogsReq) Descriptor() ([]byte, []int)
Deprecated: Use GetCatalogsReq.ProtoReflect.Descriptor instead.
func (*GetCatalogsReq) GetCatalogNameFilter ¶
func (x *GetCatalogsReq) GetCatalogNameFilter() *LikeFilter
func (*GetCatalogsReq) ProtoMessage ¶
func (*GetCatalogsReq) ProtoMessage()
func (*GetCatalogsReq) ProtoReflect ¶
func (x *GetCatalogsReq) ProtoReflect() protoreflect.Message
func (*GetCatalogsReq) Reset ¶
func (x *GetCatalogsReq) Reset()
func (*GetCatalogsReq) String ¶
func (x *GetCatalogsReq) String() string
type GetCatalogsResp ¶
type GetCatalogsResp struct { Status *RequestStatus `protobuf:"varint,1,opt,name=status,enum=exec.user.RequestStatus" json:"status,omitempty"` Catalogs []*CatalogMetadata `protobuf:"bytes,2,rep,name=catalogs" json:"catalogs,omitempty"` Error *shared.DrillPBError `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"` // contains filtered or unexported fields }
Response message for GetCatalogReq.
func (*GetCatalogsResp) Descriptor
deprecated
func (*GetCatalogsResp) Descriptor() ([]byte, []int)
Deprecated: Use GetCatalogsResp.ProtoReflect.Descriptor instead.
func (*GetCatalogsResp) GetCatalogs ¶
func (x *GetCatalogsResp) GetCatalogs() []*CatalogMetadata
func (*GetCatalogsResp) GetError ¶
func (x *GetCatalogsResp) GetError() *shared.DrillPBError
func (*GetCatalogsResp) GetStatus ¶
func (x *GetCatalogsResp) GetStatus() RequestStatus
func (*GetCatalogsResp) ProtoMessage ¶
func (*GetCatalogsResp) ProtoMessage()
func (*GetCatalogsResp) ProtoReflect ¶
func (x *GetCatalogsResp) ProtoReflect() protoreflect.Message
func (*GetCatalogsResp) Reset ¶
func (x *GetCatalogsResp) Reset()
func (*GetCatalogsResp) String ¶
func (x *GetCatalogsResp) String() string
type GetColumnsReq ¶
type GetColumnsReq struct { CatalogNameFilter *LikeFilter `protobuf:"bytes,1,opt,name=catalog_name_filter,json=catalogNameFilter" json:"catalog_name_filter,omitempty"` SchemaNameFilter *LikeFilter `protobuf:"bytes,2,opt,name=schema_name_filter,json=schemaNameFilter" json:"schema_name_filter,omitempty"` TableNameFilter *LikeFilter `protobuf:"bytes,3,opt,name=table_name_filter,json=tableNameFilter" json:"table_name_filter,omitempty"` ColumnNameFilter *LikeFilter `protobuf:"bytes,4,opt,name=column_name_filter,json=columnNameFilter" json:"column_name_filter,omitempty"` // contains filtered or unexported fields }
Request message for getting the metadata for columns satisfying the given optional filters.
func (*GetColumnsReq) Descriptor
deprecated
func (*GetColumnsReq) Descriptor() ([]byte, []int)
Deprecated: Use GetColumnsReq.ProtoReflect.Descriptor instead.
func (*GetColumnsReq) GetCatalogNameFilter ¶
func (x *GetColumnsReq) GetCatalogNameFilter() *LikeFilter
func (*GetColumnsReq) GetColumnNameFilter ¶
func (x *GetColumnsReq) GetColumnNameFilter() *LikeFilter
func (*GetColumnsReq) GetSchemaNameFilter ¶
func (x *GetColumnsReq) GetSchemaNameFilter() *LikeFilter
func (*GetColumnsReq) GetTableNameFilter ¶
func (x *GetColumnsReq) GetTableNameFilter() *LikeFilter
func (*GetColumnsReq) ProtoMessage ¶
func (*GetColumnsReq) ProtoMessage()
func (*GetColumnsReq) ProtoReflect ¶
func (x *GetColumnsReq) ProtoReflect() protoreflect.Message
func (*GetColumnsReq) Reset ¶
func (x *GetColumnsReq) Reset()
func (*GetColumnsReq) String ¶
func (x *GetColumnsReq) String() string
type GetColumnsResp ¶
type GetColumnsResp struct { Status *RequestStatus `protobuf:"varint,1,opt,name=status,enum=exec.user.RequestStatus" json:"status,omitempty"` Columns []*ColumnMetadata `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"` Error *shared.DrillPBError `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"` // contains filtered or unexported fields }
Response message for GetColumnsReq.
func (*GetColumnsResp) Descriptor
deprecated
func (*GetColumnsResp) Descriptor() ([]byte, []int)
Deprecated: Use GetColumnsResp.ProtoReflect.Descriptor instead.
func (*GetColumnsResp) GetColumns ¶
func (x *GetColumnsResp) GetColumns() []*ColumnMetadata
func (*GetColumnsResp) GetError ¶
func (x *GetColumnsResp) GetError() *shared.DrillPBError
func (*GetColumnsResp) GetStatus ¶
func (x *GetColumnsResp) GetStatus() RequestStatus
func (*GetColumnsResp) ProtoMessage ¶
func (*GetColumnsResp) ProtoMessage()
func (*GetColumnsResp) ProtoReflect ¶
func (x *GetColumnsResp) ProtoReflect() protoreflect.Message
func (*GetColumnsResp) Reset ¶
func (x *GetColumnsResp) Reset()
func (*GetColumnsResp) String ¶
func (x *GetColumnsResp) String() string
type GetQueryPlanFragments ¶
type GetQueryPlanFragments struct { Query *string `protobuf:"bytes,1,req,name=query" json:"query,omitempty"` Type *shared.QueryType `protobuf:"varint,2,opt,name=type,enum=exec.shared.QueryType" json:"type,omitempty"` SplitPlan *bool `protobuf:"varint,3,opt,name=split_plan,json=splitPlan,def=0" json:"split_plan,omitempty"` // contains filtered or unexported fields }
func (*GetQueryPlanFragments) Descriptor
deprecated
func (*GetQueryPlanFragments) Descriptor() ([]byte, []int)
Deprecated: Use GetQueryPlanFragments.ProtoReflect.Descriptor instead.
func (*GetQueryPlanFragments) GetQuery ¶
func (x *GetQueryPlanFragments) GetQuery() string
func (*GetQueryPlanFragments) GetSplitPlan ¶
func (x *GetQueryPlanFragments) GetSplitPlan() bool
func (*GetQueryPlanFragments) GetType ¶
func (x *GetQueryPlanFragments) GetType() shared.QueryType
func (*GetQueryPlanFragments) ProtoMessage ¶
func (*GetQueryPlanFragments) ProtoMessage()
func (*GetQueryPlanFragments) ProtoReflect ¶
func (x *GetQueryPlanFragments) ProtoReflect() protoreflect.Message
func (*GetQueryPlanFragments) Reset ¶
func (x *GetQueryPlanFragments) Reset()
func (*GetQueryPlanFragments) String ¶
func (x *GetQueryPlanFragments) String() string
type GetSchemasReq ¶
type GetSchemasReq struct { CatalogNameFilter *LikeFilter `protobuf:"bytes,1,opt,name=catalog_name_filter,json=catalogNameFilter" json:"catalog_name_filter,omitempty"` SchemaNameFilter *LikeFilter `protobuf:"bytes,2,opt,name=schema_name_filter,json=schemaNameFilter" json:"schema_name_filter,omitempty"` // contains filtered or unexported fields }
Request message for getting the metadata for schemas satisfying the given optional filters.
func (*GetSchemasReq) Descriptor
deprecated
func (*GetSchemasReq) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemasReq.ProtoReflect.Descriptor instead.
func (*GetSchemasReq) GetCatalogNameFilter ¶
func (x *GetSchemasReq) GetCatalogNameFilter() *LikeFilter
func (*GetSchemasReq) GetSchemaNameFilter ¶
func (x *GetSchemasReq) GetSchemaNameFilter() *LikeFilter
func (*GetSchemasReq) ProtoMessage ¶
func (*GetSchemasReq) ProtoMessage()
func (*GetSchemasReq) ProtoReflect ¶
func (x *GetSchemasReq) ProtoReflect() protoreflect.Message
func (*GetSchemasReq) Reset ¶
func (x *GetSchemasReq) Reset()
func (*GetSchemasReq) String ¶
func (x *GetSchemasReq) String() string
type GetSchemasResp ¶
type GetSchemasResp struct { Status *RequestStatus `protobuf:"varint,1,opt,name=status,enum=exec.user.RequestStatus" json:"status,omitempty"` Schemas []*SchemaMetadata `protobuf:"bytes,2,rep,name=schemas" json:"schemas,omitempty"` Error *shared.DrillPBError `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"` // contains filtered or unexported fields }
Response message for GetSchemasReq.
func (*GetSchemasResp) Descriptor
deprecated
func (*GetSchemasResp) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemasResp.ProtoReflect.Descriptor instead.
func (*GetSchemasResp) GetError ¶
func (x *GetSchemasResp) GetError() *shared.DrillPBError
func (*GetSchemasResp) GetSchemas ¶
func (x *GetSchemasResp) GetSchemas() []*SchemaMetadata
func (*GetSchemasResp) GetStatus ¶
func (x *GetSchemasResp) GetStatus() RequestStatus
func (*GetSchemasResp) ProtoMessage ¶
func (*GetSchemasResp) ProtoMessage()
func (*GetSchemasResp) ProtoReflect ¶
func (x *GetSchemasResp) ProtoReflect() protoreflect.Message
func (*GetSchemasResp) Reset ¶
func (x *GetSchemasResp) Reset()
func (*GetSchemasResp) String ¶
func (x *GetSchemasResp) String() string
type GetServerMetaReq ¶
type GetServerMetaReq struct {
// contains filtered or unexported fields
}
Request message for getting server metadata
func (*GetServerMetaReq) Descriptor
deprecated
func (*GetServerMetaReq) Descriptor() ([]byte, []int)
Deprecated: Use GetServerMetaReq.ProtoReflect.Descriptor instead.
func (*GetServerMetaReq) ProtoMessage ¶
func (*GetServerMetaReq) ProtoMessage()
func (*GetServerMetaReq) ProtoReflect ¶
func (x *GetServerMetaReq) ProtoReflect() protoreflect.Message
func (*GetServerMetaReq) Reset ¶
func (x *GetServerMetaReq) Reset()
func (*GetServerMetaReq) String ¶
func (x *GetServerMetaReq) String() string
type GetServerMetaResp ¶
type GetServerMetaResp struct { Status *RequestStatus `protobuf:"varint,1,opt,name=status,enum=exec.user.RequestStatus" json:"status,omitempty"` ServerMeta *ServerMeta `protobuf:"bytes,2,opt,name=server_meta,json=serverMeta" json:"server_meta,omitempty"` Error *shared.DrillPBError `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"` // contains filtered or unexported fields }
Response message for GetServerMetaReq
func (*GetServerMetaResp) Descriptor
deprecated
func (*GetServerMetaResp) Descriptor() ([]byte, []int)
Deprecated: Use GetServerMetaResp.ProtoReflect.Descriptor instead.
func (*GetServerMetaResp) GetError ¶
func (x *GetServerMetaResp) GetError() *shared.DrillPBError
func (*GetServerMetaResp) GetServerMeta ¶
func (x *GetServerMetaResp) GetServerMeta() *ServerMeta
func (*GetServerMetaResp) GetStatus ¶
func (x *GetServerMetaResp) GetStatus() RequestStatus
func (*GetServerMetaResp) ProtoMessage ¶
func (*GetServerMetaResp) ProtoMessage()
func (*GetServerMetaResp) ProtoReflect ¶
func (x *GetServerMetaResp) ProtoReflect() protoreflect.Message
func (*GetServerMetaResp) Reset ¶
func (x *GetServerMetaResp) Reset()
func (*GetServerMetaResp) String ¶
func (x *GetServerMetaResp) String() string
type GetTablesReq ¶
type GetTablesReq struct { CatalogNameFilter *LikeFilter `protobuf:"bytes,1,opt,name=catalog_name_filter,json=catalogNameFilter" json:"catalog_name_filter,omitempty"` SchemaNameFilter *LikeFilter `protobuf:"bytes,2,opt,name=schema_name_filter,json=schemaNameFilter" json:"schema_name_filter,omitempty"` TableNameFilter *LikeFilter `protobuf:"bytes,3,opt,name=table_name_filter,json=tableNameFilter" json:"table_name_filter,omitempty"` TableTypeFilter []string `protobuf:"bytes,4,rep,name=table_type_filter,json=tableTypeFilter" json:"table_type_filter,omitempty"` // contains filtered or unexported fields }
Request message for getting the metadata for tables satisfying the given optional filters.
func (*GetTablesReq) Descriptor
deprecated
func (*GetTablesReq) Descriptor() ([]byte, []int)
Deprecated: Use GetTablesReq.ProtoReflect.Descriptor instead.
func (*GetTablesReq) GetCatalogNameFilter ¶
func (x *GetTablesReq) GetCatalogNameFilter() *LikeFilter
func (*GetTablesReq) GetSchemaNameFilter ¶
func (x *GetTablesReq) GetSchemaNameFilter() *LikeFilter
func (*GetTablesReq) GetTableNameFilter ¶
func (x *GetTablesReq) GetTableNameFilter() *LikeFilter
func (*GetTablesReq) GetTableTypeFilter ¶
func (x *GetTablesReq) GetTableTypeFilter() []string
func (*GetTablesReq) ProtoMessage ¶
func (*GetTablesReq) ProtoMessage()
func (*GetTablesReq) ProtoReflect ¶
func (x *GetTablesReq) ProtoReflect() protoreflect.Message
func (*GetTablesReq) Reset ¶
func (x *GetTablesReq) Reset()
func (*GetTablesReq) String ¶
func (x *GetTablesReq) String() string
type GetTablesResp ¶
type GetTablesResp struct { Status *RequestStatus `protobuf:"varint,1,opt,name=status,enum=exec.user.RequestStatus" json:"status,omitempty"` Tables []*TableMetadata `protobuf:"bytes,2,rep,name=tables" json:"tables,omitempty"` Error *shared.DrillPBError `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"` // contains filtered or unexported fields }
Response message for GetTablesReq.
func (*GetTablesResp) Descriptor
deprecated
func (*GetTablesResp) Descriptor() ([]byte, []int)
Deprecated: Use GetTablesResp.ProtoReflect.Descriptor instead.
func (*GetTablesResp) GetError ¶
func (x *GetTablesResp) GetError() *shared.DrillPBError
func (*GetTablesResp) GetStatus ¶
func (x *GetTablesResp) GetStatus() RequestStatus
func (*GetTablesResp) GetTables ¶
func (x *GetTablesResp) GetTables() []*TableMetadata
func (*GetTablesResp) ProtoMessage ¶
func (*GetTablesResp) ProtoMessage()
func (*GetTablesResp) ProtoReflect ¶
func (x *GetTablesResp) ProtoReflect() protoreflect.Message
func (*GetTablesResp) Reset ¶
func (x *GetTablesResp) Reset()
func (*GetTablesResp) String ¶
func (x *GetTablesResp) String() string
type GroupBySupport ¶
type GroupBySupport int32
const ( GroupBySupport_GB_NONE GroupBySupport = 1 // Group by is not supported GroupBySupport_GB_SELECT_ONLY GroupBySupport = 2 // Group by supported with non aggregated columns in select GroupBySupport_GB_BEYOND_SELECT GroupBySupport = 3 GroupBySupport_GB_UNRELATED GroupBySupport = 4 // Group by supported with columns absent from the select list )
func (GroupBySupport) Descriptor ¶
func (GroupBySupport) Descriptor() protoreflect.EnumDescriptor
func (GroupBySupport) Enum ¶
func (x GroupBySupport) Enum() *GroupBySupport
func (GroupBySupport) EnumDescriptor
deprecated
func (GroupBySupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use GroupBySupport.Descriptor instead.
func (GroupBySupport) Number ¶
func (x GroupBySupport) Number() protoreflect.EnumNumber
func (GroupBySupport) String ¶
func (x GroupBySupport) String() string
func (GroupBySupport) Type ¶
func (GroupBySupport) Type() protoreflect.EnumType
func (*GroupBySupport) UnmarshalJSON
deprecated
func (x *GroupBySupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type HandshakeStatus ¶
type HandshakeStatus int32
const ( HandshakeStatus_SUCCESS HandshakeStatus = 1 // Handshake is successful (including authentication if any) HandshakeStatus_RPC_VERSION_MISMATCH HandshakeStatus = 2 // Client and Server RPC versions are different HandshakeStatus_AUTH_FAILED HandshakeStatus = 3 // User authentication failed HandshakeStatus_UNKNOWN_FAILURE HandshakeStatus = 4 // Unknown failure, refer to the error message for more details HandshakeStatus_AUTH_REQUIRED HandshakeStatus = 5 // User authentication required )
func (HandshakeStatus) Descriptor ¶
func (HandshakeStatus) Descriptor() protoreflect.EnumDescriptor
func (HandshakeStatus) Enum ¶
func (x HandshakeStatus) Enum() *HandshakeStatus
func (HandshakeStatus) EnumDescriptor
deprecated
func (HandshakeStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use HandshakeStatus.Descriptor instead.
func (HandshakeStatus) Number ¶
func (x HandshakeStatus) Number() protoreflect.EnumNumber
func (HandshakeStatus) String ¶
func (x HandshakeStatus) String() string
func (HandshakeStatus) Type ¶
func (HandshakeStatus) Type() protoreflect.EnumType
func (*HandshakeStatus) UnmarshalJSON
deprecated
func (x *HandshakeStatus) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type IdentifierCasing ¶
type IdentifierCasing int32
const ( IdentifierCasing_IC_UNKNOWN IdentifierCasing = 0 // Unknown support (for forward compatibility) IdentifierCasing_IC_STORES_LOWER IdentifierCasing = 1 IdentifierCasing_IC_STORES_MIXED IdentifierCasing = 2 IdentifierCasing_IC_STORES_UPPER IdentifierCasing = 3 IdentifierCasing_IC_SUPPORTS_MIXED IdentifierCasing = 4 )
func (IdentifierCasing) Descriptor ¶
func (IdentifierCasing) Descriptor() protoreflect.EnumDescriptor
func (IdentifierCasing) Enum ¶
func (x IdentifierCasing) Enum() *IdentifierCasing
func (IdentifierCasing) EnumDescriptor
deprecated
func (IdentifierCasing) EnumDescriptor() ([]byte, []int)
Deprecated: Use IdentifierCasing.Descriptor instead.
func (IdentifierCasing) Number ¶
func (x IdentifierCasing) Number() protoreflect.EnumNumber
func (IdentifierCasing) String ¶
func (x IdentifierCasing) String() string
func (IdentifierCasing) Type ¶
func (IdentifierCasing) Type() protoreflect.EnumType
func (*IdentifierCasing) UnmarshalJSON
deprecated
func (x *IdentifierCasing) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type LikeFilter ¶
type LikeFilter struct { Pattern *string `protobuf:"bytes,1,opt,name=pattern" json:"pattern,omitempty"` // pattern to match Escape *string `protobuf:"bytes,2,opt,name=escape" json:"escape,omitempty"` // escape character (if any) present in the pattern // contains filtered or unexported fields }
Simple filter which encapsulates the SQL LIKE ... ESCAPE function
func (*LikeFilter) Descriptor
deprecated
func (*LikeFilter) Descriptor() ([]byte, []int)
Deprecated: Use LikeFilter.ProtoReflect.Descriptor instead.
func (*LikeFilter) GetEscape ¶
func (x *LikeFilter) GetEscape() string
func (*LikeFilter) GetPattern ¶
func (x *LikeFilter) GetPattern() string
func (*LikeFilter) ProtoMessage ¶
func (*LikeFilter) ProtoMessage()
func (*LikeFilter) ProtoReflect ¶
func (x *LikeFilter) ProtoReflect() protoreflect.Message
func (*LikeFilter) Reset ¶
func (x *LikeFilter) Reset()
func (*LikeFilter) String ¶
func (x *LikeFilter) String() string
type NullCollation ¶
type NullCollation int32
const ( NullCollation_NC_UNKNOWN NullCollation = 0 // Unknown support (for forward compatibility) NullCollation_NC_AT_START NullCollation = 1 // NULL values are sorted at the start regardless of the order NullCollation_NC_AT_END NullCollation = 2 // NULL values are sorted at the end regardless of the order NullCollation_NC_HIGH NullCollation = 3 // NULL is the highest value NullCollation_NC_LOW NullCollation = 4 // NULL is the lowest value )
func (NullCollation) Descriptor ¶
func (NullCollation) Descriptor() protoreflect.EnumDescriptor
func (NullCollation) Enum ¶
func (x NullCollation) Enum() *NullCollation
func (NullCollation) EnumDescriptor
deprecated
func (NullCollation) EnumDescriptor() ([]byte, []int)
Deprecated: Use NullCollation.Descriptor instead.
func (NullCollation) Number ¶
func (x NullCollation) Number() protoreflect.EnumNumber
func (NullCollation) String ¶
func (x NullCollation) String() string
func (NullCollation) Type ¶
func (NullCollation) Type() protoreflect.EnumType
func (*NullCollation) UnmarshalJSON
deprecated
func (x *NullCollation) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type OrderBySupport ¶
type OrderBySupport int32
const ( OrderBySupport_OB_UNKNOWN OrderBySupport = 0 // Unknown support (for forward compatibility) OrderBySupport_OB_UNRELATED OrderBySupport = 1 // ORDER BY supported with columns not in SELECT list OrderBySupport_OB_EXPRESSION OrderBySupport = 2 // ORDER BY with expressions is supported )
func (OrderBySupport) Descriptor ¶
func (OrderBySupport) Descriptor() protoreflect.EnumDescriptor
func (OrderBySupport) Enum ¶
func (x OrderBySupport) Enum() *OrderBySupport
func (OrderBySupport) EnumDescriptor
deprecated
func (OrderBySupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use OrderBySupport.Descriptor instead.
func (OrderBySupport) Number ¶
func (x OrderBySupport) Number() protoreflect.EnumNumber
func (OrderBySupport) String ¶
func (x OrderBySupport) String() string
func (OrderBySupport) Type ¶
func (OrderBySupport) Type() protoreflect.EnumType
func (*OrderBySupport) UnmarshalJSON
deprecated
func (x *OrderBySupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type OuterJoinSupport ¶
type OuterJoinSupport int32
const ( OuterJoinSupport_OJ_UNKNOWN OuterJoinSupport = 0 // Unknown support (for forward compatibility) OuterJoinSupport_OJ_LEFT OuterJoinSupport = 1 // Left outer join is supported OuterJoinSupport_OJ_RIGHT OuterJoinSupport = 2 // Right outer join is supported OuterJoinSupport_OJ_FULL OuterJoinSupport = 3 // Full outer join is supported OuterJoinSupport_OJ_NESTED OuterJoinSupport = 4 // Nested outer join is supported OuterJoinSupport_OJ_NOT_ORDERED OuterJoinSupport = 5 OuterJoinSupport_OJ_INNER OuterJoinSupport = 6 // Inner table can also be used in an inner join OuterJoinSupport_OJ_ALL_COMPARISON_OPS OuterJoinSupport = 7 // Any comparison operator is supported in the ON clause )
func (OuterJoinSupport) Descriptor ¶
func (OuterJoinSupport) Descriptor() protoreflect.EnumDescriptor
func (OuterJoinSupport) Enum ¶
func (x OuterJoinSupport) Enum() *OuterJoinSupport
func (OuterJoinSupport) EnumDescriptor
deprecated
func (OuterJoinSupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use OuterJoinSupport.Descriptor instead.
func (OuterJoinSupport) Number ¶
func (x OuterJoinSupport) Number() protoreflect.EnumNumber
func (OuterJoinSupport) String ¶
func (x OuterJoinSupport) String() string
func (OuterJoinSupport) Type ¶
func (OuterJoinSupport) Type() protoreflect.EnumType
func (*OuterJoinSupport) UnmarshalJSON
deprecated
func (x *OuterJoinSupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type PreparedStatement ¶
type PreparedStatement struct { Columns []*ResultColumnMetadata `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"` // // In order to execute the prepared statement, // clients need to submit this object in RunQuery message. ServerHandle *PreparedStatementHandle `protobuf:"bytes,2,opt,name=server_handle,json=serverHandle" json:"server_handle,omitempty"` // contains filtered or unexported fields }
Prepared statement. It contains the query metadata and handle to prepared statement state on server.
func (*PreparedStatement) Descriptor
deprecated
func (*PreparedStatement) Descriptor() ([]byte, []int)
Deprecated: Use PreparedStatement.ProtoReflect.Descriptor instead.
func (*PreparedStatement) GetColumns ¶
func (x *PreparedStatement) GetColumns() []*ResultColumnMetadata
func (*PreparedStatement) GetServerHandle ¶
func (x *PreparedStatement) GetServerHandle() *PreparedStatementHandle
func (*PreparedStatement) ProtoMessage ¶
func (*PreparedStatement) ProtoMessage()
func (*PreparedStatement) ProtoReflect ¶
func (x *PreparedStatement) ProtoReflect() protoreflect.Message
func (*PreparedStatement) Reset ¶
func (x *PreparedStatement) Reset()
func (*PreparedStatement) String ¶
func (x *PreparedStatement) String() string
type PreparedStatementHandle ¶
type PreparedStatementHandle struct { ServerInfo []byte `protobuf:"bytes,1,opt,name=server_info,json=serverInfo" json:"server_info,omitempty"` // contains filtered or unexported fields }
Server state of prepared statement. Contents are opaque to client. Client just need to submit this object in RunQuery to the prepared statement.
func (*PreparedStatementHandle) Descriptor
deprecated
func (*PreparedStatementHandle) Descriptor() ([]byte, []int)
Deprecated: Use PreparedStatementHandle.ProtoReflect.Descriptor instead.
func (*PreparedStatementHandle) GetServerInfo ¶
func (x *PreparedStatementHandle) GetServerInfo() []byte
func (*PreparedStatementHandle) ProtoMessage ¶
func (*PreparedStatementHandle) ProtoMessage()
func (*PreparedStatementHandle) ProtoReflect ¶
func (x *PreparedStatementHandle) ProtoReflect() protoreflect.Message
func (*PreparedStatementHandle) Reset ¶
func (x *PreparedStatementHandle) Reset()
func (*PreparedStatementHandle) String ¶
func (x *PreparedStatementHandle) String() string
type Property ¶
type Property struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Value *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Property) Descriptor
deprecated
func (*Property) ProtoMessage ¶
func (*Property) ProtoMessage()
func (*Property) ProtoReflect ¶
func (x *Property) ProtoReflect() protoreflect.Message
type QueryPlanFragments ¶
type QueryPlanFragments struct { Status *shared.QueryResult_QueryState `protobuf:"varint,1,req,name=status,enum=exec.shared.QueryResult_QueryState" json:"status,omitempty"` QueryId *shared.QueryId `protobuf:"bytes,2,opt,name=query_id,json=queryId" json:"query_id,omitempty"` Fragments []*control.PlanFragment `protobuf:"bytes,3,rep,name=fragments" json:"fragments,omitempty"` Error *shared.DrillPBError `protobuf:"bytes,4,opt,name=error" json:"error,omitempty"` // contains filtered or unexported fields }
func (*QueryPlanFragments) Descriptor
deprecated
func (*QueryPlanFragments) Descriptor() ([]byte, []int)
Deprecated: Use QueryPlanFragments.ProtoReflect.Descriptor instead.
func (*QueryPlanFragments) GetError ¶
func (x *QueryPlanFragments) GetError() *shared.DrillPBError
func (*QueryPlanFragments) GetFragments ¶
func (x *QueryPlanFragments) GetFragments() []*control.PlanFragment
func (*QueryPlanFragments) GetQueryId ¶
func (x *QueryPlanFragments) GetQueryId() *shared.QueryId
func (*QueryPlanFragments) GetStatus ¶
func (x *QueryPlanFragments) GetStatus() shared.QueryResult_QueryState
func (*QueryPlanFragments) ProtoMessage ¶
func (*QueryPlanFragments) ProtoMessage()
func (*QueryPlanFragments) ProtoReflect ¶
func (x *QueryPlanFragments) ProtoReflect() protoreflect.Message
func (*QueryPlanFragments) Reset ¶
func (x *QueryPlanFragments) Reset()
func (*QueryPlanFragments) String ¶
func (x *QueryPlanFragments) String() string
type QueryResultsMode ¶
type QueryResultsMode int32
const (
QueryResultsMode_STREAM_FULL QueryResultsMode = 1 // Server will inform the client regularly on the status of the query. Once the query is completed, service will inform the client as each query chunk is made available.
)
func (QueryResultsMode) Descriptor ¶
func (QueryResultsMode) Descriptor() protoreflect.EnumDescriptor
func (QueryResultsMode) Enum ¶
func (x QueryResultsMode) Enum() *QueryResultsMode
func (QueryResultsMode) EnumDescriptor
deprecated
func (QueryResultsMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use QueryResultsMode.Descriptor instead.
func (QueryResultsMode) Number ¶
func (x QueryResultsMode) Number() protoreflect.EnumNumber
func (QueryResultsMode) String ¶
func (x QueryResultsMode) String() string
func (QueryResultsMode) Type ¶
func (QueryResultsMode) Type() protoreflect.EnumType
func (*QueryResultsMode) UnmarshalJSON
deprecated
func (x *QueryResultsMode) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type RequestResults ¶
type RequestResults struct { QueryId *shared.QueryId `protobuf:"bytes,1,opt,name=query_id,json=queryId" json:"query_id,omitempty"` MaximumResponses *int32 `protobuf:"varint,2,opt,name=maximum_responses,json=maximumResponses" json:"maximum_responses,omitempty"` // contains filtered or unexported fields }
func (*RequestResults) Descriptor
deprecated
func (*RequestResults) Descriptor() ([]byte, []int)
Deprecated: Use RequestResults.ProtoReflect.Descriptor instead.
func (*RequestResults) GetMaximumResponses ¶
func (x *RequestResults) GetMaximumResponses() int32
func (*RequestResults) GetQueryId ¶
func (x *RequestResults) GetQueryId() *shared.QueryId
func (*RequestResults) ProtoMessage ¶
func (*RequestResults) ProtoMessage()
func (*RequestResults) ProtoReflect ¶
func (x *RequestResults) ProtoReflect() protoreflect.Message
func (*RequestResults) Reset ¶
func (x *RequestResults) Reset()
func (*RequestResults) String ¶
func (x *RequestResults) String() string
type RequestStatus ¶
type RequestStatus int32
Enum indicating the request status.
const ( RequestStatus_UNKNOWN_STATUS RequestStatus = 0 RequestStatus_OK RequestStatus = 1 RequestStatus_FAILED RequestStatus = 2 //* // Request timed out. Futher attempts can change any API specific parameters and retry or just retry the request. RequestStatus_TIMEOUT RequestStatus = 3 )
func (RequestStatus) Descriptor ¶
func (RequestStatus) Descriptor() protoreflect.EnumDescriptor
func (RequestStatus) Enum ¶
func (x RequestStatus) Enum() *RequestStatus
func (RequestStatus) EnumDescriptor
deprecated
func (RequestStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use RequestStatus.Descriptor instead.
func (RequestStatus) Number ¶
func (x RequestStatus) Number() protoreflect.EnumNumber
func (RequestStatus) String ¶
func (x RequestStatus) String() string
func (RequestStatus) Type ¶
func (RequestStatus) Type() protoreflect.EnumType
func (*RequestStatus) UnmarshalJSON
deprecated
func (x *RequestStatus) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type ResultColumnMetadata ¶
type ResultColumnMetadata struct { // // Designated column's catalog name. Empty string if not applicable. // Defaults to "DRILL" as drill has only one catalog. CatalogName *string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName" json:"catalog_name,omitempty"` // // Designated column's schema name. Not set if not applicable. Initial implementation // defaults to no value as we use LIMIT 0 queries to get the schema and schema info // is lost. If we derive the schema from plan, we may get the right value. SchemaName *string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName" json:"schema_name,omitempty"` // // Designated column's table name. Not set if not applicable. Initial implementation // defaults to no value as we use LIMIT 0 queries to get the schema and table info // is lost. If we derive the schema from query plan, we may get the right value. TableName *string `protobuf:"bytes,3,opt,name=table_name,json=tableName" json:"table_name,omitempty"` ColumnName *string `protobuf:"bytes,4,opt,name=column_name,json=columnName" json:"column_name,omitempty"` // column name // // Column label name for display or print purposes. // Ex. a column named "empName" might be labeled as "Employee Name". Label *string `protobuf:"bytes,5,opt,name=label" json:"label,omitempty"` // // Data type in string format. Value is SQL standard type. DataType *string `protobuf:"bytes,6,opt,name=data_type,json=dataType" json:"data_type,omitempty"` IsNullable *bool `protobuf:"varint,7,opt,name=is_nullable,json=isNullable" json:"is_nullable,omitempty"` // // For numeric data, this is the maximum precision. // For character data, this is the length in characters. // For datetime datatypes, this is the length in characters of the String representation // (assuming the maximum allowed precision of the fractional seconds component). // For binary data, this is the length in bytes. // For all other types 0 is returned where the column size is not applicable. Precision *int32 `protobuf:"varint,8,opt,name=precision" json:"precision,omitempty"` // // Column's number of digits to right of the decimal point. // 0 is returned for types where the scale is not applicable Scale *int32 `protobuf:"varint,9,opt,name=scale" json:"scale,omitempty"` // // Indicates whether values in the designated column are signed numbers. Signed *bool `protobuf:"varint,10,opt,name=signed" json:"signed,omitempty"` // // Maximum number of characters required to display data from the column. DisplaySize *int32 `protobuf:"varint,11,opt,name=display_size,json=displaySize" json:"display_size,omitempty"` // // Is the column an aliased column. Initial implementation defaults to // true as we derive schema from LIMIT 0 query and not the query plan. IsAliased *bool `protobuf:"varint,12,opt,name=is_aliased,json=isAliased" json:"is_aliased,omitempty"` Searchability *ColumnSearchability `protobuf:"varint,13,opt,name=searchability,enum=exec.user.ColumnSearchability" json:"searchability,omitempty"` // // Defaults to READ_ONLY Updatability *ColumnUpdatability `protobuf:"varint,14,opt,name=updatability,enum=exec.user.ColumnUpdatability" json:"updatability,omitempty"` // // whether the designated column is automatically incremented. AutoIncrement *bool `protobuf:"varint,15,opt,name=auto_increment,json=autoIncrement" json:"auto_increment,omitempty"` // // Whether column's case matters for collations and comparisons. Defaults to true. CaseSensitivity *bool `protobuf:"varint,16,opt,name=case_sensitivity,json=caseSensitivity" json:"case_sensitivity,omitempty"` // // whether the column can be used in ORDER BY clause Sortable *bool `protobuf:"varint,17,opt,name=sortable" json:"sortable,omitempty"` // // A fully-qualified name of the Java class whose instances are created // if the method ResultSet.getObject is called to retrieve // a value from the column. Applicable only to JDBC clients. ClassName *string `protobuf:"bytes,18,opt,name=class_name,json=className" json:"class_name,omitempty"` // // Is the data type a currency type? For JDBC only. IsCurrency *bool `protobuf:"varint,20,opt,name=is_currency,json=isCurrency" json:"is_currency,omitempty"` // contains filtered or unexported fields }
Metadata of a column in query result set
func (*ResultColumnMetadata) Descriptor
deprecated
func (*ResultColumnMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ResultColumnMetadata.ProtoReflect.Descriptor instead.
func (*ResultColumnMetadata) GetAutoIncrement ¶
func (x *ResultColumnMetadata) GetAutoIncrement() bool
func (*ResultColumnMetadata) GetCaseSensitivity ¶
func (x *ResultColumnMetadata) GetCaseSensitivity() bool
func (*ResultColumnMetadata) GetCatalogName ¶
func (x *ResultColumnMetadata) GetCatalogName() string
func (*ResultColumnMetadata) GetClassName ¶
func (x *ResultColumnMetadata) GetClassName() string
func (*ResultColumnMetadata) GetColumnName ¶
func (x *ResultColumnMetadata) GetColumnName() string
func (*ResultColumnMetadata) GetDataType ¶
func (x *ResultColumnMetadata) GetDataType() string
func (*ResultColumnMetadata) GetDisplaySize ¶
func (x *ResultColumnMetadata) GetDisplaySize() int32
func (*ResultColumnMetadata) GetIsAliased ¶
func (x *ResultColumnMetadata) GetIsAliased() bool
func (*ResultColumnMetadata) GetIsCurrency ¶
func (x *ResultColumnMetadata) GetIsCurrency() bool
func (*ResultColumnMetadata) GetIsNullable ¶
func (x *ResultColumnMetadata) GetIsNullable() bool
func (*ResultColumnMetadata) GetLabel ¶
func (x *ResultColumnMetadata) GetLabel() string
func (*ResultColumnMetadata) GetPrecision ¶
func (x *ResultColumnMetadata) GetPrecision() int32
func (*ResultColumnMetadata) GetScale ¶
func (x *ResultColumnMetadata) GetScale() int32
func (*ResultColumnMetadata) GetSchemaName ¶
func (x *ResultColumnMetadata) GetSchemaName() string
func (*ResultColumnMetadata) GetSearchability ¶
func (x *ResultColumnMetadata) GetSearchability() ColumnSearchability
func (*ResultColumnMetadata) GetSigned ¶
func (x *ResultColumnMetadata) GetSigned() bool
func (*ResultColumnMetadata) GetSortable ¶
func (x *ResultColumnMetadata) GetSortable() bool
func (*ResultColumnMetadata) GetTableName ¶
func (x *ResultColumnMetadata) GetTableName() string
func (*ResultColumnMetadata) GetUpdatability ¶
func (x *ResultColumnMetadata) GetUpdatability() ColumnUpdatability
func (*ResultColumnMetadata) ProtoMessage ¶
func (*ResultColumnMetadata) ProtoMessage()
func (*ResultColumnMetadata) ProtoReflect ¶
func (x *ResultColumnMetadata) ProtoReflect() protoreflect.Message
func (*ResultColumnMetadata) Reset ¶
func (x *ResultColumnMetadata) Reset()
func (*ResultColumnMetadata) String ¶
func (x *ResultColumnMetadata) String() string
type RpcEndpointInfos ¶
type RpcEndpointInfos struct { Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` // example: Apache Drill Server, Apache Drill C++ client Version *string `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"` // example: 1.9.0 MajorVersion *uint32 `protobuf:"varint,3,opt,name=majorVersion" json:"majorVersion,omitempty"` // example: 1 MinorVersion *uint32 `protobuf:"varint,4,opt,name=minorVersion" json:"minorVersion,omitempty"` // example: 9 PatchVersion *uint32 `protobuf:"varint,5,opt,name=patchVersion" json:"patchVersion,omitempty"` // example: 0 Application *string `protobuf:"bytes,6,opt,name=application" json:"application,omitempty"` // example: Tableau 9.3 BuildNumber *uint32 `protobuf:"varint,7,opt,name=buildNumber" json:"buildNumber,omitempty"` // example: 32 VersionQualifier *string `protobuf:"bytes,8,opt,name=versionQualifier" json:"versionQualifier,omitempty"` // example: SNAPSHOT // contains filtered or unexported fields }
func (*RpcEndpointInfos) Descriptor
deprecated
func (*RpcEndpointInfos) Descriptor() ([]byte, []int)
Deprecated: Use RpcEndpointInfos.ProtoReflect.Descriptor instead.
func (*RpcEndpointInfos) GetApplication ¶
func (x *RpcEndpointInfos) GetApplication() string
func (*RpcEndpointInfos) GetBuildNumber ¶
func (x *RpcEndpointInfos) GetBuildNumber() uint32
func (*RpcEndpointInfos) GetMajorVersion ¶
func (x *RpcEndpointInfos) GetMajorVersion() uint32
func (*RpcEndpointInfos) GetMinorVersion ¶
func (x *RpcEndpointInfos) GetMinorVersion() uint32
func (*RpcEndpointInfos) GetName ¶
func (x *RpcEndpointInfos) GetName() string
func (*RpcEndpointInfos) GetPatchVersion ¶
func (x *RpcEndpointInfos) GetPatchVersion() uint32
func (*RpcEndpointInfos) GetVersion ¶
func (x *RpcEndpointInfos) GetVersion() string
func (*RpcEndpointInfos) GetVersionQualifier ¶
func (x *RpcEndpointInfos) GetVersionQualifier() string
func (*RpcEndpointInfos) ProtoMessage ¶
func (*RpcEndpointInfos) ProtoMessage()
func (*RpcEndpointInfos) ProtoReflect ¶
func (x *RpcEndpointInfos) ProtoReflect() protoreflect.Message
func (*RpcEndpointInfos) Reset ¶
func (x *RpcEndpointInfos) Reset()
func (*RpcEndpointInfos) String ¶
func (x *RpcEndpointInfos) String() string
type RpcType ¶
type RpcType int32
//// User <-> Bit RPC ///////
const ( RpcType_HANDSHAKE RpcType = 0 RpcType_ACK RpcType = 1 RpcType_GOODBYE RpcType = 2 // user to bit RpcType_RUN_QUERY RpcType = 3 // user is submitting a new query to the drillbit RpcType_CANCEL_QUERY RpcType = 4 // user is sending a query cancellation request to the drillbit RpcType_REQUEST_RESULTS RpcType = 5 RpcType_RESUME_PAUSED_QUERY RpcType = 11 // user is sending a query resume request to the drillbit RpcType_GET_QUERY_PLAN_FRAGMENTS RpcType = 12 // to get plan fragments from query RpcType_GET_CATALOGS RpcType = 14 // user is requesting metadata of catalog(s). RpcType_GET_SCHEMAS RpcType = 15 // user is requesting metadata of schema(s) RpcType_GET_TABLES RpcType = 16 // user is requesting metadata of table(s) RpcType_GET_COLUMNS RpcType = 17 // user is requesting metadata of column(s) RpcType_CREATE_PREPARED_STATEMENT RpcType = 22 // user is sending a request to create prepared statement RpcType_GET_SERVER_META RpcType = 8 // user is sending a request to receive server metadata // bit to user RpcType_QUERY_DATA RpcType = 6 // drillbit is sending a query result data batch to the user RpcType_QUERY_HANDLE RpcType = 7 RpcType_QUERY_PLAN_FRAGMENTS RpcType = 13 // return plan fragments RpcType_CATALOGS RpcType = 18 // return catalogs metadata in response to GET_CATALOGS RpcType_SCHEMAS RpcType = 19 // return schema metadata in response to GET_SCHEMAS RpcType_TABLES RpcType = 20 // return table metadata in response to GET_TABLES RpcType_COLUMNS RpcType = 21 // return column metadata in response to GET_COLUMNS RpcType_PREPARED_STATEMENT RpcType = 23 // return preparated statement in response to CREATE_PREPARED_STATEMENT RpcType_SERVER_META RpcType = 9 // return server infos in respose to GET_SERVER_META RpcType_QUERY_RESULT RpcType = 10 // drillbit is reporting a query status change, most likely a terminal message, to the user // user to bit and bit to user RpcType_SASL_MESSAGE RpcType = 24 )
func (RpcType) Descriptor ¶
func (RpcType) Descriptor() protoreflect.EnumDescriptor
func (RpcType) EnumDescriptor
deprecated
func (RpcType) Number ¶
func (x RpcType) Number() protoreflect.EnumNumber
func (RpcType) Type ¶
func (RpcType) Type() protoreflect.EnumType
func (*RpcType) UnmarshalJSON
deprecated
type RunQuery ¶
type RunQuery struct { ResultsMode *QueryResultsMode `protobuf:"varint,1,opt,name=results_mode,json=resultsMode,enum=exec.user.QueryResultsMode" json:"results_mode,omitempty"` Type *shared.QueryType `protobuf:"varint,2,opt,name=type,enum=exec.shared.QueryType" json:"type,omitempty"` // // Input for query type LOGICAL, PHYSICAL or SQL. Plan *string `protobuf:"bytes,3,opt,name=plan" json:"plan,omitempty"` // // Input for query type EXECUTION. Input is a set of executable fragments. Fragments []*control.PlanFragment `protobuf:"bytes,4,rep,name=fragments" json:"fragments,omitempty"` // // Input for query type PREPARED_STATEMENT. Input is a prepared statement handle // to state on server side which is returned in response to CreatePreparedStatementReq. PreparedStatementHandle *PreparedStatementHandle `protobuf:"bytes,5,opt,name=prepared_statement_handle,json=preparedStatementHandle" json:"prepared_statement_handle,omitempty"` // // Input for indicating the limit on a query's result set. AutolimitRowcount *int32 `protobuf:"varint,6,opt,name=autolimit_rowcount,json=autolimitRowcount" json:"autolimit_rowcount,omitempty"` // contains filtered or unexported fields }
Request message for running a query.
func (*RunQuery) Descriptor
deprecated
func (*RunQuery) GetAutolimitRowcount ¶
func (*RunQuery) GetFragments ¶
func (x *RunQuery) GetFragments() []*control.PlanFragment
func (*RunQuery) GetPreparedStatementHandle ¶
func (x *RunQuery) GetPreparedStatementHandle() *PreparedStatementHandle
func (*RunQuery) GetResultsMode ¶
func (x *RunQuery) GetResultsMode() QueryResultsMode
func (*RunQuery) ProtoMessage ¶
func (*RunQuery) ProtoMessage()
func (*RunQuery) ProtoReflect ¶
func (x *RunQuery) ProtoReflect() protoreflect.Message
type SaslSupport ¶
type SaslSupport int32
const ( SaslSupport_UNKNOWN_SASL_SUPPORT SaslSupport = 0 SaslSupport_SASL_AUTH SaslSupport = 1 SaslSupport_SASL_PRIVACY SaslSupport = 2 )
func (SaslSupport) Descriptor ¶
func (SaslSupport) Descriptor() protoreflect.EnumDescriptor
func (SaslSupport) Enum ¶
func (x SaslSupport) Enum() *SaslSupport
func (SaslSupport) EnumDescriptor
deprecated
func (SaslSupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use SaslSupport.Descriptor instead.
func (SaslSupport) Number ¶
func (x SaslSupport) Number() protoreflect.EnumNumber
func (SaslSupport) String ¶
func (x SaslSupport) String() string
func (SaslSupport) Type ¶
func (SaslSupport) Type() protoreflect.EnumType
func (*SaslSupport) UnmarshalJSON
deprecated
func (x *SaslSupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type SchemaMetadata ¶
type SchemaMetadata struct { CatalogName *string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName" json:"catalog_name,omitempty"` SchemaName *string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName" json:"schema_name,omitempty"` Owner *string `protobuf:"bytes,3,opt,name=owner" json:"owner,omitempty"` Type *string `protobuf:"bytes,4,opt,name=type" json:"type,omitempty"` // Type. Ex. "file", "mongodb", "hive" etc. Mutable *string `protobuf:"bytes,5,opt,name=mutable" json:"mutable,omitempty"` // contains filtered or unexported fields }
Message encapsulating metadata for a Schema.
func (*SchemaMetadata) Descriptor
deprecated
func (*SchemaMetadata) Descriptor() ([]byte, []int)
Deprecated: Use SchemaMetadata.ProtoReflect.Descriptor instead.
func (*SchemaMetadata) GetCatalogName ¶
func (x *SchemaMetadata) GetCatalogName() string
func (*SchemaMetadata) GetMutable ¶
func (x *SchemaMetadata) GetMutable() string
func (*SchemaMetadata) GetOwner ¶
func (x *SchemaMetadata) GetOwner() string
func (*SchemaMetadata) GetSchemaName ¶
func (x *SchemaMetadata) GetSchemaName() string
func (*SchemaMetadata) GetType ¶
func (x *SchemaMetadata) GetType() string
func (*SchemaMetadata) ProtoMessage ¶
func (*SchemaMetadata) ProtoMessage()
func (*SchemaMetadata) ProtoReflect ¶
func (x *SchemaMetadata) ProtoReflect() protoreflect.Message
func (*SchemaMetadata) Reset ¶
func (x *SchemaMetadata) Reset()
func (*SchemaMetadata) String ¶
func (x *SchemaMetadata) String() string
type ServerMeta ¶
type ServerMeta struct { // True if current user can use all tables returned by GetTables AllTablesSelectable *bool `protobuf:"varint,1,opt,name=all_tables_selectable,json=allTablesSelectable" json:"all_tables_selectable,omitempty"` // True if BLOB are included into the max row size BlobIncludedInMaxRowSize *bool `` /* 135-byte string literal not displayed */ // True if catalog name is at the start of a fully qualified table CatalogAtStart *bool `protobuf:"varint,3,opt,name=catalog_at_start,json=catalogAtStart" json:"catalog_at_start,omitempty"` // The catalog separator CatalogSeparator *string `protobuf:"bytes,4,opt,name=catalog_separator,json=catalogSeparator" json:"catalog_separator,omitempty"` // The term used to designate catalogs CatalogTerm *string `protobuf:"bytes,5,opt,name=catalog_term,json=catalogTerm" json:"catalog_term,omitempty"` // COLLATE support CollateSupport []CollateSupport `` /* 127-byte string literal not displayed */ // True if column aliasing is supported ColumnAliasingSupported *bool `` /* 126-byte string literal not displayed */ // CONVERT support ConvertSupport []*ConvertSupport `protobuf:"bytes,8,rep,name=convert_support,json=convertSupport" json:"convert_support,omitempty"` // Correlation names support CorrelationNamesSupport *CorrelationNamesSupport `` /* 165-byte string literal not displayed */ // Supported ODBC/JDBC Date Time scalar functions DateTimeFunctions []string `protobuf:"bytes,10,rep,name=date_time_functions,json=dateTimeFunctions" json:"date_time_functions,omitempty"` // Supported Date Time literals DateTimeLiteralsSupport []DateTimeLiteralsSupport `` /* 168-byte string literal not displayed */ // Group By support GroupBySupport *GroupBySupport `` /* 130-byte string literal not displayed */ // Unquoted Identifier casing IdentifierCasing *IdentifierCasing `` /* 136-byte string literal not displayed */ // Quote string for identifiers IdentifierQuoteString *string `protobuf:"bytes,14,opt,name=identifier_quote_string,json=identifierQuoteString" json:"identifier_quote_string,omitempty"` // True if LIKE supports an ESCAPE clause LikeEscapeClauseSupported *bool `` /* 135-byte string literal not displayed */ // Maximum number of hexa characters for binary literals (0 if unlimited or unknown) MaxBinaryLiteralLength *uint32 `` /* 126-byte string literal not displayed */ // Maximum length of catalog names (0 if unlimited or unknown) MaxCatalogNameLength *uint32 `protobuf:"varint,17,opt,name=max_catalog_name_length,json=maxCatalogNameLength" json:"max_catalog_name_length,omitempty"` // Maximum number of characters for string literals (0 if unlimited or unknown) MaxCharLiteralLength *uint32 `protobuf:"varint,18,opt,name=max_char_literal_length,json=maxCharLiteralLength" json:"max_char_literal_length,omitempty"` // Maximum length of column names (0 if unlimited or unknown) MaxColumnNameLength *uint32 `protobuf:"varint,19,opt,name=max_column_name_length,json=maxColumnNameLength" json:"max_column_name_length,omitempty"` // Maximum number of columns in GROUP BY expressions (0 if unlimited or unknown) MaxColumnsInGroupBy *uint32 `protobuf:"varint,20,opt,name=max_columns_in_group_by,json=maxColumnsInGroupBy" json:"max_columns_in_group_by,omitempty"` // Maximum number of columns in ORDER BY expressions (0 if unlimited or unknown) MaxColumnsInOrderBy *uint32 `protobuf:"varint,21,opt,name=max_columns_in_order_by,json=maxColumnsInOrderBy" json:"max_columns_in_order_by,omitempty"` // Maximum number of columns in SELECT expressions (0 if unlimited or unknown) MaxColumnsInSelect *uint32 `protobuf:"varint,22,opt,name=max_columns_in_select,json=maxColumnsInSelect" json:"max_columns_in_select,omitempty"` // Maximum length of cursor names (0 if unlimited or unknown) MaxCursorNameLength *uint32 `protobuf:"varint,23,opt,name=max_cursor_name_length,json=maxCursorNameLength" json:"max_cursor_name_length,omitempty"` // Maximum logical size for LOB types (0 if unlimited or unknown) MaxLogicalLobSize *uint32 `protobuf:"varint,24,opt,name=max_logical_lob_size,json=maxLogicalLobSize" json:"max_logical_lob_size,omitempty"` // Maximum number of bytes for a single row (0 if unlimited or unknown) MaxRowSize *uint32 `protobuf:"varint,25,opt,name=max_row_size,json=maxRowSize" json:"max_row_size,omitempty"` // Maximum length of schema names (0 if unlimited or unknown) MaxSchemaNameLength *uint32 `protobuf:"varint,26,opt,name=max_schema_name_length,json=maxSchemaNameLength" json:"max_schema_name_length,omitempty"` // Maximum length for statements (0 if unlimited or unknown) MaxStatementLength *uint32 `protobuf:"varint,27,opt,name=max_statement_length,json=maxStatementLength" json:"max_statement_length,omitempty"` // Maximum number of statements (0 if unlimited or unknown) MaxStatements *uint32 `protobuf:"varint,28,opt,name=max_statements,json=maxStatements" json:"max_statements,omitempty"` // Maximum length of table names (0 if unlimited or unknown) MaxTableNameLength *uint32 `protobuf:"varint,29,opt,name=max_table_name_length,json=maxTableNameLength" json:"max_table_name_length,omitempty"` // Maximum number of tables in a SELECT expression (0 if unlimited or unknown) MaxTablesInSelect *uint32 `protobuf:"varint,30,opt,name=max_tables_in_select,json=maxTablesInSelect" json:"max_tables_in_select,omitempty"` // Maximum length of user names (0 if unlimited or unknown) MaxUserNameLength *uint32 `protobuf:"varint,31,opt,name=max_user_name_length,json=maxUserNameLength" json:"max_user_name_length,omitempty"` // How NULL are sorted NullCollation *NullCollation `protobuf:"varint,32,opt,name=null_collation,json=nullCollation,enum=exec.user.NullCollation" json:"null_collation,omitempty"` // True if NULL + non NULL is NULL NullPlusNonNullEqualsNull *bool `` /* 139-byte string literal not displayed */ // Supported ODBC/JDBC numeric scalar functions NumericFunctions []string `protobuf:"bytes,34,rep,name=numeric_functions,json=numericFunctions" json:"numeric_functions,omitempty"` // Outer join suport OrderBySupport []OrderBySupport `` /* 130-byte string literal not displayed */ // Outer join suport OuterJoinSupport []OuterJoinSupport `` /* 138-byte string literal not displayed */ // Quoted identifier casing QuotedIdentifierCasing *IdentifierCasing `` /* 156-byte string literal not displayed */ // True if connection access is read only ReadOnly *bool `protobuf:"varint,38,opt,name=read_only,json=readOnly" json:"read_only,omitempty"` // The term used to designate a schema SchemaTerm *string `protobuf:"bytes,39,opt,name=schema_term,json=schemaTerm" json:"schema_term,omitempty"` // Characters used for escaping (empty if not suported) SearchEscapeString *string `protobuf:"bytes,40,opt,name=search_escape_string,json=searchEscapeString" json:"search_escape_string,omitempty"` // True if SELECT FOR UPDATE is supported SelectForUpdateSupported *bool `` /* 132-byte string literal not displayed */ // List of extra characters that can be used in identifier names SpecialCharacters *string `protobuf:"bytes,42,opt,name=special_characters,json=specialCharacters" json:"special_characters,omitempty"` // list of SQL keywords SqlKeywords []string `protobuf:"bytes,43,rep,name=sql_keywords,json=sqlKeywords" json:"sql_keywords,omitempty"` // Supported ODBC/JDBC string scalar functions StringFunctions []string `protobuf:"bytes,44,rep,name=string_functions,json=stringFunctions" json:"string_functions,omitempty"` // Subquery support SubquerySupport []SubQuerySupport `` /* 132-byte string literal not displayed */ // Supported ODBC/JDBC systen scalar functions SystemFunctions []string `protobuf:"bytes,46,rep,name=system_functions,json=systemFunctions" json:"system_functions,omitempty"` // The term used to designate a table TableTerm *string `protobuf:"bytes,47,opt,name=table_term,json=tableTerm" json:"table_term,omitempty"` // True if transaction is supported TransactionSupported *bool `protobuf:"varint,48,opt,name=transaction_supported,json=transactionSupported" json:"transaction_supported,omitempty"` // UNION support UnionSupport []UnionSupport `protobuf:"varint,49,rep,name=union_support,json=unionSupport,enum=exec.user.UnionSupport" json:"union_support,omitempty"` // current schema CurrentSchema *string `protobuf:"bytes,50,opt,name=current_schema,json=currentSchema" json:"current_schema,omitempty"` // contains filtered or unexported fields }
func (*ServerMeta) Descriptor
deprecated
func (*ServerMeta) Descriptor() ([]byte, []int)
Deprecated: Use ServerMeta.ProtoReflect.Descriptor instead.
func (*ServerMeta) GetAllTablesSelectable ¶
func (x *ServerMeta) GetAllTablesSelectable() bool
func (*ServerMeta) GetBlobIncludedInMaxRowSize ¶
func (x *ServerMeta) GetBlobIncludedInMaxRowSize() bool
func (*ServerMeta) GetCatalogAtStart ¶
func (x *ServerMeta) GetCatalogAtStart() bool
func (*ServerMeta) GetCatalogSeparator ¶
func (x *ServerMeta) GetCatalogSeparator() string
func (*ServerMeta) GetCatalogTerm ¶
func (x *ServerMeta) GetCatalogTerm() string
func (*ServerMeta) GetCollateSupport ¶
func (x *ServerMeta) GetCollateSupport() []CollateSupport
func (*ServerMeta) GetColumnAliasingSupported ¶
func (x *ServerMeta) GetColumnAliasingSupported() bool
func (*ServerMeta) GetConvertSupport ¶
func (x *ServerMeta) GetConvertSupport() []*ConvertSupport
func (*ServerMeta) GetCorrelationNamesSupport ¶
func (x *ServerMeta) GetCorrelationNamesSupport() CorrelationNamesSupport
func (*ServerMeta) GetCurrentSchema ¶
func (x *ServerMeta) GetCurrentSchema() string
func (*ServerMeta) GetDateTimeFunctions ¶
func (x *ServerMeta) GetDateTimeFunctions() []string
func (*ServerMeta) GetDateTimeLiteralsSupport ¶
func (x *ServerMeta) GetDateTimeLiteralsSupport() []DateTimeLiteralsSupport
func (*ServerMeta) GetGroupBySupport ¶
func (x *ServerMeta) GetGroupBySupport() GroupBySupport
func (*ServerMeta) GetIdentifierCasing ¶
func (x *ServerMeta) GetIdentifierCasing() IdentifierCasing
func (*ServerMeta) GetIdentifierQuoteString ¶
func (x *ServerMeta) GetIdentifierQuoteString() string
func (*ServerMeta) GetLikeEscapeClauseSupported ¶
func (x *ServerMeta) GetLikeEscapeClauseSupported() bool
func (*ServerMeta) GetMaxBinaryLiteralLength ¶
func (x *ServerMeta) GetMaxBinaryLiteralLength() uint32
func (*ServerMeta) GetMaxCatalogNameLength ¶
func (x *ServerMeta) GetMaxCatalogNameLength() uint32
func (*ServerMeta) GetMaxCharLiteralLength ¶
func (x *ServerMeta) GetMaxCharLiteralLength() uint32
func (*ServerMeta) GetMaxColumnNameLength ¶
func (x *ServerMeta) GetMaxColumnNameLength() uint32
func (*ServerMeta) GetMaxColumnsInGroupBy ¶
func (x *ServerMeta) GetMaxColumnsInGroupBy() uint32
func (*ServerMeta) GetMaxColumnsInOrderBy ¶
func (x *ServerMeta) GetMaxColumnsInOrderBy() uint32
func (*ServerMeta) GetMaxColumnsInSelect ¶
func (x *ServerMeta) GetMaxColumnsInSelect() uint32
func (*ServerMeta) GetMaxCursorNameLength ¶
func (x *ServerMeta) GetMaxCursorNameLength() uint32
func (*ServerMeta) GetMaxLogicalLobSize ¶
func (x *ServerMeta) GetMaxLogicalLobSize() uint32
func (*ServerMeta) GetMaxRowSize ¶
func (x *ServerMeta) GetMaxRowSize() uint32
func (*ServerMeta) GetMaxSchemaNameLength ¶
func (x *ServerMeta) GetMaxSchemaNameLength() uint32
func (*ServerMeta) GetMaxStatementLength ¶
func (x *ServerMeta) GetMaxStatementLength() uint32
func (*ServerMeta) GetMaxStatements ¶
func (x *ServerMeta) GetMaxStatements() uint32
func (*ServerMeta) GetMaxTableNameLength ¶
func (x *ServerMeta) GetMaxTableNameLength() uint32
func (*ServerMeta) GetMaxTablesInSelect ¶
func (x *ServerMeta) GetMaxTablesInSelect() uint32
func (*ServerMeta) GetMaxUserNameLength ¶
func (x *ServerMeta) GetMaxUserNameLength() uint32
func (*ServerMeta) GetNullCollation ¶
func (x *ServerMeta) GetNullCollation() NullCollation
func (*ServerMeta) GetNullPlusNonNullEqualsNull ¶
func (x *ServerMeta) GetNullPlusNonNullEqualsNull() bool
func (*ServerMeta) GetNumericFunctions ¶
func (x *ServerMeta) GetNumericFunctions() []string
func (*ServerMeta) GetOrderBySupport ¶
func (x *ServerMeta) GetOrderBySupport() []OrderBySupport
func (*ServerMeta) GetOuterJoinSupport ¶
func (x *ServerMeta) GetOuterJoinSupport() []OuterJoinSupport
func (*ServerMeta) GetQuotedIdentifierCasing ¶
func (x *ServerMeta) GetQuotedIdentifierCasing() IdentifierCasing
func (*ServerMeta) GetReadOnly ¶
func (x *ServerMeta) GetReadOnly() bool
func (*ServerMeta) GetSchemaTerm ¶
func (x *ServerMeta) GetSchemaTerm() string
func (*ServerMeta) GetSearchEscapeString ¶
func (x *ServerMeta) GetSearchEscapeString() string
func (*ServerMeta) GetSelectForUpdateSupported ¶
func (x *ServerMeta) GetSelectForUpdateSupported() bool
func (*ServerMeta) GetSpecialCharacters ¶
func (x *ServerMeta) GetSpecialCharacters() string
func (*ServerMeta) GetSqlKeywords ¶
func (x *ServerMeta) GetSqlKeywords() []string
func (*ServerMeta) GetStringFunctions ¶
func (x *ServerMeta) GetStringFunctions() []string
func (*ServerMeta) GetSubquerySupport ¶
func (x *ServerMeta) GetSubquerySupport() []SubQuerySupport
func (*ServerMeta) GetSystemFunctions ¶
func (x *ServerMeta) GetSystemFunctions() []string
func (*ServerMeta) GetTableTerm ¶
func (x *ServerMeta) GetTableTerm() string
func (*ServerMeta) GetTransactionSupported ¶
func (x *ServerMeta) GetTransactionSupported() bool
func (*ServerMeta) GetUnionSupport ¶
func (x *ServerMeta) GetUnionSupport() []UnionSupport
func (*ServerMeta) ProtoMessage ¶
func (*ServerMeta) ProtoMessage()
func (*ServerMeta) ProtoReflect ¶
func (x *ServerMeta) ProtoReflect() protoreflect.Message
func (*ServerMeta) Reset ¶
func (x *ServerMeta) Reset()
func (*ServerMeta) String ¶
func (x *ServerMeta) String() string
type SubQuerySupport ¶
type SubQuerySupport int32
const ( SubQuerySupport_SQ_UNKNOWN SubQuerySupport = 0 // Unknown support (for forward compatibility) SubQuerySupport_SQ_CORRELATED SubQuerySupport = 1 // Correlated subquery is supported SubQuerySupport_SQ_IN_COMPARISON SubQuerySupport = 2 // Subquery in comparison expression is supported SubQuerySupport_SQ_IN_EXISTS SubQuerySupport = 3 // Subquery in EXISTS expression is supported SubQuerySupport_SQ_IN_INSERT SubQuerySupport = 4 // Subquery in INSERT expression is supported SubQuerySupport_SQ_IN_QUANTIFIED SubQuerySupport = 5 // Subquery in quantified expression is supported )
func (SubQuerySupport) Descriptor ¶
func (SubQuerySupport) Descriptor() protoreflect.EnumDescriptor
func (SubQuerySupport) Enum ¶
func (x SubQuerySupport) Enum() *SubQuerySupport
func (SubQuerySupport) EnumDescriptor
deprecated
func (SubQuerySupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubQuerySupport.Descriptor instead.
func (SubQuerySupport) Number ¶
func (x SubQuerySupport) Number() protoreflect.EnumNumber
func (SubQuerySupport) String ¶
func (x SubQuerySupport) String() string
func (SubQuerySupport) Type ¶
func (SubQuerySupport) Type() protoreflect.EnumType
func (*SubQuerySupport) UnmarshalJSON
deprecated
func (x *SubQuerySupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type TableMetadata ¶
type TableMetadata struct { CatalogName *string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName" json:"catalog_name,omitempty"` SchemaName *string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName" json:"schema_name,omitempty"` TableName *string `protobuf:"bytes,3,opt,name=table_name,json=tableName" json:"table_name,omitempty"` Type *string `protobuf:"bytes,4,opt,name=type" json:"type,omitempty"` // Type. Ex. "TABLE", "VIEW" etc. // contains filtered or unexported fields }
Message encapsulating metadata for a Table.
func (*TableMetadata) Descriptor
deprecated
func (*TableMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TableMetadata.ProtoReflect.Descriptor instead.
func (*TableMetadata) GetCatalogName ¶
func (x *TableMetadata) GetCatalogName() string
func (*TableMetadata) GetSchemaName ¶
func (x *TableMetadata) GetSchemaName() string
func (*TableMetadata) GetTableName ¶
func (x *TableMetadata) GetTableName() string
func (*TableMetadata) GetType ¶
func (x *TableMetadata) GetType() string
func (*TableMetadata) ProtoMessage ¶
func (*TableMetadata) ProtoMessage()
func (*TableMetadata) ProtoReflect ¶
func (x *TableMetadata) ProtoReflect() protoreflect.Message
func (*TableMetadata) Reset ¶
func (x *TableMetadata) Reset()
func (*TableMetadata) String ¶
func (x *TableMetadata) String() string
type UnionSupport ¶
type UnionSupport int32
const ( UnionSupport_U_UNKNOWN UnionSupport = 0 // Unknown support (for forward compatibility) UnionSupport_U_UNION UnionSupport = 1 // UNION is supported UnionSupport_U_UNION_ALL UnionSupport = 2 // UNION_ALL is supported )
func (UnionSupport) Descriptor ¶
func (UnionSupport) Descriptor() protoreflect.EnumDescriptor
func (UnionSupport) Enum ¶
func (x UnionSupport) Enum() *UnionSupport
func (UnionSupport) EnumDescriptor
deprecated
func (UnionSupport) EnumDescriptor() ([]byte, []int)
Deprecated: Use UnionSupport.Descriptor instead.
func (UnionSupport) Number ¶
func (x UnionSupport) Number() protoreflect.EnumNumber
func (UnionSupport) String ¶
func (x UnionSupport) String() string
func (UnionSupport) Type ¶
func (UnionSupport) Type() protoreflect.EnumType
func (*UnionSupport) UnmarshalJSON
deprecated
func (x *UnionSupport) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type UserProperties ¶
type UserProperties struct { Properties []*Property `protobuf:"bytes,1,rep,name=properties" json:"properties,omitempty"` // contains filtered or unexported fields }
func (*UserProperties) Descriptor
deprecated
func (*UserProperties) Descriptor() ([]byte, []int)
Deprecated: Use UserProperties.ProtoReflect.Descriptor instead.
func (*UserProperties) GetProperties ¶
func (x *UserProperties) GetProperties() []*Property
func (*UserProperties) ProtoMessage ¶
func (*UserProperties) ProtoMessage()
func (*UserProperties) ProtoReflect ¶
func (x *UserProperties) ProtoReflect() protoreflect.Message
func (*UserProperties) Reset ¶
func (x *UserProperties) Reset()
func (*UserProperties) String ¶
func (x *UserProperties) String() string
type UserToBitHandshake ¶
type UserToBitHandshake struct { Channel *shared.RpcChannel `protobuf:"varint,1,opt,name=channel,enum=exec.shared.RpcChannel,def=2" json:"channel,omitempty"` SupportListening *bool `protobuf:"varint,2,opt,name=support_listening,json=supportListening" json:"support_listening,omitempty"` RpcVersion *int32 `protobuf:"varint,3,opt,name=rpc_version,json=rpcVersion" json:"rpc_version,omitempty"` Credentials *shared.UserCredentials `protobuf:"bytes,4,opt,name=credentials" json:"credentials,omitempty"` Properties *UserProperties `protobuf:"bytes,5,opt,name=properties" json:"properties,omitempty"` SupportComplexTypes *bool `protobuf:"varint,6,opt,name=support_complex_types,json=supportComplexTypes,def=0" json:"support_complex_types,omitempty"` SupportTimeout *bool `protobuf:"varint,7,opt,name=support_timeout,json=supportTimeout,def=0" json:"support_timeout,omitempty"` ClientInfos *RpcEndpointInfos `protobuf:"bytes,8,opt,name=client_infos,json=clientInfos" json:"client_infos,omitempty"` SaslSupport *SaslSupport `protobuf:"varint,9,opt,name=sasl_support,json=saslSupport,enum=exec.user.SaslSupport" json:"sasl_support,omitempty"` // contains filtered or unexported fields }
func (*UserToBitHandshake) Descriptor
deprecated
func (*UserToBitHandshake) Descriptor() ([]byte, []int)
Deprecated: Use UserToBitHandshake.ProtoReflect.Descriptor instead.
func (*UserToBitHandshake) GetChannel ¶
func (x *UserToBitHandshake) GetChannel() shared.RpcChannel
func (*UserToBitHandshake) GetClientInfos ¶
func (x *UserToBitHandshake) GetClientInfos() *RpcEndpointInfos
func (*UserToBitHandshake) GetCredentials ¶
func (x *UserToBitHandshake) GetCredentials() *shared.UserCredentials
func (*UserToBitHandshake) GetProperties ¶
func (x *UserToBitHandshake) GetProperties() *UserProperties
func (*UserToBitHandshake) GetRpcVersion ¶
func (x *UserToBitHandshake) GetRpcVersion() int32
func (*UserToBitHandshake) GetSaslSupport ¶
func (x *UserToBitHandshake) GetSaslSupport() SaslSupport
func (*UserToBitHandshake) GetSupportComplexTypes ¶
func (x *UserToBitHandshake) GetSupportComplexTypes() bool
func (*UserToBitHandshake) GetSupportListening ¶
func (x *UserToBitHandshake) GetSupportListening() bool
func (*UserToBitHandshake) GetSupportTimeout ¶
func (x *UserToBitHandshake) GetSupportTimeout() bool
func (*UserToBitHandshake) ProtoMessage ¶
func (*UserToBitHandshake) ProtoMessage()
func (*UserToBitHandshake) ProtoReflect ¶
func (x *UserToBitHandshake) ProtoReflect() protoreflect.Message
func (*UserToBitHandshake) Reset ¶
func (x *UserToBitHandshake) Reset()
func (*UserToBitHandshake) String ¶
func (x *UserToBitHandshake) String() string