Versions in this module Expand all Collapse all v2 v2.0.8 Mar 12, 2026 Changes in this version + var GoUnusedProtection__ int + var TFlushReq_IsSeq_DEFAULT string + var TFlushReq_RegionIds_DEFAULT []string + var TFlushReq_StorageGroups_DEFAULT []string + var TNodeLocations_ConfigNodeLocations_DEFAULT []*TConfigNodeLocation + var TNodeLocations_DataNodeLocations_DEFAULT []*TDataNodeLocation + var TPipeHeartbeatResp_PipeCompletedList_DEFAULT []bool + var TPipeHeartbeatResp_PipeRemainingEventCountList_DEFAULT []int64 + var TPipeHeartbeatResp_PipeRemainingTimeList_DEFAULT []float64 + var TSStatus_Message_DEFAULT string + var TSStatus_NeedRetry_DEFAULT bool + var TSStatus_SubStatus_DEFAULT []*TSStatus + var TShowAppliedConfigurationsResp_Data_DEFAULT map[string]string + var TSpaceQuota_DeviceNum_DEFAULT int64 + var TSpaceQuota_DiskSize_DEFAULT int64 + var TSpaceQuota_TimeserieNum_DEFAULT int64 + var TTestConnectionResult__Reason_DEFAULT string + var TThrottleQuota_CpuLimit_DEFAULT int32 + var TThrottleQuota_MemLimit_DEFAULT int64 + var TThrottleQuota_ThrottleLimit_DEFAULT map[ThrottleType]*TTimedQuota + type FunctionType int64 + const FunctionType_AGGREGATE + const FunctionType_NONE + const FunctionType_SCALAR + const FunctionType_TABLE + func FunctionTypeFromString(s string) (FunctionType, error) + func FunctionTypePtr(v FunctionType) *FunctionType + func (p *FunctionType) Scan(value interface{}) error + func (p *FunctionType) UnmarshalText(text []byte) error + func (p *FunctionType) Value() (driver.Value, error) + func (p FunctionType) MarshalText() ([]byte, error) + func (p FunctionType) String() string + type Model int64 + const Model_TABLE + const Model_TREE + func ModelFromString(s string) (Model, error) + func ModelPtr(v Model) *Model + func (p *Model) Scan(value interface{}) error + func (p *Model) UnmarshalText(text []byte) error + func (p *Model) Value() (driver.Value, error) + func (p Model) MarshalText() ([]byte, error) + func (p Model) String() string + type TAINodeConfiguration struct + Location *TAINodeLocation + Resource *TNodeResource + func NewTAINodeConfiguration() *TAINodeConfiguration + func (p *TAINodeConfiguration) Equals(other *TAINodeConfiguration) bool + func (p *TAINodeConfiguration) GetLocation() *TAINodeLocation + func (p *TAINodeConfiguration) GetResource() *TNodeResource + func (p *TAINodeConfiguration) IsSetLocation() bool + func (p *TAINodeConfiguration) IsSetResource() bool + func (p *TAINodeConfiguration) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAINodeConfiguration) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAINodeConfiguration) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAINodeConfiguration) String() string + func (p *TAINodeConfiguration) Write(ctx context.Context, oprot thrift.TProtocol) error + type TAINodeLocation struct + AiNodeId int32 + InternalEndPoint *TEndPoint + var TAINodeConfiguration_Location_DEFAULT *TAINodeLocation + func NewTAINodeLocation() *TAINodeLocation + func (p *TAINodeLocation) Equals(other *TAINodeLocation) bool + func (p *TAINodeLocation) GetAiNodeId() int32 + func (p *TAINodeLocation) GetInternalEndPoint() *TEndPoint + func (p *TAINodeLocation) IsSetInternalEndPoint() bool + func (p *TAINodeLocation) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAINodeLocation) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAINodeLocation) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TAINodeLocation) String() string + func (p *TAINodeLocation) Write(ctx context.Context, oprot thrift.TProtocol) error + type TAggregationType int64 + const TAggregationType_APPROX_COUNT_DISTINCT + const TAggregationType_APPROX_MOST_FREQUENT + const TAggregationType_APPROX_PERCENTILE + const TAggregationType_AVG + const TAggregationType_COUNT + const TAggregationType_COUNT_ALL + const TAggregationType_COUNT_IF + const TAggregationType_COUNT_TIME + const TAggregationType_EXTREME + const TAggregationType_FIRST + const TAggregationType_FIRST_BY + const TAggregationType_FIRST_VALUE + const TAggregationType_LAST + const TAggregationType_LAST_BY + const TAggregationType_LAST_VALUE + const TAggregationType_MAX + const TAggregationType_MAX_BY + const TAggregationType_MAX_TIME + const TAggregationType_MAX_VALUE + const TAggregationType_MIN + const TAggregationType_MIN_BY + const TAggregationType_MIN_TIME + const TAggregationType_MIN_VALUE + const TAggregationType_MODE + const TAggregationType_STDDEV + const TAggregationType_STDDEV_POP + const TAggregationType_STDDEV_SAMP + const TAggregationType_SUM + const TAggregationType_TIME_DURATION + const TAggregationType_UDAF + const TAggregationType_VARIANCE + const TAggregationType_VAR_POP + const TAggregationType_VAR_SAMP + func TAggregationTypeFromString(s string) (TAggregationType, error) + func TAggregationTypePtr(v TAggregationType) *TAggregationType + func (p *TAggregationType) Scan(value interface{}) error + func (p *TAggregationType) UnmarshalText(text []byte) error + func (p *TAggregationType) Value() (driver.Value, error) + func (p TAggregationType) MarshalText() ([]byte, error) + func (p TAggregationType) String() string + type TConfigNodeLocation struct + ConfigNodeId int32 + ConsensusEndPoint *TEndPoint + InternalEndPoint *TEndPoint + var TSender_ConfigNodeLocation_DEFAULT *TConfigNodeLocation + func NewTConfigNodeLocation() *TConfigNodeLocation + func (p *TConfigNodeLocation) Equals(other *TConfigNodeLocation) bool + func (p *TConfigNodeLocation) GetConfigNodeId() int32 + func (p *TConfigNodeLocation) GetConsensusEndPoint() *TEndPoint + func (p *TConfigNodeLocation) GetInternalEndPoint() *TEndPoint + func (p *TConfigNodeLocation) IsSetConsensusEndPoint() bool + func (p *TConfigNodeLocation) IsSetInternalEndPoint() bool + func (p *TConfigNodeLocation) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TConfigNodeLocation) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TConfigNodeLocation) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TConfigNodeLocation) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TConfigNodeLocation) String() string + func (p *TConfigNodeLocation) Write(ctx context.Context, oprot thrift.TProtocol) error + type TConsensusGroupId struct + ID int32 + Type TConsensusGroupType + var TRegionReplicaSet_RegionId_DEFAULT *TConsensusGroupId + func NewTConsensusGroupId() *TConsensusGroupId + func (p *TConsensusGroupId) Equals(other *TConsensusGroupId) bool + func (p *TConsensusGroupId) GetID() int32 + func (p *TConsensusGroupId) GetType() TConsensusGroupType + func (p *TConsensusGroupId) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TConsensusGroupId) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TConsensusGroupId) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TConsensusGroupId) String() string + func (p *TConsensusGroupId) Write(ctx context.Context, oprot thrift.TProtocol) error + type TConsensusGroupType int64 + const TConsensusGroupType_ConfigRegion + const TConsensusGroupType_DataRegion + const TConsensusGroupType_SchemaRegion + func TConsensusGroupTypeFromString(s string) (TConsensusGroupType, error) + func TConsensusGroupTypePtr(v TConsensusGroupType) *TConsensusGroupType + func (p *TConsensusGroupType) Scan(value interface{}) error + func (p *TConsensusGroupType) UnmarshalText(text []byte) error + func (p *TConsensusGroupType) Value() (driver.Value, error) + func (p TConsensusGroupType) MarshalText() ([]byte, error) + func (p TConsensusGroupType) String() string + type TDataNodeConfiguration struct + Location *TDataNodeLocation + Resource *TNodeResource + func NewTDataNodeConfiguration() *TDataNodeConfiguration + func (p *TDataNodeConfiguration) Equals(other *TDataNodeConfiguration) bool + func (p *TDataNodeConfiguration) GetLocation() *TDataNodeLocation + func (p *TDataNodeConfiguration) GetResource() *TNodeResource + func (p *TDataNodeConfiguration) IsSetLocation() bool + func (p *TDataNodeConfiguration) IsSetResource() bool + func (p *TDataNodeConfiguration) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeConfiguration) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeConfiguration) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeConfiguration) String() string + func (p *TDataNodeConfiguration) Write(ctx context.Context, oprot thrift.TProtocol) error + type TDataNodeLocation struct + ClientRpcEndPoint *TEndPoint + DataNodeId int32 + DataRegionConsensusEndPoint *TEndPoint + InternalEndPoint *TEndPoint + MPPDataExchangeEndPoint *TEndPoint + SchemaRegionConsensusEndPoint *TEndPoint + var TDataNodeConfiguration_Location_DEFAULT *TDataNodeLocation + var TSender_DataNodeLocation_DEFAULT *TDataNodeLocation + func NewTDataNodeLocation() *TDataNodeLocation + func (p *TDataNodeLocation) Equals(other *TDataNodeLocation) bool + func (p *TDataNodeLocation) GetClientRpcEndPoint() *TEndPoint + func (p *TDataNodeLocation) GetDataNodeId() int32 + func (p *TDataNodeLocation) GetDataRegionConsensusEndPoint() *TEndPoint + func (p *TDataNodeLocation) GetInternalEndPoint() *TEndPoint + func (p *TDataNodeLocation) GetMPPDataExchangeEndPoint() *TEndPoint + func (p *TDataNodeLocation) GetSchemaRegionConsensusEndPoint() *TEndPoint + func (p *TDataNodeLocation) IsSetClientRpcEndPoint() bool + func (p *TDataNodeLocation) IsSetDataRegionConsensusEndPoint() bool + func (p *TDataNodeLocation) IsSetInternalEndPoint() bool + func (p *TDataNodeLocation) IsSetMPPDataExchangeEndPoint() bool + func (p *TDataNodeLocation) IsSetSchemaRegionConsensusEndPoint() bool + func (p *TDataNodeLocation) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeLocation) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeLocation) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeLocation) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeLocation) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeLocation) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeLocation) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TDataNodeLocation) String() string + func (p *TDataNodeLocation) Write(ctx context.Context, oprot thrift.TProtocol) error + type TEndPoint struct + IP string + Port int32 + var TAINodeLocation_InternalEndPoint_DEFAULT *TEndPoint + var TConfigNodeLocation_ConsensusEndPoint_DEFAULT *TEndPoint + var TConfigNodeLocation_InternalEndPoint_DEFAULT *TEndPoint + var TDataNodeLocation_ClientRpcEndPoint_DEFAULT *TEndPoint + var TDataNodeLocation_DataRegionConsensusEndPoint_DEFAULT *TEndPoint + var TDataNodeLocation_InternalEndPoint_DEFAULT *TEndPoint + var TDataNodeLocation_MPPDataExchangeEndPoint_DEFAULT *TEndPoint + var TDataNodeLocation_SchemaRegionConsensusEndPoint_DEFAULT *TEndPoint + var TSStatus_RedirectNode_DEFAULT *TEndPoint + var TServiceProvider_EndPoint_DEFAULT *TEndPoint + func NewTEndPoint() *TEndPoint + func (p *TEndPoint) Equals(other *TEndPoint) bool + func (p *TEndPoint) GetIP() string + func (p *TEndPoint) GetPort() int32 + func (p *TEndPoint) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TEndPoint) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TEndPoint) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TEndPoint) String() string + func (p *TEndPoint) Write(ctx context.Context, oprot thrift.TProtocol) error + type TExternalServiceEntry struct + ClassName string + DataNodeId int32 + ServiceName string + ServiceType int8 + State int8 + func NewTExternalServiceEntry() *TExternalServiceEntry + func (p *TExternalServiceEntry) Equals(other *TExternalServiceEntry) bool + func (p *TExternalServiceEntry) GetClassName() string + func (p *TExternalServiceEntry) GetDataNodeId() int32 + func (p *TExternalServiceEntry) GetServiceName() string + func (p *TExternalServiceEntry) GetServiceType() int8 + func (p *TExternalServiceEntry) GetState() int8 + func (p *TExternalServiceEntry) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceEntry) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceEntry) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceEntry) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceEntry) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceEntry) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceEntry) String() string + func (p *TExternalServiceEntry) Write(ctx context.Context, oprot thrift.TProtocol) error + type TExternalServiceListResp struct + ExternalServiceInfos []*TExternalServiceEntry + Status *TSStatus + func NewTExternalServiceListResp() *TExternalServiceListResp + func (p *TExternalServiceListResp) Equals(other *TExternalServiceListResp) bool + func (p *TExternalServiceListResp) GetExternalServiceInfos() []*TExternalServiceEntry + func (p *TExternalServiceListResp) GetStatus() *TSStatus + func (p *TExternalServiceListResp) IsSetStatus() bool + func (p *TExternalServiceListResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceListResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceListResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExternalServiceListResp) String() string + func (p *TExternalServiceListResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TFile struct + File []byte + FileName string + func NewTFile() *TFile + func (p *TFile) Equals(other *TFile) bool + func (p *TFile) GetFile() []byte + func (p *TFile) GetFileName() string + func (p *TFile) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFile) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFile) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFile) String() string + func (p *TFile) Write(ctx context.Context, oprot thrift.TProtocol) error + type TFilesResp struct + Files []*TFile + Status *TSStatus + func NewTFilesResp() *TFilesResp + func (p *TFilesResp) Equals(other *TFilesResp) bool + func (p *TFilesResp) GetFiles() []*TFile + func (p *TFilesResp) GetStatus() *TSStatus + func (p *TFilesResp) IsSetStatus() bool + func (p *TFilesResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFilesResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFilesResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFilesResp) String() string + func (p *TFilesResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TFlushReq struct + IsSeq *string + RegionIds []string + StorageGroups []string + func NewTFlushReq() *TFlushReq + func (p *TFlushReq) Equals(other *TFlushReq) bool + func (p *TFlushReq) GetIsSeq() string + func (p *TFlushReq) GetRegionIds() []string + func (p *TFlushReq) GetStorageGroups() []string + func (p *TFlushReq) IsSetIsSeq() bool + func (p *TFlushReq) IsSetRegionIds() bool + func (p *TFlushReq) IsSetStorageGroups() bool + func (p *TFlushReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFlushReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFlushReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFlushReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TFlushReq) String() string + func (p *TFlushReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TLicense struct + CpuCoreNumLimit int32 + DataNodeNumLimit int16 + DeviceNumLimit int64 + DisconnectionFromActiveNodeTimeLimit int64 + ExpireTimestamp int64 + LicenseIssueTimestamp int64 + MlNodeNumLimit int16 + SensorNumLimit int64 + func NewTLicense() *TLicense + func (p *TLicense) Equals(other *TLicense) bool + func (p *TLicense) GetCpuCoreNumLimit() int32 + func (p *TLicense) GetDataNodeNumLimit() int16 + func (p *TLicense) GetDeviceNumLimit() int64 + func (p *TLicense) GetDisconnectionFromActiveNodeTimeLimit() int64 + func (p *TLicense) GetExpireTimestamp() int64 + func (p *TLicense) GetLicenseIssueTimestamp() int64 + func (p *TLicense) GetMlNodeNumLimit() int16 + func (p *TLicense) GetSensorNumLimit() int64 + func (p *TLicense) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLicense) String() string + func (p *TLicense) Write(ctx context.Context, oprot thrift.TProtocol) error + type TLoadSample struct + CpuUsageRate float64 + DiskUsageRate float64 + FreeDiskSpace float64 + MemoryUsageRate float64 + func NewTLoadSample() *TLoadSample + func (p *TLoadSample) Equals(other *TLoadSample) bool + func (p *TLoadSample) GetCpuUsageRate() float64 + func (p *TLoadSample) GetDiskUsageRate() float64 + func (p *TLoadSample) GetFreeDiskSpace() float64 + func (p *TLoadSample) GetMemoryUsageRate() float64 + func (p *TLoadSample) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLoadSample) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLoadSample) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLoadSample) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLoadSample) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TLoadSample) String() string + func (p *TLoadSample) Write(ctx context.Context, oprot thrift.TProtocol) error + type TNodeLocations struct + ConfigNodeLocations []*TConfigNodeLocation + DataNodeLocations []*TDataNodeLocation + func NewTNodeLocations() *TNodeLocations + func (p *TNodeLocations) Equals(other *TNodeLocations) bool + func (p *TNodeLocations) GetConfigNodeLocations() []*TConfigNodeLocation + func (p *TNodeLocations) GetDataNodeLocations() []*TDataNodeLocation + func (p *TNodeLocations) IsSetConfigNodeLocations() bool + func (p *TNodeLocations) IsSetDataNodeLocations() bool + func (p *TNodeLocations) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TNodeLocations) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TNodeLocations) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TNodeLocations) String() string + func (p *TNodeLocations) Write(ctx context.Context, oprot thrift.TProtocol) error + type TNodeResource struct + CpuCoreNum int32 + MaxMemory int64 + var TAINodeConfiguration_Resource_DEFAULT *TNodeResource + var TDataNodeConfiguration_Resource_DEFAULT *TNodeResource + func NewTNodeResource() *TNodeResource + func (p *TNodeResource) Equals(other *TNodeResource) bool + func (p *TNodeResource) GetCpuCoreNum() int32 + func (p *TNodeResource) GetMaxMemory() int64 + func (p *TNodeResource) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TNodeResource) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TNodeResource) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TNodeResource) String() string + func (p *TNodeResource) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPipeHeartbeatResp struct + PipeCompletedList []bool + PipeMetaList [][]byte + PipeRemainingEventCountList []int64 + PipeRemainingTimeList []float64 + func NewTPipeHeartbeatResp() *TPipeHeartbeatResp + func (p *TPipeHeartbeatResp) Equals(other *TPipeHeartbeatResp) bool + func (p *TPipeHeartbeatResp) GetPipeCompletedList() []bool + func (p *TPipeHeartbeatResp) GetPipeMetaList() [][]byte + func (p *TPipeHeartbeatResp) GetPipeRemainingEventCountList() []int64 + func (p *TPipeHeartbeatResp) GetPipeRemainingTimeList() []float64 + func (p *TPipeHeartbeatResp) IsSetPipeCompletedList() bool + func (p *TPipeHeartbeatResp) IsSetPipeRemainingEventCountList() bool + func (p *TPipeHeartbeatResp) IsSetPipeRemainingTimeList() bool + func (p *TPipeHeartbeatResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeHeartbeatResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeHeartbeatResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeHeartbeatResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeHeartbeatResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeHeartbeatResp) String() string + func (p *TPipeHeartbeatResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TRegionMaintainTaskStatus int64 + const TRegionMaintainTaskStatus_FAIL + const TRegionMaintainTaskStatus_PROCESSING + const TRegionMaintainTaskStatus_SUCCESS + const TRegionMaintainTaskStatus_TASK_NOT_EXIST + func TRegionMaintainTaskStatusFromString(s string) (TRegionMaintainTaskStatus, error) + func TRegionMaintainTaskStatusPtr(v TRegionMaintainTaskStatus) *TRegionMaintainTaskStatus + func (p *TRegionMaintainTaskStatus) Scan(value interface{}) error + func (p *TRegionMaintainTaskStatus) UnmarshalText(text []byte) error + func (p *TRegionMaintainTaskStatus) Value() (driver.Value, error) + func (p TRegionMaintainTaskStatus) MarshalText() ([]byte, error) + func (p TRegionMaintainTaskStatus) String() string + type TRegionMigrateFailedType int64 + const TRegionMigrateFailedType_AddPeerFailed + const TRegionMigrateFailedType_CreateRegionFailed + const TRegionMigrateFailedType_DeleteRegionFailed + const TRegionMigrateFailedType_Disconnect + const TRegionMigrateFailedType_RemoveConsensusGroupFailed + const TRegionMigrateFailedType_RemovePeerFailed + func TRegionMigrateFailedTypeFromString(s string) (TRegionMigrateFailedType, error) + func TRegionMigrateFailedTypePtr(v TRegionMigrateFailedType) *TRegionMigrateFailedType + func (p *TRegionMigrateFailedType) Scan(value interface{}) error + func (p *TRegionMigrateFailedType) UnmarshalText(text []byte) error + func (p *TRegionMigrateFailedType) Value() (driver.Value, error) + func (p TRegionMigrateFailedType) MarshalText() ([]byte, error) + func (p TRegionMigrateFailedType) String() string + type TRegionReplicaSet struct + DataNodeLocations []*TDataNodeLocation + RegionId *TConsensusGroupId + func NewTRegionReplicaSet() *TRegionReplicaSet + func (p *TRegionReplicaSet) Equals(other *TRegionReplicaSet) bool + func (p *TRegionReplicaSet) GetDataNodeLocations() []*TDataNodeLocation + func (p *TRegionReplicaSet) GetRegionId() *TConsensusGroupId + func (p *TRegionReplicaSet) IsSetRegionId() bool + func (p *TRegionReplicaSet) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegionReplicaSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegionReplicaSet) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TRegionReplicaSet) String() string + func (p *TRegionReplicaSet) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSStatus struct + Code int32 + Message *string + NeedRetry *bool + RedirectNode *TEndPoint + SubStatus []*TSStatus + var TExternalServiceListResp_Status_DEFAULT *TSStatus + var TFilesResp_Status_DEFAULT *TSStatus + var TShowAppliedConfigurationsResp_Status_DEFAULT *TSStatus + var TShowConfigurationResp_Status_DEFAULT *TSStatus + var TShowConfigurationTemplateResp_Status_DEFAULT *TSStatus + var TTestConnectionResp_Status_DEFAULT *TSStatus + func NewTSStatus() *TSStatus + func (p *TSStatus) Equals(other *TSStatus) bool + func (p *TSStatus) GetCode() int32 + func (p *TSStatus) GetMessage() string + func (p *TSStatus) GetNeedRetry() bool + func (p *TSStatus) GetRedirectNode() *TEndPoint + func (p *TSStatus) GetSubStatus() []*TSStatus + func (p *TSStatus) IsSetMessage() bool + func (p *TSStatus) IsSetNeedRetry() bool + func (p *TSStatus) IsSetRedirectNode() bool + func (p *TSStatus) IsSetSubStatus() bool + func (p *TSStatus) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSStatus) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSStatus) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSStatus) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSStatus) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSStatus) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSStatus) String() string + func (p *TSStatus) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSchemaNode struct + NodeName string + NodeType int8 + func NewTSchemaNode() *TSchemaNode + func (p *TSchemaNode) Equals(other *TSchemaNode) bool + func (p *TSchemaNode) GetNodeName() string + func (p *TSchemaNode) GetNodeType() int8 + func (p *TSchemaNode) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSchemaNode) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSchemaNode) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSchemaNode) String() string + func (p *TSchemaNode) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSender struct + ConfigNodeLocation *TConfigNodeLocation + DataNodeLocation *TDataNodeLocation + var TTestConnectionResult__Sender_DEFAULT *TSender + func NewTSender() *TSender + func (p *TSender) Equals(other *TSender) bool + func (p *TSender) GetConfigNodeLocation() *TConfigNodeLocation + func (p *TSender) GetDataNodeLocation() *TDataNodeLocation + func (p *TSender) IsSetConfigNodeLocation() bool + func (p *TSender) IsSetDataNodeLocation() bool + func (p *TSender) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSender) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSender) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSender) String() string + func (p *TSender) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSeriesPartitionSlot struct + SlotId int32 + func NewTSeriesPartitionSlot() *TSeriesPartitionSlot + func (p *TSeriesPartitionSlot) Equals(other *TSeriesPartitionSlot) bool + func (p *TSeriesPartitionSlot) GetSlotId() int32 + func (p *TSeriesPartitionSlot) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSeriesPartitionSlot) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSeriesPartitionSlot) String() string + func (p *TSeriesPartitionSlot) Write(ctx context.Context, oprot thrift.TProtocol) error + type TServiceProvider struct + EndPoint *TEndPoint + NodeId int32 + ServiceType TServiceType + var TTestConnectionResult__ServiceProvider_DEFAULT *TServiceProvider + func NewTServiceProvider() *TServiceProvider + func (p *TServiceProvider) Equals(other *TServiceProvider) bool + func (p *TServiceProvider) GetEndPoint() *TEndPoint + func (p *TServiceProvider) GetNodeId() int32 + func (p *TServiceProvider) GetServiceType() TServiceType + func (p *TServiceProvider) IsSetEndPoint() bool + func (p *TServiceProvider) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TServiceProvider) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TServiceProvider) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TServiceProvider) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TServiceProvider) String() string + func (p *TServiceProvider) Write(ctx context.Context, oprot thrift.TProtocol) error + type TServiceType int64 + const TServiceType_ConfigNodeInternalService + const TServiceType_DataNodeExternalService + const TServiceType_DataNodeInternalService + const TServiceType_DataNodeMPPService + func TServiceTypeFromString(s string) (TServiceType, error) + func TServiceTypePtr(v TServiceType) *TServiceType + func (p *TServiceType) Scan(value interface{}) error + func (p *TServiceType) UnmarshalText(text []byte) error + func (p *TServiceType) Value() (driver.Value, error) + func (p TServiceType) MarshalText() ([]byte, error) + func (p TServiceType) String() string + type TSetConfigurationReq struct + Configs map[string]string + NodeId int32 + func NewTSetConfigurationReq() *TSetConfigurationReq + func (p *TSetConfigurationReq) Equals(other *TSetConfigurationReq) bool + func (p *TSetConfigurationReq) GetConfigs() map[string]string + func (p *TSetConfigurationReq) GetNodeId() int32 + func (p *TSetConfigurationReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetConfigurationReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetConfigurationReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetConfigurationReq) String() string + func (p *TSetConfigurationReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSetSpaceQuotaReq struct + Database []string + SpaceLimit *TSpaceQuota + func NewTSetSpaceQuotaReq() *TSetSpaceQuotaReq + func (p *TSetSpaceQuotaReq) Equals(other *TSetSpaceQuotaReq) bool + func (p *TSetSpaceQuotaReq) GetDatabase() []string + func (p *TSetSpaceQuotaReq) GetSpaceLimit() *TSpaceQuota + func (p *TSetSpaceQuotaReq) IsSetSpaceLimit() bool + func (p *TSetSpaceQuotaReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetSpaceQuotaReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetSpaceQuotaReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetSpaceQuotaReq) String() string + func (p *TSetSpaceQuotaReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSetTTLReq struct + IsDataBase bool + PathPattern []string + TTL int64 + func NewTSetTTLReq() *TSetTTLReq + func (p *TSetTTLReq) Equals(other *TSetTTLReq) bool + func (p *TSetTTLReq) GetIsDataBase() bool + func (p *TSetTTLReq) GetPathPattern() []string + func (p *TSetTTLReq) GetTTL() int64 + func (p *TSetTTLReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetTTLReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetTTLReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetTTLReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetTTLReq) String() string + func (p *TSetTTLReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSetThrottleQuotaReq struct + ThrottleQuota *TThrottleQuota + UserName string + func NewTSetThrottleQuotaReq() *TSetThrottleQuotaReq + func (p *TSetThrottleQuotaReq) Equals(other *TSetThrottleQuotaReq) bool + func (p *TSetThrottleQuotaReq) GetThrottleQuota() *TThrottleQuota + func (p *TSetThrottleQuotaReq) GetUserName() string + func (p *TSetThrottleQuotaReq) IsSetThrottleQuota() bool + func (p *TSetThrottleQuotaReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetThrottleQuotaReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetThrottleQuotaReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSetThrottleQuotaReq) String() string + func (p *TSetThrottleQuotaReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSettleReq struct + Paths []string + func NewTSettleReq() *TSettleReq + func (p *TSettleReq) Equals(other *TSettleReq) bool + func (p *TSettleReq) GetPaths() []string + func (p *TSettleReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSettleReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSettleReq) String() string + func (p *TSettleReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TShowAppliedConfigurationsResp struct + Data map[string]string + Status *TSStatus + func NewTShowAppliedConfigurationsResp() *TShowAppliedConfigurationsResp + func (p *TShowAppliedConfigurationsResp) Equals(other *TShowAppliedConfigurationsResp) bool + func (p *TShowAppliedConfigurationsResp) GetData() map[string]string + func (p *TShowAppliedConfigurationsResp) GetStatus() *TSStatus + func (p *TShowAppliedConfigurationsResp) IsSetData() bool + func (p *TShowAppliedConfigurationsResp) IsSetStatus() bool + func (p *TShowAppliedConfigurationsResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowAppliedConfigurationsResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowAppliedConfigurationsResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowAppliedConfigurationsResp) String() string + func (p *TShowAppliedConfigurationsResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TShowConfigurationResp struct + Content string + Status *TSStatus + func NewTShowConfigurationResp() *TShowConfigurationResp + func (p *TShowConfigurationResp) Equals(other *TShowConfigurationResp) bool + func (p *TShowConfigurationResp) GetContent() string + func (p *TShowConfigurationResp) GetStatus() *TSStatus + func (p *TShowConfigurationResp) IsSetStatus() bool + func (p *TShowConfigurationResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowConfigurationResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowConfigurationResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowConfigurationResp) String() string + func (p *TShowConfigurationResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TShowConfigurationTemplateResp struct + Content string + Status *TSStatus + func NewTShowConfigurationTemplateResp() *TShowConfigurationTemplateResp + func (p *TShowConfigurationTemplateResp) Equals(other *TShowConfigurationTemplateResp) bool + func (p *TShowConfigurationTemplateResp) GetContent() string + func (p *TShowConfigurationTemplateResp) GetStatus() *TSStatus + func (p *TShowConfigurationTemplateResp) IsSetStatus() bool + func (p *TShowConfigurationTemplateResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowConfigurationTemplateResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowConfigurationTemplateResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowConfigurationTemplateResp) String() string + func (p *TShowConfigurationTemplateResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TShowTTLReq struct + PathPattern []string + func NewTShowTTLReq() *TShowTTLReq + func (p *TShowTTLReq) Equals(other *TShowTTLReq) bool + func (p *TShowTTLReq) GetPathPattern() []string + func (p *TShowTTLReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowTTLReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TShowTTLReq) String() string + func (p *TShowTTLReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSpaceQuota struct + DeviceNum *int64 + DiskSize *int64 + TimeserieNum *int64 + var TSetSpaceQuotaReq_SpaceLimit_DEFAULT *TSpaceQuota + func NewTSpaceQuota() *TSpaceQuota + func (p *TSpaceQuota) Equals(other *TSpaceQuota) bool + func (p *TSpaceQuota) GetDeviceNum() int64 + func (p *TSpaceQuota) GetDiskSize() int64 + func (p *TSpaceQuota) GetTimeserieNum() int64 + func (p *TSpaceQuota) IsSetDeviceNum() bool + func (p *TSpaceQuota) IsSetDiskSize() bool + func (p *TSpaceQuota) IsSetTimeserieNum() bool + func (p *TSpaceQuota) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSpaceQuota) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSpaceQuota) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSpaceQuota) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSpaceQuota) String() string + func (p *TSpaceQuota) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTestConnectionResp struct + ResultList []*TTestConnectionResult_ + Status *TSStatus + func NewTTestConnectionResp() *TTestConnectionResp + func (p *TTestConnectionResp) Equals(other *TTestConnectionResp) bool + func (p *TTestConnectionResp) GetResultList() []*TTestConnectionResult_ + func (p *TTestConnectionResp) GetStatus() *TSStatus + func (p *TTestConnectionResp) IsSetStatus() bool + func (p *TTestConnectionResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTestConnectionResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTestConnectionResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTestConnectionResp) String() string + func (p *TTestConnectionResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTestConnectionResult_ struct + Reason *string + Sender *TSender + ServiceProvider *TServiceProvider + Success bool + func NewTTestConnectionResult_() *TTestConnectionResult_ + func (p *TTestConnectionResult_) Equals(other *TTestConnectionResult_) bool + func (p *TTestConnectionResult_) GetReason() string + func (p *TTestConnectionResult_) GetSender() *TSender + func (p *TTestConnectionResult_) GetServiceProvider() *TServiceProvider + func (p *TTestConnectionResult_) GetSuccess() bool + func (p *TTestConnectionResult_) IsSetReason() bool + func (p *TTestConnectionResult_) IsSetSender() bool + func (p *TTestConnectionResult_) IsSetServiceProvider() bool + func (p *TTestConnectionResult_) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTestConnectionResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTestConnectionResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTestConnectionResult_) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTestConnectionResult_) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTestConnectionResult_) String() string + func (p *TTestConnectionResult_) Write(ctx context.Context, oprot thrift.TProtocol) error + type TThrottleQuota struct + CpuLimit *int32 + MemLimit *int64 + ThrottleLimit map[ThrottleType]*TTimedQuota + var TSetThrottleQuotaReq_ThrottleQuota_DEFAULT *TThrottleQuota + func NewTThrottleQuota() *TThrottleQuota + func (p *TThrottleQuota) Equals(other *TThrottleQuota) bool + func (p *TThrottleQuota) GetCpuLimit() int32 + func (p *TThrottleQuota) GetMemLimit() int64 + func (p *TThrottleQuota) GetThrottleLimit() map[ThrottleType]*TTimedQuota + func (p *TThrottleQuota) IsSetCpuLimit() bool + func (p *TThrottleQuota) IsSetMemLimit() bool + func (p *TThrottleQuota) IsSetThrottleLimit() bool + func (p *TThrottleQuota) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TThrottleQuota) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TThrottleQuota) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TThrottleQuota) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TThrottleQuota) String() string + func (p *TThrottleQuota) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTimePartitionSlot struct + StartTime int64 + func NewTTimePartitionSlot() *TTimePartitionSlot + func (p *TTimePartitionSlot) Equals(other *TTimePartitionSlot) bool + func (p *TTimePartitionSlot) GetStartTime() int64 + func (p *TTimePartitionSlot) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimePartitionSlot) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimePartitionSlot) String() string + func (p *TTimePartitionSlot) Write(ctx context.Context, oprot thrift.TProtocol) error + type TTimedQuota struct + SoftLimit int64 + TimeUnit int64 + func NewTTimedQuota() *TTimedQuota + func (p *TTimedQuota) Equals(other *TTimedQuota) bool + func (p *TTimedQuota) GetSoftLimit() int64 + func (p *TTimedQuota) GetTimeUnit() int64 + func (p *TTimedQuota) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimedQuota) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimedQuota) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TTimedQuota) String() string + func (p *TTimedQuota) Write(ctx context.Context, oprot thrift.TProtocol) error + type ThrottleType int64 + const ThrottleType_READ_NUMBER + const ThrottleType_READ_SIZE + const ThrottleType_REQUEST_NUMBER + const ThrottleType_REQUEST_SIZE + const ThrottleType_WRITE_NUMBER + const ThrottleType_WRITE_SIZE + func ThrottleTypeFromString(s string) (ThrottleType, error) + func ThrottleTypePtr(v ThrottleType) *ThrottleType + func (p *ThrottleType) Scan(value interface{}) error + func (p *ThrottleType) UnmarshalText(text []byte) error + func (p *ThrottleType) Value() (driver.Value, error) + func (p ThrottleType) MarshalText() ([]byte, error) + func (p ThrottleType) String() string + type TrainingState int64 + const TrainingState_DROPPING + const TrainingState_FAILED + const TrainingState_FINISHED + const TrainingState_PENDING + const TrainingState_RUNNING + func TrainingStateFromString(s string) (TrainingState, error) + func TrainingStatePtr(v TrainingState) *TrainingState + func (p *TrainingState) Scan(value interface{}) error + func (p *TrainingState) UnmarshalText(text []byte) error + func (p *TrainingState) Value() (driver.Value, error) + func (p TrainingState) MarshalText() ([]byte, error) + func (p TrainingState) String() string v2.0.3-1 Jun 20, 2025 Other modules containing this package github.com/apache/iotdb-client-go
Go to main page