common

package

Go to main page

Versions in this module

v1

v1.3.4

Apr 14, 2025

Changes in this version

+ var TFlushReq_RegionIds_DEFAULT []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 TEndPoint

+ var TAINodeLocation_InternalEndPoint_DEFAULT *TEndPoint

type TFlushReq

+ RegionIds []string

+ func (p *TFlushReq) GetRegionIds() []string

+ func (p *TFlushReq) IsSetRegionIds() bool

+ func (p *TFlushReq) ReadField3(ctx context.Context, iprot 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 TNodeResource

+ var TAINodeConfiguration_Resource_DEFAULT *TNodeResource

v1.3.3

Nov 4, 2024

Changes in this version

+ var TNodeLocations_ConfigNodeLocations_DEFAULT []*TConfigNodeLocation

+ var TNodeLocations_DataNodeLocations_DEFAULT []*TDataNodeLocation

+ var TSStatus_NeedRetry_DEFAULT bool

+ var TTestConnectionResult__Reason_DEFAULT string

type TAggregationType

+ const TAggregationType_COUNT_TIME

+ const TAggregationType_MAX_BY

+ const TAggregationType_MIN_BY

+ const TAggregationType_STDDEV

+ const TAggregationType_STDDEV_POP

+ const TAggregationType_STDDEV_SAMP

+ const TAggregationType_UDAF

+ const TAggregationType_VARIANCE

+ const TAggregationType_VAR_POP

+ const TAggregationType_VAR_SAMP

type TConfigNodeLocation

+ var TSender_ConfigNodeLocation_DEFAULT *TConfigNodeLocation

type TDataNodeLocation

+ var TSender_DataNodeLocation_DEFAULT *TDataNodeLocation

type TEndPoint

+ var TServiceProvider_EndPoint_DEFAULT *TEndPoint

+ 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 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 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

+ const TRegionMigrateFailedType_Disconnect

type TSStatus

+ NeedRetry *bool

+ var TShowConfigurationResp_Status_DEFAULT *TSStatus

+ var TShowConfigurationTemplateResp_Status_DEFAULT *TSStatus

+ var TTestConnectionResp_Status_DEFAULT *TSStatus

+ func (p *TSStatus) GetNeedRetry() bool

+ func (p *TSStatus) IsSetNeedRetry() bool

+ func (p *TSStatus) ReadField5(ctx context.Context, iprot 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 TServiceProvider struct

+ EndPoint *TEndPoint

+ 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) 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) 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 TSetTTLReq

+ IsDataBase bool

+ PathPattern []string

+ func (p *TSetTTLReq) GetIsDataBase() bool

+ func (p *TSetTTLReq) GetPathPattern() []string

+ func (p *TSetTTLReq) ReadField3(ctx context.Context, iprot 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 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

v1.2.0-tsbs

May 29, 2023

v1.1.7

Apr 25, 2023

v1.1.6

Apr 24, 2023

v1.1.5

Apr 12, 2023

Changes in this version

+ var GoUnusedProtection__ int

+ var TFlushReq_IsSeq_DEFAULT string

+ var TFlushReq_StorageGroups_DEFAULT []string

+ var TSStatus_Message_DEFAULT string

+ var TSStatus_SubStatus_DEFAULT []*TSStatus

+ var TSpaceQuota_DeviceNum_DEFAULT int64

+ var TSpaceQuota_DiskSize_DEFAULT int64

+ var TSpaceQuota_TimeserieNum_DEFAULT int64

+ var TThrottleQuota_CpuLimit_DEFAULT int32

+ var TThrottleQuota_MemLimit_DEFAULT int64

+ var TThrottleQuota_ThrottleLimit_DEFAULT map[ThrottleType]*TTimedQuota

+ type ModelTask int64

+ const ModelTask_FORECAST

+ func ModelTaskFromString(s string) (ModelTask, error)

+ func ModelTaskPtr(v ModelTask) *ModelTask

+ func (p *ModelTask) Scan(value interface{}) error

+ func (p *ModelTask) UnmarshalText(text []byte) error

+ func (p *ModelTask) Value() (driver.Value, error)

+ func (p ModelTask) MarshalText() ([]byte, error)

+ func (p ModelTask) String() string

+ type TAggregationType int64

+ const TAggregationType_AVG

+ const TAggregationType_COUNT

+ const TAggregationType_COUNT_IF

+ const TAggregationType_EXTREME

+ const TAggregationType_FIRST_VALUE

+ const TAggregationType_LAST_VALUE

+ const TAggregationType_MAX_TIME

+ const TAggregationType_MAX_VALUE

+ const TAggregationType_MIN_TIME

+ const TAggregationType_MIN_VALUE

+ const TAggregationType_MODE

+ const TAggregationType_SUM

+ const TAggregationType_TIME_DURATION

+ 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

+ 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

+ 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 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

+ 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 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

+ StorageGroups []string

+ func NewTFlushReq() *TFlushReq

+ func (p *TFlushReq) Equals(other *TFlushReq) bool

+ func (p *TFlushReq) GetIsSeq() string

+ func (p *TFlushReq) GetStorageGroups() []string

+ func (p *TFlushReq) IsSetIsSeq() 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) String() string

+ func (p *TFlushReq) Write(ctx context.Context, oprot thrift.TProtocol) error

+ type TNodeResource struct

+ CpuCoreNum int32

+ MaxMemory int64

+ 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 TRegionMigrateFailedType int64

+ const TRegionMigrateFailedType_AddPeerFailed

+ const TRegionMigrateFailedType_CreateRegionFailed

+ const TRegionMigrateFailedType_DeleteRegionFailed

+ 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

+ RedirectNode *TEndPoint

+ SubStatus []*TSStatus

+ var TFilesResp_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) GetRedirectNode() *TEndPoint

+ func (p *TSStatus) GetSubStatus() []*TSStatus

+ func (p *TSStatus) IsSetMessage() 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) 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 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 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

+ StorageGroupPathPattern []string

+ TTL int64

+ func NewTSetTTLReq() *TSetTTLReq

+ func (p *TSetTTLReq) Equals(other *TSetTTLReq) bool

+ func (p *TSetTTLReq) GetStorageGroupPathPattern() []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) 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 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 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

v1.1.1-tsbs

May 15, 2023

v1.1.0-tsbs

May 17, 2023

Other modules containing this package

github.com/apache/iotdb-client-go/v2

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