Versions in this module Expand all Collapse all v0 v0.16.1 Sep 22, 2022 Changes in this version + var GoUnusedProtection__ int + var TBinaryPredicate_Value_DEFAULT *data.TColumnValue + var TCloseParams_ScanHandle_DEFAULT string + var TCloseResult__Status_DEFAULT *status.TStatus + var TColumnDesc_Name_DEFAULT string + var TColumnDesc_Type_DEFAULT *types.TColumnType + var TGetNextParams_ScanHandle_DEFAULT string + var TGetNextResult__Eos_DEFAULT bool + var TGetNextResult__Status_DEFAULT *status.TStatus + var TOpenParams_AuthenticatedUserName_DEFAULT string + var TOpenParams_BatchSize_DEFAULT int32 + var TOpenParams_InitString_DEFAULT string + var TOpenParams_Limit_DEFAULT int64 + var TOpenParams_Predicates_DEFAULT [][]*TBinaryPredicate + var TOpenParams_QueryID_DEFAULT *types.TUniqueId + var TOpenParams_TableName_DEFAULT string + var TOpenResult__ScanHandle_DEFAULT string + var TOpenResult__Status_DEFAULT *status.TStatus + var TPrepareParams_InitString_DEFAULT string + var TPrepareParams_Predicates_DEFAULT [][]*TBinaryPredicate + var TPrepareParams_TableName_DEFAULT string + var TPrepareResult__AcceptedConjuncts_DEFAULT []int32 + var TPrepareResult__NumRowsEstimate_DEFAULT int64 + var TPrepareResult__Status_DEFAULT *status.TStatus + var TRowBatch_Cols_DEFAULT []*data.TColumnData + var TRowBatch_NumRows_DEFAULT int64 + var TTableSchema_Cols_DEFAULT []*TColumnDesc + type TBinaryPredicate struct + Col *TColumnDesc + Op *TComparisonOp + Value *data.TColumnValue + func NewTBinaryPredicate() *TBinaryPredicate + func (p *TBinaryPredicate) Equals(other *TBinaryPredicate) bool + func (p *TBinaryPredicate) GetCol() *TColumnDesc + func (p *TBinaryPredicate) GetOp() TComparisonOp + func (p *TBinaryPredicate) GetValue() *data.TColumnValue + func (p *TBinaryPredicate) IsSetCol() bool + func (p *TBinaryPredicate) IsSetOp() bool + func (p *TBinaryPredicate) IsSetValue() bool + func (p *TBinaryPredicate) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TBinaryPredicate) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TBinaryPredicate) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TBinaryPredicate) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TBinaryPredicate) String() string + func (p *TBinaryPredicate) Write(ctx context.Context, oprot thrift.TProtocol) error + type TCloseParams struct + ScanHandle *string + func NewTCloseParams() *TCloseParams + func (p *TCloseParams) Equals(other *TCloseParams) bool + func (p *TCloseParams) GetScanHandle() string + func (p *TCloseParams) IsSetScanHandle() bool + func (p *TCloseParams) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCloseParams) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCloseParams) String() string + func (p *TCloseParams) Write(ctx context.Context, oprot thrift.TProtocol) error + type TCloseResult_ struct + Status *status.TStatus + func NewTCloseResult_() *TCloseResult_ + func (p *TCloseResult_) Equals(other *TCloseResult_) bool + func (p *TCloseResult_) GetStatus() *status.TStatus + func (p *TCloseResult_) IsSetStatus() bool + func (p *TCloseResult_) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCloseResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCloseResult_) String() string + func (p *TCloseResult_) Write(ctx context.Context, oprot thrift.TProtocol) error + type TColumnDesc struct + Name *string + Type *types.TColumnType + var TBinaryPredicate_Col_DEFAULT *TColumnDesc + func NewTColumnDesc() *TColumnDesc + func (p *TColumnDesc) Equals(other *TColumnDesc) bool + func (p *TColumnDesc) GetName() string + func (p *TColumnDesc) GetType() *types.TColumnType + func (p *TColumnDesc) IsSetName() bool + func (p *TColumnDesc) IsSetType() bool + func (p *TColumnDesc) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TColumnDesc) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TColumnDesc) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TColumnDesc) String() string + func (p *TColumnDesc) Write(ctx context.Context, oprot thrift.TProtocol) error + type TComparisonOp int64 + const TComparisonOp_DISTINCT_FROM + const TComparisonOp_EQ + const TComparisonOp_GE + const TComparisonOp_GT + const TComparisonOp_LE + const TComparisonOp_LT + const TComparisonOp_NE + const TComparisonOp_NOT_DISTINCT + var TBinaryPredicate_Op_DEFAULT TComparisonOp + func TComparisonOpFromString(s string) (TComparisonOp, error) + func TComparisonOpPtr(v TComparisonOp) *TComparisonOp + func (p *TComparisonOp) Scan(value interface{}) error + func (p *TComparisonOp) UnmarshalText(text []byte) error + func (p *TComparisonOp) Value() (driver.Value, error) + func (p TComparisonOp) MarshalText() ([]byte, error) + func (p TComparisonOp) String() string + type TGetNextParams struct + ScanHandle *string + func NewTGetNextParams() *TGetNextParams + func (p *TGetNextParams) Equals(other *TGetNextParams) bool + func (p *TGetNextParams) GetScanHandle() string + func (p *TGetNextParams) IsSetScanHandle() bool + func (p *TGetNextParams) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TGetNextParams) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TGetNextParams) String() string + func (p *TGetNextParams) Write(ctx context.Context, oprot thrift.TProtocol) error + type TGetNextResult_ struct + Eos *bool + Rows *TRowBatch + Status *status.TStatus + func NewTGetNextResult_() *TGetNextResult_ + func (p *TGetNextResult_) Equals(other *TGetNextResult_) bool + func (p *TGetNextResult_) GetEos() bool + func (p *TGetNextResult_) GetRows() *TRowBatch + func (p *TGetNextResult_) GetStatus() *status.TStatus + func (p *TGetNextResult_) IsSetEos() bool + func (p *TGetNextResult_) IsSetRows() bool + func (p *TGetNextResult_) IsSetStatus() bool + func (p *TGetNextResult_) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TGetNextResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TGetNextResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TGetNextResult_) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TGetNextResult_) String() string + func (p *TGetNextResult_) Write(ctx context.Context, oprot thrift.TProtocol) error + type TOpenParams struct + AuthenticatedUserName *string + BatchSize *int32 + InitString *string + Limit *int64 + Predicates [][]*TBinaryPredicate + QueryID *types.TUniqueId + RowSchema *TTableSchema + TableName *string + func NewTOpenParams() *TOpenParams + func (p *TOpenParams) Equals(other *TOpenParams) bool + func (p *TOpenParams) GetAuthenticatedUserName() string + func (p *TOpenParams) GetBatchSize() int32 + func (p *TOpenParams) GetInitString() string + func (p *TOpenParams) GetLimit() int64 + func (p *TOpenParams) GetPredicates() [][]*TBinaryPredicate + func (p *TOpenParams) GetQueryID() *types.TUniqueId + func (p *TOpenParams) GetRowSchema() *TTableSchema + func (p *TOpenParams) GetTableName() string + func (p *TOpenParams) IsSetAuthenticatedUserName() bool + func (p *TOpenParams) IsSetBatchSize() bool + func (p *TOpenParams) IsSetInitString() bool + func (p *TOpenParams) IsSetLimit() bool + func (p *TOpenParams) IsSetPredicates() bool + func (p *TOpenParams) IsSetQueryID() bool + func (p *TOpenParams) IsSetRowSchema() bool + func (p *TOpenParams) IsSetTableName() bool + func (p *TOpenParams) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenParams) String() string + func (p *TOpenParams) Write(ctx context.Context, oprot thrift.TProtocol) error + type TOpenResult_ struct + ScanHandle *string + Status *status.TStatus + func NewTOpenResult_() *TOpenResult_ + func (p *TOpenResult_) Equals(other *TOpenResult_) bool + func (p *TOpenResult_) GetScanHandle() string + func (p *TOpenResult_) GetStatus() *status.TStatus + func (p *TOpenResult_) IsSetScanHandle() bool + func (p *TOpenResult_) IsSetStatus() bool + func (p *TOpenResult_) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TOpenResult_) String() string + func (p *TOpenResult_) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPrepareParams struct + InitString *string + Predicates [][]*TBinaryPredicate + TableName *string + func NewTPrepareParams() *TPrepareParams + func (p *TPrepareParams) Equals(other *TPrepareParams) bool + func (p *TPrepareParams) GetInitString() string + func (p *TPrepareParams) GetPredicates() [][]*TBinaryPredicate + func (p *TPrepareParams) GetTableName() string + func (p *TPrepareParams) IsSetInitString() bool + func (p *TPrepareParams) IsSetPredicates() bool + func (p *TPrepareParams) IsSetTableName() bool + func (p *TPrepareParams) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPrepareParams) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPrepareParams) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPrepareParams) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPrepareParams) String() string + func (p *TPrepareParams) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPrepareResult_ struct + AcceptedConjuncts []int32 + NumRowsEstimate *int64 + Status *status.TStatus + func NewTPrepareResult_() *TPrepareResult_ + func (p *TPrepareResult_) Equals(other *TPrepareResult_) bool + func (p *TPrepareResult_) GetAcceptedConjuncts() []int32 + func (p *TPrepareResult_) GetNumRowsEstimate() int64 + func (p *TPrepareResult_) GetStatus() *status.TStatus + func (p *TPrepareResult_) IsSetAcceptedConjuncts() bool + func (p *TPrepareResult_) IsSetNumRowsEstimate() bool + func (p *TPrepareResult_) IsSetStatus() bool + func (p *TPrepareResult_) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPrepareResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPrepareResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPrepareResult_) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPrepareResult_) String() string + func (p *TPrepareResult_) Write(ctx context.Context, oprot thrift.TProtocol) error + type TRowBatch struct + Cols []*data.TColumnData + NumRows *int64 + var TGetNextResult__Rows_DEFAULT *TRowBatch + func NewTRowBatch() *TRowBatch + func (p *TRowBatch) Equals(other *TRowBatch) bool + func (p *TRowBatch) GetCols() []*data.TColumnData + func (p *TRowBatch) GetNumRows() int64 + func (p *TRowBatch) IsSetCols() bool + func (p *TRowBatch) IsSetNumRows() bool + func (p *TRowBatch) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRowBatch) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRowBatch) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRowBatch) String() string + func (p *TRowBatch) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTableSchema struct + Cols []*TColumnDesc + var TOpenParams_RowSchema_DEFAULT *TTableSchema + func NewTTableSchema() *TTableSchema + func (p *TTableSchema) Equals(other *TTableSchema) bool + func (p *TTableSchema) GetCols() []*TColumnDesc + func (p *TTableSchema) IsSetCols() bool + func (p *TTableSchema) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTableSchema) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTableSchema) String() string + func (p *TTableSchema) Write(ctx context.Context, oprot thrift.TProtocol) error