common

package
v1.3.3 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2024 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var TFlushReq_IsSeq_DEFAULT string
View Source 
var TFlushReq_StorageGroups_DEFAULT []string
View Source 
var TNodeLocations_ConfigNodeLocations_DEFAULT []*TConfigNodeLocation
View Source 
var TNodeLocations_DataNodeLocations_DEFAULT []*TDataNodeLocation
View Source 
var TSStatus_Message_DEFAULT string
View Source 
var TSStatus_NeedRetry_DEFAULT bool
View Source 
var TSStatus_SubStatus_DEFAULT []*TSStatus
View Source 
var TSpaceQuota_DeviceNum_DEFAULT int64
View Source 
var TSpaceQuota_DiskSize_DEFAULT int64
View Source 
var TSpaceQuota_TimeserieNum_DEFAULT int64
View Source 
var TTestConnectionResult__Reason_DEFAULT string
View Source 
var TThrottleQuota_CpuLimit_DEFAULT int32
View Source 
var TThrottleQuota_MemLimit_DEFAULT int64
View Source 
var TThrottleQuota_ThrottleLimit_DEFAULT map[ThrottleType]*TTimedQuota

Functions

This section is empty.

Types

type TAggregationType 

type TAggregationType int64
const (
	TAggregationType_COUNT         TAggregationType = 0
	TAggregationType_AVG           TAggregationType = 1
	TAggregationType_SUM           TAggregationType = 2
	TAggregationType_FIRST_VALUE   TAggregationType = 3
	TAggregationType_LAST_VALUE    TAggregationType = 4
	TAggregationType_MAX_TIME      TAggregationType = 5
	TAggregationType_MIN_TIME      TAggregationType = 6
	TAggregationType_MAX_VALUE     TAggregationType = 7
	TAggregationType_MIN_VALUE     TAggregationType = 8
	TAggregationType_EXTREME       TAggregationType = 9
	TAggregationType_COUNT_IF      TAggregationType = 10
	TAggregationType_TIME_DURATION TAggregationType = 11
	TAggregationType_MODE          TAggregationType = 12
	TAggregationType_COUNT_TIME    TAggregationType = 13
	TAggregationType_STDDEV        TAggregationType = 14
	TAggregationType_STDDEV_POP    TAggregationType = 15
	TAggregationType_STDDEV_SAMP   TAggregationType = 16
	TAggregationType_VARIANCE      TAggregationType = 17
	TAggregationType_VAR_POP       TAggregationType = 18
	TAggregationType_VAR_SAMP      TAggregationType = 19
	TAggregationType_MAX_BY        TAggregationType = 20
	TAggregationType_MIN_BY        TAggregationType = 21
	TAggregationType_UDAF          TAggregationType = 22
)

func TAggregationTypeFromString 

func TAggregationTypeFromString(s string) (TAggregationType, error)

func TAggregationTypePtr 

func TAggregationTypePtr(v TAggregationType) *TAggregationType

func (TAggregationType) MarshalText 

func (p TAggregationType) MarshalText() ([]byte, error)

func (*TAggregationType) Scan 

func (p *TAggregationType) Scan(value interface{}) error

func (TAggregationType) String 

func (p TAggregationType) String() string

func (*TAggregationType) UnmarshalText 

func (p *TAggregationType) UnmarshalText(text []byte) error

func (*TAggregationType) Value 

func (p *TAggregationType) Value() (driver.Value, error)

type TConfigNodeLocation 

type TConfigNodeLocation struct {
	ConfigNodeId      int32      `thrift:"configNodeId,1,required" db:"configNodeId" json:"configNodeId"`
	InternalEndPoint  *TEndPoint `thrift:"internalEndPoint,2,required" db:"internalEndPoint" json:"internalEndPoint"`
	ConsensusEndPoint *TEndPoint `thrift:"consensusEndPoint,3,required" db:"consensusEndPoint" json:"consensusEndPoint"`
}

Attributes:

  • ConfigNodeId
  • InternalEndPoint
  • ConsensusEndPoint
var TSender_ConfigNodeLocation_DEFAULT *TConfigNodeLocation

func NewTConfigNodeLocation 

func NewTConfigNodeLocation() *TConfigNodeLocation

func (*TConfigNodeLocation) Equals 

func (p *TConfigNodeLocation) Equals(other *TConfigNodeLocation) bool

func (*TConfigNodeLocation) GetConfigNodeId 

func (p *TConfigNodeLocation) GetConfigNodeId() int32

func (*TConfigNodeLocation) GetConsensusEndPoint 

func (p *TConfigNodeLocation) GetConsensusEndPoint() *TEndPoint

func (*TConfigNodeLocation) GetInternalEndPoint 

func (p *TConfigNodeLocation) GetInternalEndPoint() *TEndPoint

func (*TConfigNodeLocation) IsSetConsensusEndPoint 

func (p *TConfigNodeLocation) IsSetConsensusEndPoint() bool

func (*TConfigNodeLocation) IsSetInternalEndPoint 

func (p *TConfigNodeLocation) IsSetInternalEndPoint() bool

func (*TConfigNodeLocation) Read 

func (p *TConfigNodeLocation) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TConfigNodeLocation) ReadField1 

func (p *TConfigNodeLocation) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TConfigNodeLocation) ReadField2 

func (p *TConfigNodeLocation) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TConfigNodeLocation) ReadField3 

func (p *TConfigNodeLocation) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TConfigNodeLocation) String 

func (p *TConfigNodeLocation) String() string

func (*TConfigNodeLocation) Write 

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

type TConsensusGroupId 

type TConsensusGroupId struct {
	Type TConsensusGroupType `thrift:"type,1,required" db:"type" json:"type"`
	ID   int32               `thrift:"id,2,required" db:"id" json:"id"`
}

Attributes:

  • Type
  • ID
var TRegionReplicaSet_RegionId_DEFAULT *TConsensusGroupId

func NewTConsensusGroupId 

func NewTConsensusGroupId() *TConsensusGroupId

func (*TConsensusGroupId) Equals 

func (p *TConsensusGroupId) Equals(other *TConsensusGroupId) bool

func (*TConsensusGroupId) GetID 

func (p *TConsensusGroupId) GetID() int32

func (*TConsensusGroupId) GetType 

func (p *TConsensusGroupId) GetType() TConsensusGroupType

func (*TConsensusGroupId) Read 

func (p *TConsensusGroupId) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TConsensusGroupId) ReadField1 

func (p *TConsensusGroupId) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TConsensusGroupId) ReadField2 

func (p *TConsensusGroupId) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TConsensusGroupId) String 

func (p *TConsensusGroupId) String() string

func (*TConsensusGroupId) Write 

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

type TConsensusGroupType 

type TConsensusGroupType int64
const (
	TConsensusGroupType_ConfigRegion TConsensusGroupType = 0
	TConsensusGroupType_DataRegion   TConsensusGroupType = 1
	TConsensusGroupType_SchemaRegion TConsensusGroupType = 2
)

func TConsensusGroupTypeFromString 

func TConsensusGroupTypeFromString(s string) (TConsensusGroupType, error)

func TConsensusGroupTypePtr 

func TConsensusGroupTypePtr(v TConsensusGroupType) *TConsensusGroupType

func (TConsensusGroupType) MarshalText 

func (p TConsensusGroupType) MarshalText() ([]byte, error)

func (*TConsensusGroupType) Scan 

func (p *TConsensusGroupType) Scan(value interface{}) error

func (TConsensusGroupType) String 

func (p TConsensusGroupType) String() string

func (*TConsensusGroupType) UnmarshalText 

func (p *TConsensusGroupType) UnmarshalText(text []byte) error

func (*TConsensusGroupType) Value 

func (p *TConsensusGroupType) Value() (driver.Value, error)

type TDataNodeConfiguration 

type TDataNodeConfiguration struct {
	Location *TDataNodeLocation `thrift:"location,1,required" db:"location" json:"location"`
	Resource *TNodeResource     `thrift:"resource,2,required" db:"resource" json:"resource"`
}

Attributes:

  • Location
  • Resource

func NewTDataNodeConfiguration 

func NewTDataNodeConfiguration() *TDataNodeConfiguration

func (*TDataNodeConfiguration) Equals 

func (p *TDataNodeConfiguration) Equals(other *TDataNodeConfiguration) bool

func (*TDataNodeConfiguration) GetLocation 

func (p *TDataNodeConfiguration) GetLocation() *TDataNodeLocation

func (*TDataNodeConfiguration) GetResource 

func (p *TDataNodeConfiguration) GetResource() *TNodeResource

func (*TDataNodeConfiguration) IsSetLocation 

func (p *TDataNodeConfiguration) IsSetLocation() bool

func (*TDataNodeConfiguration) IsSetResource 

func (p *TDataNodeConfiguration) IsSetResource() bool

func (*TDataNodeConfiguration) Read 

func (p *TDataNodeConfiguration) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataNodeConfiguration) ReadField1 

func (p *TDataNodeConfiguration) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataNodeConfiguration) ReadField2 

func (p *TDataNodeConfiguration) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataNodeConfiguration) String 

func (p *TDataNodeConfiguration) String() string

func (*TDataNodeConfiguration) Write 

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

type TDataNodeLocation 

type TDataNodeLocation struct {
	DataNodeId                    int32      `thrift:"dataNodeId,1,required" db:"dataNodeId" json:"dataNodeId"`
	ClientRpcEndPoint             *TEndPoint `thrift:"clientRpcEndPoint,2,required" db:"clientRpcEndPoint" json:"clientRpcEndPoint"`
	InternalEndPoint              *TEndPoint `thrift:"internalEndPoint,3,required" db:"internalEndPoint" json:"internalEndPoint"`
	MPPDataExchangeEndPoint       *TEndPoint `thrift:"mPPDataExchangeEndPoint,4,required" db:"mPPDataExchangeEndPoint" json:"mPPDataExchangeEndPoint"`
	DataRegionConsensusEndPoint   *TEndPoint `thrift:"dataRegionConsensusEndPoint,5,required" db:"dataRegionConsensusEndPoint" json:"dataRegionConsensusEndPoint"`
	SchemaRegionConsensusEndPoint *TEndPoint `thrift:"schemaRegionConsensusEndPoint,6,required" db:"schemaRegionConsensusEndPoint" json:"schemaRegionConsensusEndPoint"`
}

Attributes:

  • DataNodeId
  • ClientRpcEndPoint
  • InternalEndPoint
  • MPPDataExchangeEndPoint
  • DataRegionConsensusEndPoint
  • SchemaRegionConsensusEndPoint
var TDataNodeConfiguration_Location_DEFAULT *TDataNodeLocation
var TSender_DataNodeLocation_DEFAULT *TDataNodeLocation

func NewTDataNodeLocation 

func NewTDataNodeLocation() *TDataNodeLocation

func (*TDataNodeLocation) Equals 

func (p *TDataNodeLocation) Equals(other *TDataNodeLocation) bool

func (*TDataNodeLocation) GetClientRpcEndPoint 

func (p *TDataNodeLocation) GetClientRpcEndPoint() *TEndPoint

func (*TDataNodeLocation) GetDataNodeId 

func (p *TDataNodeLocation) GetDataNodeId() int32

func (*TDataNodeLocation) GetDataRegionConsensusEndPoint 

func (p *TDataNodeLocation) GetDataRegionConsensusEndPoint() *TEndPoint

func (*TDataNodeLocation) GetInternalEndPoint 

func (p *TDataNodeLocation) GetInternalEndPoint() *TEndPoint

func (*TDataNodeLocation) GetMPPDataExchangeEndPoint 

func (p *TDataNodeLocation) GetMPPDataExchangeEndPoint() *TEndPoint

func (*TDataNodeLocation) GetSchemaRegionConsensusEndPoint 

func (p *TDataNodeLocation) GetSchemaRegionConsensusEndPoint() *TEndPoint

func (*TDataNodeLocation) IsSetClientRpcEndPoint 

func (p *TDataNodeLocation) IsSetClientRpcEndPoint() bool

func (*TDataNodeLocation) IsSetDataRegionConsensusEndPoint 

func (p *TDataNodeLocation) IsSetDataRegionConsensusEndPoint() bool

func (*TDataNodeLocation) IsSetInternalEndPoint 

func (p *TDataNodeLocation) IsSetInternalEndPoint() bool

func (*TDataNodeLocation) IsSetMPPDataExchangeEndPoint 

func (p *TDataNodeLocation) IsSetMPPDataExchangeEndPoint() bool

func (*TDataNodeLocation) IsSetSchemaRegionConsensusEndPoint 

func (p *TDataNodeLocation) IsSetSchemaRegionConsensusEndPoint() bool

func (*TDataNodeLocation) Read 

func (p *TDataNodeLocation) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataNodeLocation) ReadField1 

func (p *TDataNodeLocation) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataNodeLocation) ReadField2 

func (p *TDataNodeLocation) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataNodeLocation) ReadField3 

func (p *TDataNodeLocation) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataNodeLocation) ReadField4 

func (p *TDataNodeLocation) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TDataNodeLocation) ReadField5 

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

func (*TDataNodeLocation) ReadField6 

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

func (*TDataNodeLocation) String 

func (p *TDataNodeLocation) String() string

func (*TDataNodeLocation) Write 

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

type TEndPoint 

type TEndPoint struct {
	IP   string `thrift:"ip,1,required" db:"ip" json:"ip"`
	Port int32  `thrift:"port,2,required" db:"port" json:"port"`
}

Attributes:

  • IP
  • Port
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 

func NewTEndPoint() *TEndPoint

func (*TEndPoint) Equals 

func (p *TEndPoint) Equals(other *TEndPoint) bool

func (*TEndPoint) GetIP 

func (p *TEndPoint) GetIP() string

func (*TEndPoint) GetPort 

func (p *TEndPoint) GetPort() int32

func (*TEndPoint) Read 

func (p *TEndPoint) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TEndPoint) ReadField1 

func (p *TEndPoint) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TEndPoint) ReadField2 

func (p *TEndPoint) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TEndPoint) String 

func (p *TEndPoint) String() string

func (*TEndPoint) Write 

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

type TFile 

type TFile struct {
	FileName string `thrift:"fileName,1,required" db:"fileName" json:"fileName"`
	File     []byte `thrift:"file,2,required" db:"file" json:"file"`
}

Attributes:

  • FileName
  • File

func NewTFile 

func NewTFile() *TFile

func (*TFile) Equals 

func (p *TFile) Equals(other *TFile) bool

func (*TFile) GetFile 

func (p *TFile) GetFile() []byte

func (*TFile) GetFileName 

func (p *TFile) GetFileName() string

func (*TFile) Read 

func (p *TFile) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TFile) ReadField1 

func (p *TFile) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TFile) ReadField2 

func (p *TFile) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TFile) String 

func (p *TFile) String() string

func (*TFile) Write 

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

type TFilesResp 

type TFilesResp struct {
	Status *TSStatus `thrift:"status,1,required" db:"status" json:"status"`
	Files  []*TFile  `thrift:"files,2,required" db:"files" json:"files"`
}

Attributes:

  • Status
  • Files

func NewTFilesResp 

func NewTFilesResp() *TFilesResp

func (*TFilesResp) Equals 

func (p *TFilesResp) Equals(other *TFilesResp) bool

func (*TFilesResp) GetFiles 

func (p *TFilesResp) GetFiles() []*TFile

func (*TFilesResp) GetStatus 

func (p *TFilesResp) GetStatus() *TSStatus

func (*TFilesResp) IsSetStatus 

func (p *TFilesResp) IsSetStatus() bool

func (*TFilesResp) Read 

func (p *TFilesResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TFilesResp) ReadField1 

func (p *TFilesResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TFilesResp) ReadField2 

func (p *TFilesResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TFilesResp) String 

func (p *TFilesResp) String() string

func (*TFilesResp) Write 

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

type TFlushReq 

type TFlushReq struct {
	IsSeq         *string  `thrift:"isSeq,1" db:"isSeq" json:"isSeq,omitempty"`
	StorageGroups []string `thrift:"storageGroups,2" db:"storageGroups" json:"storageGroups,omitempty"`
}

Attributes:

  • IsSeq
  • StorageGroups

func NewTFlushReq 

func NewTFlushReq() *TFlushReq

func (*TFlushReq) Equals 

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

func (*TFlushReq) GetIsSeq 

func (p *TFlushReq) GetIsSeq() string

func (*TFlushReq) GetStorageGroups 

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

func (*TFlushReq) IsSetIsSeq 

func (p *TFlushReq) IsSetIsSeq() bool

func (*TFlushReq) IsSetStorageGroups 

func (p *TFlushReq) IsSetStorageGroups() bool

func (*TFlushReq) Read 

func (p *TFlushReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TFlushReq) ReadField1 

func (p *TFlushReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TFlushReq) ReadField2 

func (p *TFlushReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TFlushReq) String 

func (p *TFlushReq) String() string

func (*TFlushReq) Write 

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

type TLicense added in v1.3.3 

type TLicense struct {
	LicenseIssueTimestamp int64 `thrift:"licenseIssueTimestamp,1,required" db:"licenseIssueTimestamp" json:"licenseIssueTimestamp"`
	ExpireTimestamp       int64 `thrift:"expireTimestamp,2,required" db:"expireTimestamp" json:"expireTimestamp"`
	// unused field # 3
	DataNodeNumLimit                     int16 `thrift:"dataNodeNumLimit,4,required" db:"dataNodeNumLimit" json:"dataNodeNumLimit"`
	CpuCoreNumLimit                      int32 `thrift:"cpuCoreNumLimit,5,required" db:"cpuCoreNumLimit" json:"cpuCoreNumLimit"`
	DeviceNumLimit                       int64 `thrift:"deviceNumLimit,6,required" db:"deviceNumLimit" json:"deviceNumLimit"`
	SensorNumLimit                       int64 `thrift:"sensorNumLimit,7,required" db:"sensorNumLimit" json:"sensorNumLimit"`
	DisconnectionFromActiveNodeTimeLimit int64 `` /* 142-byte string literal not displayed */
	MlNodeNumLimit                       int16 `thrift:"mlNodeNumLimit,9,required" db:"mlNodeNumLimit" json:"mlNodeNumLimit"`
}

Attributes:

  • LicenseIssueTimestamp
  • ExpireTimestamp
  • DataNodeNumLimit
  • CpuCoreNumLimit
  • DeviceNumLimit
  • SensorNumLimit
  • DisconnectionFromActiveNodeTimeLimit
  • MlNodeNumLimit

func NewTLicense added in v1.3.3 

func NewTLicense() *TLicense

func (*TLicense) Equals added in v1.3.3 

func (p *TLicense) Equals(other *TLicense) bool

func (*TLicense) GetCpuCoreNumLimit added in v1.3.3 

func (p *TLicense) GetCpuCoreNumLimit() int32

func (*TLicense) GetDataNodeNumLimit added in v1.3.3 

func (p *TLicense) GetDataNodeNumLimit() int16

func (*TLicense) GetDeviceNumLimit added in v1.3.3 

func (p *TLicense) GetDeviceNumLimit() int64

func (*TLicense) GetDisconnectionFromActiveNodeTimeLimit added in v1.3.3 

func (p *TLicense) GetDisconnectionFromActiveNodeTimeLimit() int64

func (*TLicense) GetExpireTimestamp added in v1.3.3 

func (p *TLicense) GetExpireTimestamp() int64

func (*TLicense) GetLicenseIssueTimestamp added in v1.3.3 

func (p *TLicense) GetLicenseIssueTimestamp() int64

func (*TLicense) GetMlNodeNumLimit added in v1.3.3 

func (p *TLicense) GetMlNodeNumLimit() int16

func (*TLicense) GetSensorNumLimit added in v1.3.3 

func (p *TLicense) GetSensorNumLimit() int64

func (*TLicense) Read added in v1.3.3 

func (p *TLicense) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TLicense) ReadField1 added in v1.3.3 

func (p *TLicense) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TLicense) ReadField2 added in v1.3.3 

func (p *TLicense) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TLicense) ReadField4 added in v1.3.3 

func (p *TLicense) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TLicense) ReadField5 added in v1.3.3 

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

func (*TLicense) ReadField6 added in v1.3.3 

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

func (*TLicense) ReadField7 added in v1.3.3 

func (p *TLicense) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TLicense) ReadField8 added in v1.3.3 

func (p *TLicense) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TLicense) ReadField9 added in v1.3.3 

func (p *TLicense) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TLicense) String added in v1.3.3 

func (p *TLicense) String() string

func (*TLicense) Write added in v1.3.3 

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

type TNodeLocations added in v1.3.3 

type TNodeLocations struct {
	ConfigNodeLocations []*TConfigNodeLocation `thrift:"configNodeLocations,1" db:"configNodeLocations" json:"configNodeLocations,omitempty"`
	DataNodeLocations   []*TDataNodeLocation   `thrift:"dataNodeLocations,2" db:"dataNodeLocations" json:"dataNodeLocations,omitempty"`
}

Attributes:

  • ConfigNodeLocations
  • DataNodeLocations

func NewTNodeLocations added in v1.3.3 

func NewTNodeLocations() *TNodeLocations

func (*TNodeLocations) Equals added in v1.3.3 

func (p *TNodeLocations) Equals(other *TNodeLocations) bool

func (*TNodeLocations) GetConfigNodeLocations added in v1.3.3 

func (p *TNodeLocations) GetConfigNodeLocations() []*TConfigNodeLocation

func (*TNodeLocations) GetDataNodeLocations added in v1.3.3 

func (p *TNodeLocations) GetDataNodeLocations() []*TDataNodeLocation

func (*TNodeLocations) IsSetConfigNodeLocations added in v1.3.3 

func (p *TNodeLocations) IsSetConfigNodeLocations() bool

func (*TNodeLocations) IsSetDataNodeLocations added in v1.3.3 

func (p *TNodeLocations) IsSetDataNodeLocations() bool

func (*TNodeLocations) Read added in v1.3.3 

func (p *TNodeLocations) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TNodeLocations) ReadField1 added in v1.3.3 

func (p *TNodeLocations) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TNodeLocations) ReadField2 added in v1.3.3 

func (p *TNodeLocations) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TNodeLocations) String added in v1.3.3 

func (p *TNodeLocations) String() string

func (*TNodeLocations) Write added in v1.3.3 

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

type TNodeResource 

type TNodeResource struct {
	CpuCoreNum int32 `thrift:"cpuCoreNum,1,required" db:"cpuCoreNum" json:"cpuCoreNum"`
	MaxMemory  int64 `thrift:"maxMemory,2,required" db:"maxMemory" json:"maxMemory"`
}

Attributes:

  • CpuCoreNum
  • MaxMemory
var TDataNodeConfiguration_Resource_DEFAULT *TNodeResource

func NewTNodeResource 

func NewTNodeResource() *TNodeResource

func (*TNodeResource) Equals 

func (p *TNodeResource) Equals(other *TNodeResource) bool

func (*TNodeResource) GetCpuCoreNum 

func (p *TNodeResource) GetCpuCoreNum() int32

func (*TNodeResource) GetMaxMemory 

func (p *TNodeResource) GetMaxMemory() int64

func (*TNodeResource) Read 

func (p *TNodeResource) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TNodeResource) ReadField1 

func (p *TNodeResource) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TNodeResource) ReadField2 

func (p *TNodeResource) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TNodeResource) String 

func (p *TNodeResource) String() string

func (*TNodeResource) Write 

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

type TRegionMaintainTaskStatus added in v1.3.3 

type TRegionMaintainTaskStatus int64
const (
	TRegionMaintainTaskStatus_TASK_NOT_EXIST TRegionMaintainTaskStatus = 0
	TRegionMaintainTaskStatus_PROCESSING     TRegionMaintainTaskStatus = 1
	TRegionMaintainTaskStatus_SUCCESS        TRegionMaintainTaskStatus = 2
	TRegionMaintainTaskStatus_FAIL           TRegionMaintainTaskStatus = 3
)

func TRegionMaintainTaskStatusFromString added in v1.3.3 

func TRegionMaintainTaskStatusFromString(s string) (TRegionMaintainTaskStatus, error)

func TRegionMaintainTaskStatusPtr added in v1.3.3 

func TRegionMaintainTaskStatusPtr(v TRegionMaintainTaskStatus) *TRegionMaintainTaskStatus

func (TRegionMaintainTaskStatus) MarshalText added in v1.3.3 

func (p TRegionMaintainTaskStatus) MarshalText() ([]byte, error)

func (*TRegionMaintainTaskStatus) Scan added in v1.3.3 

func (p *TRegionMaintainTaskStatus) Scan(value interface{}) error

func (TRegionMaintainTaskStatus) String added in v1.3.3 

func (p TRegionMaintainTaskStatus) String() string

func (*TRegionMaintainTaskStatus) UnmarshalText added in v1.3.3 

func (p *TRegionMaintainTaskStatus) UnmarshalText(text []byte) error

func (*TRegionMaintainTaskStatus) Value added in v1.3.3 

func (p *TRegionMaintainTaskStatus) Value() (driver.Value, error)

type TRegionMigrateFailedType 

type TRegionMigrateFailedType int64
const (
	TRegionMigrateFailedType_AddPeerFailed              TRegionMigrateFailedType = 0
	TRegionMigrateFailedType_RemovePeerFailed           TRegionMigrateFailedType = 1
	TRegionMigrateFailedType_RemoveConsensusGroupFailed TRegionMigrateFailedType = 2
	TRegionMigrateFailedType_DeleteRegionFailed         TRegionMigrateFailedType = 3
	TRegionMigrateFailedType_CreateRegionFailed         TRegionMigrateFailedType = 4
	TRegionMigrateFailedType_Disconnect                 TRegionMigrateFailedType = 5
)

func TRegionMigrateFailedTypeFromString 

func TRegionMigrateFailedTypeFromString(s string) (TRegionMigrateFailedType, error)

func TRegionMigrateFailedTypePtr 

func TRegionMigrateFailedTypePtr(v TRegionMigrateFailedType) *TRegionMigrateFailedType

func (TRegionMigrateFailedType) MarshalText 

func (p TRegionMigrateFailedType) MarshalText() ([]byte, error)

func (*TRegionMigrateFailedType) Scan 

func (p *TRegionMigrateFailedType) Scan(value interface{}) error

func (TRegionMigrateFailedType) String 

func (p TRegionMigrateFailedType) String() string

func (*TRegionMigrateFailedType) UnmarshalText 

func (p *TRegionMigrateFailedType) UnmarshalText(text []byte) error

func (*TRegionMigrateFailedType) Value 

func (p *TRegionMigrateFailedType) Value() (driver.Value, error)

type TRegionReplicaSet 

type TRegionReplicaSet struct {
	RegionId          *TConsensusGroupId   `thrift:"regionId,1,required" db:"regionId" json:"regionId"`
	DataNodeLocations []*TDataNodeLocation `thrift:"dataNodeLocations,2,required" db:"dataNodeLocations" json:"dataNodeLocations"`
}

Attributes:

  • RegionId
  • DataNodeLocations

func NewTRegionReplicaSet 

func NewTRegionReplicaSet() *TRegionReplicaSet

func (*TRegionReplicaSet) Equals 

func (p *TRegionReplicaSet) Equals(other *TRegionReplicaSet) bool

func (*TRegionReplicaSet) GetDataNodeLocations 

func (p *TRegionReplicaSet) GetDataNodeLocations() []*TDataNodeLocation

func (*TRegionReplicaSet) GetRegionId 

func (p *TRegionReplicaSet) GetRegionId() *TConsensusGroupId

func (*TRegionReplicaSet) IsSetRegionId 

func (p *TRegionReplicaSet) IsSetRegionId() bool

func (*TRegionReplicaSet) Read 

func (p *TRegionReplicaSet) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegionReplicaSet) ReadField1 

func (p *TRegionReplicaSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegionReplicaSet) ReadField2 

func (p *TRegionReplicaSet) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TRegionReplicaSet) String 

func (p *TRegionReplicaSet) String() string

func (*TRegionReplicaSet) Write 

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

type TSStatus 

type TSStatus struct {
	Code         int32       `thrift:"code,1,required" db:"code" json:"code"`
	Message      *string     `thrift:"message,2" db:"message" json:"message,omitempty"`
	SubStatus    []*TSStatus `thrift:"subStatus,3" db:"subStatus" json:"subStatus,omitempty"`
	RedirectNode *TEndPoint  `thrift:"redirectNode,4" db:"redirectNode" json:"redirectNode,omitempty"`
	NeedRetry    *bool       `thrift:"needRetry,5" db:"needRetry" json:"needRetry,omitempty"`
}

Attributes:

  • Code
  • Message
  • SubStatus
  • RedirectNode
  • NeedRetry
var TFilesResp_Status_DEFAULT *TSStatus
var TShowConfigurationResp_Status_DEFAULT *TSStatus
var TShowConfigurationTemplateResp_Status_DEFAULT *TSStatus
var TTestConnectionResp_Status_DEFAULT *TSStatus

func NewTSStatus 

func NewTSStatus() *TSStatus

func (*TSStatus) Equals 

func (p *TSStatus) Equals(other *TSStatus) bool

func (*TSStatus) GetCode 

func (p *TSStatus) GetCode() int32

func (*TSStatus) GetMessage 

func (p *TSStatus) GetMessage() string

func (*TSStatus) GetNeedRetry added in v1.3.3 

func (p *TSStatus) GetNeedRetry() bool

func (*TSStatus) GetRedirectNode 

func (p *TSStatus) GetRedirectNode() *TEndPoint

func (*TSStatus) GetSubStatus 

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

func (*TSStatus) IsSetMessage 

func (p *TSStatus) IsSetMessage() bool

func (*TSStatus) IsSetNeedRetry added in v1.3.3 

func (p *TSStatus) IsSetNeedRetry() bool

func (*TSStatus) IsSetRedirectNode 

func (p *TSStatus) IsSetRedirectNode() bool

func (*TSStatus) IsSetSubStatus 

func (p *TSStatus) IsSetSubStatus() bool

func (*TSStatus) Read 

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

func (*TSStatus) ReadField1 

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

func (*TSStatus) ReadField2 

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

func (*TSStatus) ReadField3 

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

func (*TSStatus) ReadField4 

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

func (*TSStatus) ReadField5 added in v1.3.3 

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

func (*TSStatus) String 

func (p *TSStatus) String() string

func (*TSStatus) Write 

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

type TSchemaNode 

type TSchemaNode struct {
	NodeName string `thrift:"nodeName,1,required" db:"nodeName" json:"nodeName"`
	NodeType int8   `thrift:"nodeType,2,required" db:"nodeType" json:"nodeType"`
}

Attributes:

  • NodeName
  • NodeType

func NewTSchemaNode 

func NewTSchemaNode() *TSchemaNode

func (*TSchemaNode) Equals 

func (p *TSchemaNode) Equals(other *TSchemaNode) bool

func (*TSchemaNode) GetNodeName 

func (p *TSchemaNode) GetNodeName() string

func (*TSchemaNode) GetNodeType 

func (p *TSchemaNode) GetNodeType() int8

func (*TSchemaNode) Read 

func (p *TSchemaNode) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSchemaNode) ReadField1 

func (p *TSchemaNode) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSchemaNode) ReadField2 

func (p *TSchemaNode) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSchemaNode) String 

func (p *TSchemaNode) String() string

func (*TSchemaNode) Write 

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

type TSender added in v1.3.3 

type TSender struct {
	DataNodeLocation   *TDataNodeLocation   `thrift:"dataNodeLocation,1" db:"dataNodeLocation" json:"dataNodeLocation,omitempty"`
	ConfigNodeLocation *TConfigNodeLocation `thrift:"configNodeLocation,2" db:"configNodeLocation" json:"configNodeLocation,omitempty"`
}

Attributes:

  • DataNodeLocation
  • ConfigNodeLocation
var TTestConnectionResult__Sender_DEFAULT *TSender

func NewTSender added in v1.3.3 

func NewTSender() *TSender

func (*TSender) Equals added in v1.3.3 

func (p *TSender) Equals(other *TSender) bool

func (*TSender) GetConfigNodeLocation added in v1.3.3 

func (p *TSender) GetConfigNodeLocation() *TConfigNodeLocation

func (*TSender) GetDataNodeLocation added in v1.3.3 

func (p *TSender) GetDataNodeLocation() *TDataNodeLocation

func (*TSender) IsSetConfigNodeLocation added in v1.3.3 

func (p *TSender) IsSetConfigNodeLocation() bool

func (*TSender) IsSetDataNodeLocation added in v1.3.3 

func (p *TSender) IsSetDataNodeLocation() bool

func (*TSender) Read added in v1.3.3 

func (p *TSender) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSender) ReadField1 added in v1.3.3 

func (p *TSender) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSender) ReadField2 added in v1.3.3 

func (p *TSender) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSender) String added in v1.3.3 

func (p *TSender) String() string

func (*TSender) Write added in v1.3.3 

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

type TSeriesPartitionSlot 

type TSeriesPartitionSlot struct {
	SlotId int32 `thrift:"slotId,1,required" db:"slotId" json:"slotId"`
}

Attributes:

  • SlotId

func NewTSeriesPartitionSlot 

func NewTSeriesPartitionSlot() *TSeriesPartitionSlot

func (*TSeriesPartitionSlot) Equals 

func (p *TSeriesPartitionSlot) Equals(other *TSeriesPartitionSlot) bool

func (*TSeriesPartitionSlot) GetSlotId 

func (p *TSeriesPartitionSlot) GetSlotId() int32

func (*TSeriesPartitionSlot) Read 

func (p *TSeriesPartitionSlot) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSeriesPartitionSlot) ReadField1 

func (p *TSeriesPartitionSlot) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSeriesPartitionSlot) String 

func (p *TSeriesPartitionSlot) String() string

func (*TSeriesPartitionSlot) Write 

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

type TServiceProvider added in v1.3.3 

type TServiceProvider struct {
	EndPoint    *TEndPoint   `thrift:"endPoint,1,required" db:"endPoint" json:"endPoint"`
	ServiceType TServiceType `thrift:"serviceType,2,required" db:"serviceType" json:"serviceType"`
}

Attributes:

  • EndPoint
  • ServiceType
var TTestConnectionResult__ServiceProvider_DEFAULT *TServiceProvider

func NewTServiceProvider added in v1.3.3 

func NewTServiceProvider() *TServiceProvider

func (*TServiceProvider) Equals added in v1.3.3 

func (p *TServiceProvider) Equals(other *TServiceProvider) bool

func (*TServiceProvider) GetEndPoint added in v1.3.3 

func (p *TServiceProvider) GetEndPoint() *TEndPoint

func (*TServiceProvider) GetServiceType added in v1.3.3 

func (p *TServiceProvider) GetServiceType() TServiceType

func (*TServiceProvider) IsSetEndPoint added in v1.3.3 

func (p *TServiceProvider) IsSetEndPoint() bool

func (*TServiceProvider) Read added in v1.3.3 

func (p *TServiceProvider) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TServiceProvider) ReadField1 added in v1.3.3 

func (p *TServiceProvider) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TServiceProvider) ReadField2 added in v1.3.3 

func (p *TServiceProvider) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TServiceProvider) String added in v1.3.3 

func (p *TServiceProvider) String() string

func (*TServiceProvider) Write added in v1.3.3 

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

type TServiceType added in v1.3.3 

type TServiceType int64
const (
	TServiceType_ConfigNodeInternalService TServiceType = 0
	TServiceType_DataNodeInternalService   TServiceType = 1
	TServiceType_DataNodeMPPService        TServiceType = 2
	TServiceType_DataNodeExternalService   TServiceType = 3
)

func TServiceTypeFromString added in v1.3.3 

func TServiceTypeFromString(s string) (TServiceType, error)

func TServiceTypePtr added in v1.3.3 

func TServiceTypePtr(v TServiceType) *TServiceType

func (TServiceType) MarshalText added in v1.3.3 

func (p TServiceType) MarshalText() ([]byte, error)

func (*TServiceType) Scan added in v1.3.3 

func (p *TServiceType) Scan(value interface{}) error

func (TServiceType) String added in v1.3.3 

func (p TServiceType) String() string

func (*TServiceType) UnmarshalText added in v1.3.3 

func (p *TServiceType) UnmarshalText(text []byte) error

func (*TServiceType) Value added in v1.3.3 

func (p *TServiceType) Value() (driver.Value, error)

type TSetConfigurationReq added in v1.3.3 

type TSetConfigurationReq struct {
	Configs map[string]string `thrift:"configs,1,required" db:"configs" json:"configs"`
	NodeId  int32             `thrift:"nodeId,2,required" db:"nodeId" json:"nodeId"`
}

Attributes:

  • Configs
  • NodeId

func NewTSetConfigurationReq added in v1.3.3 

func NewTSetConfigurationReq() *TSetConfigurationReq

func (*TSetConfigurationReq) Equals added in v1.3.3 

func (p *TSetConfigurationReq) Equals(other *TSetConfigurationReq) bool

func (*TSetConfigurationReq) GetConfigs added in v1.3.3 

func (p *TSetConfigurationReq) GetConfigs() map[string]string

func (*TSetConfigurationReq) GetNodeId added in v1.3.3 

func (p *TSetConfigurationReq) GetNodeId() int32

func (*TSetConfigurationReq) Read added in v1.3.3 

func (p *TSetConfigurationReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetConfigurationReq) ReadField1 added in v1.3.3 

func (p *TSetConfigurationReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetConfigurationReq) ReadField2 added in v1.3.3 

func (p *TSetConfigurationReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetConfigurationReq) String added in v1.3.3 

func (p *TSetConfigurationReq) String() string

func (*TSetConfigurationReq) Write added in v1.3.3 

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

type TSetSpaceQuotaReq 

type TSetSpaceQuotaReq struct {
	Database   []string     `thrift:"database,1,required" db:"database" json:"database"`
	SpaceLimit *TSpaceQuota `thrift:"spaceLimit,2,required" db:"spaceLimit" json:"spaceLimit"`
}

Attributes:

  • Database
  • SpaceLimit

func NewTSetSpaceQuotaReq 

func NewTSetSpaceQuotaReq() *TSetSpaceQuotaReq

func (*TSetSpaceQuotaReq) Equals 

func (p *TSetSpaceQuotaReq) Equals(other *TSetSpaceQuotaReq) bool

func (*TSetSpaceQuotaReq) GetDatabase 

func (p *TSetSpaceQuotaReq) GetDatabase() []string

func (*TSetSpaceQuotaReq) GetSpaceLimit 

func (p *TSetSpaceQuotaReq) GetSpaceLimit() *TSpaceQuota

func (*TSetSpaceQuotaReq) IsSetSpaceLimit 

func (p *TSetSpaceQuotaReq) IsSetSpaceLimit() bool

func (*TSetSpaceQuotaReq) Read 

func (p *TSetSpaceQuotaReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetSpaceQuotaReq) ReadField1 

func (p *TSetSpaceQuotaReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetSpaceQuotaReq) ReadField2 

func (p *TSetSpaceQuotaReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetSpaceQuotaReq) String 

func (p *TSetSpaceQuotaReq) String() string

func (*TSetSpaceQuotaReq) Write 

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

type TSetTTLReq 

type TSetTTLReq struct {
	PathPattern []string `thrift:"pathPattern,1,required" db:"pathPattern" json:"pathPattern"`
	TTL         int64    `thrift:"TTL,2,required" db:"TTL" json:"TTL"`
	IsDataBase  bool     `thrift:"isDataBase,3,required" db:"isDataBase" json:"isDataBase"`
}

Attributes:

  • PathPattern
  • TTL
  • IsDataBase

func NewTSetTTLReq 

func NewTSetTTLReq() *TSetTTLReq

func (*TSetTTLReq) Equals 

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

func (*TSetTTLReq) GetIsDataBase added in v1.3.3 

func (p *TSetTTLReq) GetIsDataBase() bool

func (*TSetTTLReq) GetPathPattern added in v1.3.3 

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

func (*TSetTTLReq) GetTTL 

func (p *TSetTTLReq) GetTTL() int64

func (*TSetTTLReq) Read 

func (p *TSetTTLReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetTTLReq) ReadField1 

func (p *TSetTTLReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetTTLReq) ReadField2 

func (p *TSetTTLReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetTTLReq) ReadField3 added in v1.3.3 

func (p *TSetTTLReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetTTLReq) String 

func (p *TSetTTLReq) String() string

func (*TSetTTLReq) Write 

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

type TSetThrottleQuotaReq 

type TSetThrottleQuotaReq struct {
	UserName      string          `thrift:"userName,1,required" db:"userName" json:"userName"`
	ThrottleQuota *TThrottleQuota `thrift:"throttleQuota,2,required" db:"throttleQuota" json:"throttleQuota"`
}

Attributes:

  • UserName
  • ThrottleQuota

func NewTSetThrottleQuotaReq 

func NewTSetThrottleQuotaReq() *TSetThrottleQuotaReq

func (*TSetThrottleQuotaReq) Equals 

func (p *TSetThrottleQuotaReq) Equals(other *TSetThrottleQuotaReq) bool

func (*TSetThrottleQuotaReq) GetThrottleQuota 

func (p *TSetThrottleQuotaReq) GetThrottleQuota() *TThrottleQuota

func (*TSetThrottleQuotaReq) GetUserName 

func (p *TSetThrottleQuotaReq) GetUserName() string

func (*TSetThrottleQuotaReq) IsSetThrottleQuota 

func (p *TSetThrottleQuotaReq) IsSetThrottleQuota() bool

func (*TSetThrottleQuotaReq) Read 

func (p *TSetThrottleQuotaReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetThrottleQuotaReq) ReadField1 

func (p *TSetThrottleQuotaReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetThrottleQuotaReq) ReadField2 

func (p *TSetThrottleQuotaReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSetThrottleQuotaReq) String 

func (p *TSetThrottleQuotaReq) String() string

func (*TSetThrottleQuotaReq) Write 

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

type TSettleReq 

type TSettleReq struct {
	Paths []string `thrift:"paths,1,required" db:"paths" json:"paths"`
}

Attributes:

  • Paths

func NewTSettleReq 

func NewTSettleReq() *TSettleReq

func (*TSettleReq) Equals 

func (p *TSettleReq) Equals(other *TSettleReq) bool

func (*TSettleReq) GetPaths 

func (p *TSettleReq) GetPaths() []string

func (*TSettleReq) Read 

func (p *TSettleReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSettleReq) ReadField1 

func (p *TSettleReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSettleReq) String 

func (p *TSettleReq) String() string

func (*TSettleReq) Write 

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

type TShowConfigurationResp added in v1.3.3 

type TShowConfigurationResp struct {
	Status  *TSStatus `thrift:"status,1,required" db:"status" json:"status"`
	Content string    `thrift:"content,2,required" db:"content" json:"content"`
}

Attributes:

  • Status
  • Content

func NewTShowConfigurationResp added in v1.3.3 

func NewTShowConfigurationResp() *TShowConfigurationResp

func (*TShowConfigurationResp) Equals added in v1.3.3 

func (p *TShowConfigurationResp) Equals(other *TShowConfigurationResp) bool

func (*TShowConfigurationResp) GetContent added in v1.3.3 

func (p *TShowConfigurationResp) GetContent() string

func (*TShowConfigurationResp) GetStatus added in v1.3.3 

func (p *TShowConfigurationResp) GetStatus() *TSStatus

func (*TShowConfigurationResp) IsSetStatus added in v1.3.3 

func (p *TShowConfigurationResp) IsSetStatus() bool

func (*TShowConfigurationResp) Read added in v1.3.3 

func (p *TShowConfigurationResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TShowConfigurationResp) ReadField1 added in v1.3.3 

func (p *TShowConfigurationResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TShowConfigurationResp) ReadField2 added in v1.3.3 

func (p *TShowConfigurationResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TShowConfigurationResp) String added in v1.3.3 

func (p *TShowConfigurationResp) String() string

func (*TShowConfigurationResp) Write added in v1.3.3 

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

type TShowConfigurationTemplateResp added in v1.3.3 

type TShowConfigurationTemplateResp struct {
	Status  *TSStatus `thrift:"status,1,required" db:"status" json:"status"`
	Content string    `thrift:"content,2,required" db:"content" json:"content"`
}

Attributes:

  • Status
  • Content

func NewTShowConfigurationTemplateResp added in v1.3.3 

func NewTShowConfigurationTemplateResp() *TShowConfigurationTemplateResp

func (*TShowConfigurationTemplateResp) Equals added in v1.3.3 

func (p *TShowConfigurationTemplateResp) Equals(other *TShowConfigurationTemplateResp) bool

func (*TShowConfigurationTemplateResp) GetContent added in v1.3.3 

func (p *TShowConfigurationTemplateResp) GetContent() string

func (*TShowConfigurationTemplateResp) GetStatus added in v1.3.3 

func (p *TShowConfigurationTemplateResp) GetStatus() *TSStatus

func (*TShowConfigurationTemplateResp) IsSetStatus added in v1.3.3 

func (p *TShowConfigurationTemplateResp) IsSetStatus() bool

func (*TShowConfigurationTemplateResp) Read added in v1.3.3 

func (p *TShowConfigurationTemplateResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TShowConfigurationTemplateResp) ReadField1 added in v1.3.3 

func (p *TShowConfigurationTemplateResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TShowConfigurationTemplateResp) ReadField2 added in v1.3.3 

func (p *TShowConfigurationTemplateResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TShowConfigurationTemplateResp) String added in v1.3.3 

func (p *TShowConfigurationTemplateResp) String() string

func (*TShowConfigurationTemplateResp) Write added in v1.3.3 

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

type TShowTTLReq added in v1.3.3 

type TShowTTLReq struct {
	PathPattern []string `thrift:"pathPattern,1,required" db:"pathPattern" json:"pathPattern"`
}

Attributes:

  • PathPattern

func NewTShowTTLReq added in v1.3.3 

func NewTShowTTLReq() *TShowTTLReq

func (*TShowTTLReq) Equals added in v1.3.3 

func (p *TShowTTLReq) Equals(other *TShowTTLReq) bool

func (*TShowTTLReq) GetPathPattern added in v1.3.3 

func (p *TShowTTLReq) GetPathPattern() []string

func (*TShowTTLReq) Read added in v1.3.3 

func (p *TShowTTLReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TShowTTLReq) ReadField1 added in v1.3.3 

func (p *TShowTTLReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TShowTTLReq) String added in v1.3.3 

func (p *TShowTTLReq) String() string

func (*TShowTTLReq) Write added in v1.3.3 

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

type TSpaceQuota 

type TSpaceQuota struct {
	DiskSize     *int64 `thrift:"diskSize,1" db:"diskSize" json:"diskSize,omitempty"`
	DeviceNum    *int64 `thrift:"deviceNum,2" db:"deviceNum" json:"deviceNum,omitempty"`
	TimeserieNum *int64 `thrift:"timeserieNum,3" db:"timeserieNum" json:"timeserieNum,omitempty"`
}

Attributes:

  • DiskSize
  • DeviceNum
  • TimeserieNum
var TSetSpaceQuotaReq_SpaceLimit_DEFAULT *TSpaceQuota

func NewTSpaceQuota 

func NewTSpaceQuota() *TSpaceQuota

func (*TSpaceQuota) Equals 

func (p *TSpaceQuota) Equals(other *TSpaceQuota) bool

func (*TSpaceQuota) GetDeviceNum 

func (p *TSpaceQuota) GetDeviceNum() int64

func (*TSpaceQuota) GetDiskSize 

func (p *TSpaceQuota) GetDiskSize() int64

func (*TSpaceQuota) GetTimeserieNum 

func (p *TSpaceQuota) GetTimeserieNum() int64

func (*TSpaceQuota) IsSetDeviceNum 

func (p *TSpaceQuota) IsSetDeviceNum() bool

func (*TSpaceQuota) IsSetDiskSize 

func (p *TSpaceQuota) IsSetDiskSize() bool

func (*TSpaceQuota) IsSetTimeserieNum 

func (p *TSpaceQuota) IsSetTimeserieNum() bool

func (*TSpaceQuota) Read 

func (p *TSpaceQuota) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSpaceQuota) ReadField1 

func (p *TSpaceQuota) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSpaceQuota) ReadField2 

func (p *TSpaceQuota) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSpaceQuota) ReadField3 

func (p *TSpaceQuota) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSpaceQuota) String 

func (p *TSpaceQuota) String() string

func (*TSpaceQuota) Write 

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

type TTestConnectionResp added in v1.3.3 

type TTestConnectionResp struct {
	Status     *TSStatus                 `thrift:"status,1,required" db:"status" json:"status"`
	ResultList []*TTestConnectionResult_ `thrift:"resultList,2,required" db:"resultList" json:"resultList"`
}

Attributes:

  • Status
  • ResultList

func NewTTestConnectionResp added in v1.3.3 

func NewTTestConnectionResp() *TTestConnectionResp

func (*TTestConnectionResp) Equals added in v1.3.3 

func (p *TTestConnectionResp) Equals(other *TTestConnectionResp) bool

func (*TTestConnectionResp) GetResultList added in v1.3.3 

func (p *TTestConnectionResp) GetResultList() []*TTestConnectionResult_

func (*TTestConnectionResp) GetStatus added in v1.3.3 

func (p *TTestConnectionResp) GetStatus() *TSStatus

func (*TTestConnectionResp) IsSetStatus added in v1.3.3 

func (p *TTestConnectionResp) IsSetStatus() bool

func (*TTestConnectionResp) Read added in v1.3.3 

func (p *TTestConnectionResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTestConnectionResp) ReadField1 added in v1.3.3 

func (p *TTestConnectionResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTestConnectionResp) ReadField2 added in v1.3.3 

func (p *TTestConnectionResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TTestConnectionResp) String added in v1.3.3 

func (p *TTestConnectionResp) String() string

func (*TTestConnectionResp) Write added in v1.3.3 

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

type TTestConnectionResult_ added in v1.3.3 

type TTestConnectionResult_ struct {
	ServiceProvider *TServiceProvider `thrift:"serviceProvider,1,required" db:"serviceProvider" json:"serviceProvider"`
	Sender          *TSender          `thrift:"sender,2,required" db:"sender" json:"sender"`
	Success         bool              `thrift:"success,3,required" db:"success" json:"success"`
	Reason          *string           `thrift:"reason,4" db:"reason" json:"reason,omitempty"`
}

Attributes:

  • ServiceProvider
  • Sender
  • Success
  • Reason

func NewTTestConnectionResult_ added in v1.3.3 

func NewTTestConnectionResult_() *TTestConnectionResult_

func (*TTestConnectionResult_) Equals added in v1.3.3 

func (p *TTestConnectionResult_) Equals(other *TTestConnectionResult_) bool

func (*TTestConnectionResult_) GetReason added in v1.3.3 

func (p *TTestConnectionResult_) GetReason() string

func (*TTestConnectionResult_) GetSender added in v1.3.3 

func (p *TTestConnectionResult_) GetSender() *TSender

func (*TTestConnectionResult_) GetServiceProvider added in v1.3.3 

func (p *TTestConnectionResult_) GetServiceProvider() *TServiceProvider

func (*TTestConnectionResult_) GetSuccess added in v1.3.3 

func (p *TTestConnectionResult_) GetSuccess() bool

func (*TTestConnectionResult_) IsSetReason added in v1.3.3 

func (p *TTestConnectionResult_) IsSetReason() bool

func (*TTestConnectionResult_) IsSetSender added in v1.3.3 

func (p *TTestConnectionResult_) IsSetSender() bool

func (*TTestConnectionResult_) IsSetServiceProvider added in v1.3.3 

func (p *TTestConnectionResult_) IsSetServiceProvider() bool

func (*TTestConnectionResult_) Read added in v1.3.3 

func (p *TTestConnectionResult_) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTestConnectionResult_) ReadField1 added in v1.3.3 

func (p *TTestConnectionResult_) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTestConnectionResult_) ReadField2 added in v1.3.3 

func (p *TTestConnectionResult_) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TTestConnectionResult_) ReadField3 added in v1.3.3 

func (p *TTestConnectionResult_) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TTestConnectionResult_) ReadField4 added in v1.3.3 

func (p *TTestConnectionResult_) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TTestConnectionResult_) String added in v1.3.3 

func (p *TTestConnectionResult_) String() string

func (*TTestConnectionResult_) Write added in v1.3.3 

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

type TThrottleQuota 

type TThrottleQuota struct {
	ThrottleLimit map[ThrottleType]*TTimedQuota `thrift:"throttleLimit,1" db:"throttleLimit" json:"throttleLimit,omitempty"`
	MemLimit      *int64                        `thrift:"memLimit,2" db:"memLimit" json:"memLimit,omitempty"`
	CpuLimit      *int32                        `thrift:"cpuLimit,3" db:"cpuLimit" json:"cpuLimit,omitempty"`
}

Attributes:

  • ThrottleLimit
  • MemLimit
  • CpuLimit
var TSetThrottleQuotaReq_ThrottleQuota_DEFAULT *TThrottleQuota

func NewTThrottleQuota 

func NewTThrottleQuota() *TThrottleQuota

func (*TThrottleQuota) Equals 

func (p *TThrottleQuota) Equals(other *TThrottleQuota) bool

func (*TThrottleQuota) GetCpuLimit 

func (p *TThrottleQuota) GetCpuLimit() int32

func (*TThrottleQuota) GetMemLimit 

func (p *TThrottleQuota) GetMemLimit() int64

func (*TThrottleQuota) GetThrottleLimit 

func (p *TThrottleQuota) GetThrottleLimit() map[ThrottleType]*TTimedQuota

func (*TThrottleQuota) IsSetCpuLimit 

func (p *TThrottleQuota) IsSetCpuLimit() bool

func (*TThrottleQuota) IsSetMemLimit 

func (p *TThrottleQuota) IsSetMemLimit() bool

func (*TThrottleQuota) IsSetThrottleLimit 

func (p *TThrottleQuota) IsSetThrottleLimit() bool

func (*TThrottleQuota) Read 

func (p *TThrottleQuota) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TThrottleQuota) ReadField1 

func (p *TThrottleQuota) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TThrottleQuota) ReadField2 

func (p *TThrottleQuota) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TThrottleQuota) ReadField3 

func (p *TThrottleQuota) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TThrottleQuota) String 

func (p *TThrottleQuota) String() string

func (*TThrottleQuota) Write 

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

type TTimePartitionSlot 

type TTimePartitionSlot struct {
	StartTime int64 `thrift:"startTime,1,required" db:"startTime" json:"startTime"`
}

Attributes:

  • StartTime

func NewTTimePartitionSlot 

func NewTTimePartitionSlot() *TTimePartitionSlot

func (*TTimePartitionSlot) Equals 

func (p *TTimePartitionSlot) Equals(other *TTimePartitionSlot) bool

func (*TTimePartitionSlot) GetStartTime 

func (p *TTimePartitionSlot) GetStartTime() int64

func (*TTimePartitionSlot) Read 

func (p *TTimePartitionSlot) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimePartitionSlot) ReadField1 

func (p *TTimePartitionSlot) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimePartitionSlot) String 

func (p *TTimePartitionSlot) String() string

func (*TTimePartitionSlot) Write 

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

type TTimedQuota 

type TTimedQuota struct {
	TimeUnit  int64 `thrift:"timeUnit,1,required" db:"timeUnit" json:"timeUnit"`
	SoftLimit int64 `thrift:"softLimit,2,required" db:"softLimit" json:"softLimit"`
}

Attributes:

  • TimeUnit
  • SoftLimit

func NewTTimedQuota 

func NewTTimedQuota() *TTimedQuota

func (*TTimedQuota) Equals 

func (p *TTimedQuota) Equals(other *TTimedQuota) bool

func (*TTimedQuota) GetSoftLimit 

func (p *TTimedQuota) GetSoftLimit() int64

func (*TTimedQuota) GetTimeUnit 

func (p *TTimedQuota) GetTimeUnit() int64

func (*TTimedQuota) Read 

func (p *TTimedQuota) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimedQuota) ReadField1 

func (p *TTimedQuota) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimedQuota) ReadField2 

func (p *TTimedQuota) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TTimedQuota) String 

func (p *TTimedQuota) String() string

func (*TTimedQuota) Write 

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

type ThrottleType 

type ThrottleType int64
const (
	ThrottleType_REQUEST_NUMBER ThrottleType = 0
	ThrottleType_REQUEST_SIZE   ThrottleType = 1
	ThrottleType_WRITE_NUMBER   ThrottleType = 2
	ThrottleType_WRITE_SIZE     ThrottleType = 3
	ThrottleType_READ_NUMBER    ThrottleType = 4
	ThrottleType_READ_SIZE      ThrottleType = 5
)

func ThrottleTypeFromString 

func ThrottleTypeFromString(s string) (ThrottleType, error)

func ThrottleTypePtr 

func ThrottleTypePtr(v ThrottleType) *ThrottleType

func (ThrottleType) MarshalText 

func (p ThrottleType) MarshalText() ([]byte, error)

func (*ThrottleType) Scan 

func (p *ThrottleType) Scan(value interface{}) error

func (ThrottleType) String 

func (p ThrottleType) String() string

func (*ThrottleType) UnmarshalText 

func (p *ThrottleType) UnmarshalText(text []byte) error

func (*ThrottleType) Value 

func (p *ThrottleType) Value() (driver.Value, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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