user

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_UserToBitHandshake_Channel             = shared.RpcChannel_USER
	Default_UserToBitHandshake_SupportComplexTypes = bool(false)
	Default_UserToBitHandshake_SupportTimeout      = bool(false)
)

Default values for UserToBitHandshake fields.

View Source 
const (
	Default_GetQueryPlanFragments_SplitPlan = bool(false)
)

Default values for GetQueryPlanFragments fields.

Variables

View Source 
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.

View Source 
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.

View Source 
var (
	QueryResultsMode_name = map[int32]string{
		1: "STREAM_FULL",
	}
	QueryResultsMode_value = map[string]int32{
		"STREAM_FULL": 1,
	}
)

Enum value maps for QueryResultsMode.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Property.ProtoReflect.Descriptor instead.

func (*Property) GetKey 

func (x *Property) GetKey() string

func (*Property) GetValue 

func (x *Property) GetValue() string

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) ProtoReflect 

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

func (*Property) Reset 

func (x *Property) Reset()

func (*Property) String 

func (x *Property) String() string

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) Enum 

func (x RpcType) Enum() *RpcType

func (RpcType) EnumDescriptor deprecated 

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

Deprecated: Use RpcType.Descriptor instead.

func (RpcType) Number 

func (x RpcType) Number() protoreflect.EnumNumber

func (RpcType) String 

func (x RpcType) String() string

func (RpcType) Type 

func (RpcType) Type() protoreflect.EnumType

func (*RpcType) UnmarshalJSON deprecated 

func (x *RpcType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

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) Descriptor() ([]byte, []int)

Deprecated: Use RunQuery.ProtoReflect.Descriptor instead.

func (*RunQuery) GetAutolimitRowcount 

func (x *RunQuery) GetAutolimitRowcount() int32

func (*RunQuery) GetFragments 

func (x *RunQuery) GetFragments() []*control.PlanFragment

func (*RunQuery) GetPlan 

func (x *RunQuery) GetPlan() string

func (*RunQuery) GetPreparedStatementHandle 

func (x *RunQuery) GetPreparedStatementHandle() *PreparedStatementHandle

func (*RunQuery) GetResultsMode 

func (x *RunQuery) GetResultsMode() QueryResultsMode

func (*RunQuery) GetType 

func (x *RunQuery) GetType() shared.QueryType

func (*RunQuery) ProtoMessage 

func (*RunQuery) ProtoMessage()

func (*RunQuery) ProtoReflect 

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

func (*RunQuery) Reset 

func (x *RunQuery) Reset()

func (*RunQuery) String 

func (x *RunQuery) String() string

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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