common

package

Go to main page

Versions in this module

v2

v2.0.10

Aug 21, 2026

Changes in this version

+ var TPipeHeartbeatResp_PipeDegradedStatusList_DEFAULT []int32

+ var TPipeHeartbeatResp_PipeRecentFailureList_DEFAULT []map[string]int64

+ var TSStatus_ResponseData_DEFAULT []byte

+ func FunctionTypeValues() iter.Seq[FunctionType]

+ func ModelValues() iter.Seq[Model]

+ func TAggregationTypeValues() iter.Seq[TAggregationType]

+ func TConsensusGroupTypeValues() iter.Seq[TConsensusGroupType]

+ func TRegionMaintainTaskStatusValues() iter.Seq[TRegionMaintainTaskStatus]

+ func TRegionMigrateFailedTypeValues() iter.Seq[TRegionMigrateFailedType]

+ func TServiceTypeValues() iter.Seq[TServiceType]

+ func ThrottleTypeValues() iter.Seq[ThrottleType]

+ func TrainingStateValues() iter.Seq[TrainingState]

type TAINodeConfiguration

+ func (p *TAINodeConfiguration) LogValue() slog.Value

+ func (p *TAINodeConfiguration) Validate() error

type TAINodeLocation

+ func (p *TAINodeLocation) LogValue() slog.Value

+ func (p *TAINodeLocation) Validate() error

type TAggregationType

+ const TAggregationType_CORR

+ const TAggregationType_COVAR_POP

+ const TAggregationType_COVAR_SAMP

+ const TAggregationType_DELTA

+ const TAggregationType_INCREASE

+ const TAggregationType_IRATE

+ const TAggregationType_KURTOSIS

+ const TAggregationType_PERCENTILE

+ const TAggregationType_RATE

+ const TAggregationType_REGR_INTERCEPT

+ const TAggregationType_REGR_SLOPE

+ const TAggregationType_SKEWNESS

type TConfigNodeLocation

+ func (p *TConfigNodeLocation) LogValue() slog.Value

+ func (p *TConfigNodeLocation) Validate() error

type TConsensusGroupId

+ func (p *TConsensusGroupId) LogValue() slog.Value

+ func (p *TConsensusGroupId) Validate() error

type TDataNodeConfiguration

+ func (p *TDataNodeConfiguration) LogValue() slog.Value

+ func (p *TDataNodeConfiguration) Validate() error

type TDataNodeLocation

+ func (p *TDataNodeLocation) LogValue() slog.Value

+ func (p *TDataNodeLocation) Validate() error

type TEndPoint

+ func (p *TEndPoint) LogValue() slog.Value

+ func (p *TEndPoint) Validate() error

type TExternalServiceEntry

+ func (p *TExternalServiceEntry) LogValue() slog.Value

+ func (p *TExternalServiceEntry) Validate() error

type TExternalServiceListResp

+ func (p *TExternalServiceListResp) LogValue() slog.Value

+ func (p *TExternalServiceListResp) Validate() error

type TFile

+ func (p *TFile) LogValue() slog.Value

+ func (p *TFile) Validate() error

type TFilesResp

+ func (p *TFilesResp) LogValue() slog.Value

+ func (p *TFilesResp) Validate() error

type TFlushReq

+ func (p *TFlushReq) LogValue() slog.Value

+ func (p *TFlushReq) Validate() error

type TLicense

+ func (p *TLicense) LogValue() slog.Value

+ func (p *TLicense) Validate() error

type TLoadSample

+ func (p *TLoadSample) LogValue() slog.Value

+ func (p *TLoadSample) Validate() error

type TNodeLocations

+ func (p *TNodeLocations) LogValue() slog.Value

+ func (p *TNodeLocations) Validate() error

type TNodeResource

+ func (p *TNodeResource) LogValue() slog.Value

+ func (p *TNodeResource) Validate() error

type TPipeHeartbeatResp

+ PipeDegradedStatusList []int32

+ PipeRecentFailureList []map[string]int64

+ func (p *TPipeHeartbeatResp) GetPipeDegradedStatusList() []int32

+ func (p *TPipeHeartbeatResp) GetPipeRecentFailureList() []map[string]int64

+ func (p *TPipeHeartbeatResp) IsSetPipeDegradedStatusList() bool

+ func (p *TPipeHeartbeatResp) IsSetPipeRecentFailureList() bool

+ func (p *TPipeHeartbeatResp) LogValue() slog.Value

+ func (p *TPipeHeartbeatResp) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TPipeHeartbeatResp) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TPipeHeartbeatResp) Validate() error

type TRegionReplicaSet

+ func (p *TRegionReplicaSet) LogValue() slog.Value

+ func (p *TRegionReplicaSet) Validate() error

type TSStatus

+ ResponseData []byte

+ func (p *TSStatus) GetResponseData() []byte

+ func (p *TSStatus) IsSetResponseData() bool

+ func (p *TSStatus) LogValue() slog.Value

+ func (p *TSStatus) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

+ func (p *TSStatus) Validate() error

type TSchemaNode

+ func (p *TSchemaNode) LogValue() slog.Value

+ func (p *TSchemaNode) Validate() error

type TSender

+ func (p *TSender) LogValue() slog.Value

+ func (p *TSender) Validate() error

type TSeriesPartitionSlot

+ func (p *TSeriesPartitionSlot) LogValue() slog.Value

+ func (p *TSeriesPartitionSlot) Validate() error

type TServiceProvider

+ func (p *TServiceProvider) LogValue() slog.Value

+ func (p *TServiceProvider) Validate() error

type TSetConfigurationReq

+ func (p *TSetConfigurationReq) LogValue() slog.Value

+ func (p *TSetConfigurationReq) Validate() error

type TSetSpaceQuotaReq

+ func (p *TSetSpaceQuotaReq) LogValue() slog.Value

+ func (p *TSetSpaceQuotaReq) Validate() error

type TSetTTLReq

+ func (p *TSetTTLReq) LogValue() slog.Value

+ func (p *TSetTTLReq) Validate() error

type TSetThrottleQuotaReq

+ func (p *TSetThrottleQuotaReq) LogValue() slog.Value

+ func (p *TSetThrottleQuotaReq) Validate() error

type TSettleReq

+ func (p *TSettleReq) LogValue() slog.Value

+ func (p *TSettleReq) Validate() error

type TShowAppliedConfigurationsResp

+ func (p *TShowAppliedConfigurationsResp) LogValue() slog.Value

+ func (p *TShowAppliedConfigurationsResp) Validate() error

type TShowConfigurationResp

+ func (p *TShowConfigurationResp) LogValue() slog.Value

+ func (p *TShowConfigurationResp) Validate() error

type TShowConfigurationTemplateResp

+ func (p *TShowConfigurationTemplateResp) LogValue() slog.Value

+ func (p *TShowConfigurationTemplateResp) Validate() error

type TShowTTLReq

+ func (p *TShowTTLReq) LogValue() slog.Value

+ func (p *TShowTTLReq) Validate() error

type TSpaceQuota

+ func (p *TSpaceQuota) LogValue() slog.Value

+ func (p *TSpaceQuota) Validate() error

type TTestConnectionResp

+ func (p *TTestConnectionResp) LogValue() slog.Value

+ func (p *TTestConnectionResp) Validate() error

type TTestConnectionResult_

+ func (p *TTestConnectionResult_) LogValue() slog.Value

+ func (p *TTestConnectionResult_) Validate() error

type TThrottleQuota

+ func (p *TThrottleQuota) LogValue() slog.Value

+ func (p *TThrottleQuota) Validate() error

type TTimePartitionSlot

+ func (p *TTimePartitionSlot) LogValue() slog.Value

+ func (p *TTimePartitionSlot) Validate() error

type TTimedQuota

+ func (p *TTimedQuota) LogValue() slog.Value

+ func (p *TTimedQuota) Validate() error

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL