common

package
v1.1.5 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2023 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 TSStatus_Message_DEFAULT string
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 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 ModelTask 

type ModelTask int64
const (
	ModelTask_FORECAST ModelTask = 0
)

func ModelTaskFromString 

func ModelTaskFromString(s string) (ModelTask, error)

func ModelTaskPtr 

func ModelTaskPtr(v ModelTask) *ModelTask

func (ModelTask) MarshalText 

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

func (*ModelTask) Scan 

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

func (ModelTask) String 

func (p ModelTask) String() string

func (*ModelTask) UnmarshalText 

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

func (*ModelTask) Value 

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

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
)

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

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

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

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

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"`
}

Attributes:

  • Code
  • Message
  • SubStatus
  • RedirectNode
var TFilesResp_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) GetRedirectNode 

func (p *TSStatus) GetRedirectNode() *TEndPoint

func (*TSStatus) GetSubStatus 

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

func (*TSStatus) IsSetMessage 

func (p *TSStatus) IsSetMessage() 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) 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 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 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 {
	StorageGroupPathPattern []string `thrift:"storageGroupPathPattern,1,required" db:"storageGroupPathPattern" json:"storageGroupPathPattern"`
	TTL                     int64    `thrift:"TTL,2,required" db:"TTL" json:"TTL"`
}

Attributes:

  • StorageGroupPathPattern
  • TTL

func NewTSetTTLReq 

func NewTSetTTLReq() *TSetTTLReq

func (*TSetTTLReq) Equals 

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

func (*TSetTTLReq) GetStorageGroupPathPattern 

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

type TrainingState 

type TrainingState int64
const (
	TrainingState_PENDING  TrainingState = 0
	TrainingState_RUNNING  TrainingState = 1
	TrainingState_FINISHED TrainingState = 2
	TrainingState_FAILED   TrainingState = 3
	TrainingState_DROPPING TrainingState = 4
)

func TrainingStateFromString 

func TrainingStateFromString(s string) (TrainingState, error)

func TrainingStatePtr 

func TrainingStatePtr(v TrainingState) *TrainingState

func (TrainingState) MarshalText 

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

func (*TrainingState) Scan 

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

func (TrainingState) String 

func (p TrainingState) String() string

func (*TrainingState) UnmarshalText 

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

func (*TrainingState) Value 

func (p *TrainingState) 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.