Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

common

package

Go to main page

Versions in this module

v1

v1.2.0-tsbs

May 29, 2023

v1.1.7

Apr 25, 2023

v1.1.6

Apr 24, 2023

v1.1.5

Apr 12, 2023

Changes in this version

+ var GoUnusedProtection__ int

+ var TFlushReq_IsSeq_DEFAULT string

+ var TFlushReq_StorageGroups_DEFAULT []string

+ var TSStatus_Message_DEFAULT string

+ var TSStatus_SubStatus_DEFAULT []*TSStatus

+ var TSpaceQuota_DeviceNum_DEFAULT int64

+ var TSpaceQuota_DiskSize_DEFAULT int64

+ var TSpaceQuota_TimeserieNum_DEFAULT int64

+ var TThrottleQuota_CpuLimit_DEFAULT int32

+ var TThrottleQuota_MemLimit_DEFAULT int64

+ var TThrottleQuota_ThrottleLimit_DEFAULT map[ThrottleType]*TTimedQuota

+ type ModelTask int64

+ const ModelTask_FORECAST

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

+ func ModelTaskPtr(v ModelTask) *ModelTask

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

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

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

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

+ func (p ModelTask) String() string

+ type TAggregationType int64

+ const TAggregationType_AVG

+ const TAggregationType_COUNT

+ const TAggregationType_COUNT_IF

+ const TAggregationType_EXTREME

+ const TAggregationType_FIRST_VALUE

+ const TAggregationType_LAST_VALUE

+ const TAggregationType_MAX_TIME

+ const TAggregationType_MAX_VALUE

+ const TAggregationType_MIN_TIME

+ const TAggregationType_MIN_VALUE

+ const TAggregationType_MODE

+ const TAggregationType_SUM

+ const TAggregationType_TIME_DURATION

+ func TAggregationTypeFromString(s string) (TAggregationType, error)

+ func TAggregationTypePtr(v TAggregationType) *TAggregationType

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

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

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

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

+ func (p TAggregationType) String() string

+ type TConfigNodeLocation struct

+ ConfigNodeId int32

+ ConsensusEndPoint *TEndPoint

+ InternalEndPoint *TEndPoint

+ func NewTConfigNodeLocation() *TConfigNodeLocation

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

+ func (p *TConfigNodeLocation) GetConfigNodeId() int32

+ func (p *TConfigNodeLocation) GetConsensusEndPoint() *TEndPoint

+ func (p *TConfigNodeLocation) GetInternalEndPoint() *TEndPoint

+ func (p *TConfigNodeLocation) IsSetConsensusEndPoint() bool

+ func (p *TConfigNodeLocation) IsSetInternalEndPoint() bool

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

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

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

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

+ func (p *TConfigNodeLocation) String() string

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

+ type TConsensusGroupId struct

+ ID int32

+ Type TConsensusGroupType

+ var TRegionReplicaSet_RegionId_DEFAULT *TConsensusGroupId

+ func NewTConsensusGroupId() *TConsensusGroupId

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

+ func (p *TConsensusGroupId) GetID() int32

+ func (p *TConsensusGroupId) GetType() TConsensusGroupType

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

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

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

+ func (p *TConsensusGroupId) String() string

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

+ type TConsensusGroupType int64

+ const TConsensusGroupType_ConfigRegion

+ const TConsensusGroupType_DataRegion

+ const TConsensusGroupType_SchemaRegion

+ func TConsensusGroupTypeFromString(s string) (TConsensusGroupType, error)

+ func TConsensusGroupTypePtr(v TConsensusGroupType) *TConsensusGroupType

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

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

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

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

+ func (p TConsensusGroupType) String() string

+ type TDataNodeConfiguration struct

+ Location *TDataNodeLocation

+ Resource *TNodeResource

+ func NewTDataNodeConfiguration() *TDataNodeConfiguration

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

+ func (p *TDataNodeConfiguration) GetLocation() *TDataNodeLocation

+ func (p *TDataNodeConfiguration) GetResource() *TNodeResource

+ func (p *TDataNodeConfiguration) IsSetLocation() bool

+ func (p *TDataNodeConfiguration) IsSetResource() bool

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

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

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

+ func (p *TDataNodeConfiguration) String() string

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

+ type TDataNodeLocation struct

+ ClientRpcEndPoint *TEndPoint

+ DataNodeId int32

+ DataRegionConsensusEndPoint *TEndPoint

+ InternalEndPoint *TEndPoint

+ MPPDataExchangeEndPoint *TEndPoint

+ SchemaRegionConsensusEndPoint *TEndPoint

+ var TDataNodeConfiguration_Location_DEFAULT *TDataNodeLocation

+ func NewTDataNodeLocation() *TDataNodeLocation

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

+ func (p *TDataNodeLocation) GetClientRpcEndPoint() *TEndPoint

+ func (p *TDataNodeLocation) GetDataNodeId() int32

+ func (p *TDataNodeLocation) GetDataRegionConsensusEndPoint() *TEndPoint

+ func (p *TDataNodeLocation) GetInternalEndPoint() *TEndPoint

+ func (p *TDataNodeLocation) GetMPPDataExchangeEndPoint() *TEndPoint

+ func (p *TDataNodeLocation) GetSchemaRegionConsensusEndPoint() *TEndPoint

+ func (p *TDataNodeLocation) IsSetClientRpcEndPoint() bool

+ func (p *TDataNodeLocation) IsSetDataRegionConsensusEndPoint() bool

+ func (p *TDataNodeLocation) IsSetInternalEndPoint() bool

+ func (p *TDataNodeLocation) IsSetMPPDataExchangeEndPoint() bool

+ func (p *TDataNodeLocation) IsSetSchemaRegionConsensusEndPoint() bool

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

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

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

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

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

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

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

+ func (p *TDataNodeLocation) String() string

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

+ type TEndPoint struct

+ IP string

+ Port int32

+ var TConfigNodeLocation_ConsensusEndPoint_DEFAULT *TEndPoint

+ var TConfigNodeLocation_InternalEndPoint_DEFAULT *TEndPoint

+ var TDataNodeLocation_ClientRpcEndPoint_DEFAULT *TEndPoint

+ var TDataNodeLocation_DataRegionConsensusEndPoint_DEFAULT *TEndPoint

+ var TDataNodeLocation_InternalEndPoint_DEFAULT *TEndPoint

+ var TDataNodeLocation_MPPDataExchangeEndPoint_DEFAULT *TEndPoint

+ var TDataNodeLocation_SchemaRegionConsensusEndPoint_DEFAULT *TEndPoint

+ var TSStatus_RedirectNode_DEFAULT *TEndPoint

+ func NewTEndPoint() *TEndPoint

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

+ func (p *TEndPoint) GetIP() string

+ func (p *TEndPoint) GetPort() int32

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

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

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

+ func (p *TEndPoint) String() string

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

+ type TFile struct

+ File []byte

+ FileName string

+ func NewTFile() *TFile

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

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

+ func (p *TFile) GetFileName() string

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

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

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

+ func (p *TFile) String() string

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

+ type TFilesResp struct

+ Files []*TFile

+ Status *TSStatus

+ func NewTFilesResp() *TFilesResp

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

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

+ func (p *TFilesResp) GetStatus() *TSStatus

+ func (p *TFilesResp) IsSetStatus() bool

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

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

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

+ func (p *TFilesResp) String() string

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

+ type TFlushReq struct

+ IsSeq *string

+ StorageGroups []string

+ func NewTFlushReq() *TFlushReq

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

+ func (p *TFlushReq) GetIsSeq() string

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

+ func (p *TFlushReq) IsSetIsSeq() bool

+ func (p *TFlushReq) IsSetStorageGroups() bool

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

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

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

+ func (p *TFlushReq) String() string

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

+ type TNodeResource struct

+ CpuCoreNum int32

+ MaxMemory int64

+ var TDataNodeConfiguration_Resource_DEFAULT *TNodeResource

+ func NewTNodeResource() *TNodeResource

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

+ func (p *TNodeResource) GetCpuCoreNum() int32

+ func (p *TNodeResource) GetMaxMemory() int64

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

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

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

+ func (p *TNodeResource) String() string

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

+ type TRegionMigrateFailedType int64

+ const TRegionMigrateFailedType_AddPeerFailed

+ const TRegionMigrateFailedType_CreateRegionFailed

+ const TRegionMigrateFailedType_DeleteRegionFailed

+ const TRegionMigrateFailedType_RemoveConsensusGroupFailed

+ const TRegionMigrateFailedType_RemovePeerFailed

+ func TRegionMigrateFailedTypeFromString(s string) (TRegionMigrateFailedType, error)

+ func TRegionMigrateFailedTypePtr(v TRegionMigrateFailedType) *TRegionMigrateFailedType

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

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

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

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

+ func (p TRegionMigrateFailedType) String() string

+ type TRegionReplicaSet struct

+ DataNodeLocations []*TDataNodeLocation

+ RegionId *TConsensusGroupId

+ func NewTRegionReplicaSet() *TRegionReplicaSet

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

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

+ func (p *TRegionReplicaSet) GetRegionId() *TConsensusGroupId

+ func (p *TRegionReplicaSet) IsSetRegionId() bool

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

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

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

+ func (p *TRegionReplicaSet) String() string

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

+ type TSStatus struct

+ Code int32

+ Message *string

+ RedirectNode *TEndPoint

+ SubStatus []*TSStatus

+ var TFilesResp_Status_DEFAULT *TSStatus

+ func NewTSStatus() *TSStatus

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

+ func (p *TSStatus) GetCode() int32

+ func (p *TSStatus) GetMessage() string

+ func (p *TSStatus) GetRedirectNode() *TEndPoint

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

+ func (p *TSStatus) IsSetMessage() bool

+ func (p *TSStatus) IsSetRedirectNode() bool

+ func (p *TSStatus) IsSetSubStatus() bool

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

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

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

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

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

+ func (p *TSStatus) String() string

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

+ type TSchemaNode struct

+ NodeName string

+ NodeType int8

+ func NewTSchemaNode() *TSchemaNode

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

+ func (p *TSchemaNode) GetNodeName() string

+ func (p *TSchemaNode) GetNodeType() int8

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

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

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

+ func (p *TSchemaNode) String() string

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

+ type TSeriesPartitionSlot struct

+ SlotId int32

+ func NewTSeriesPartitionSlot() *TSeriesPartitionSlot

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

+ func (p *TSeriesPartitionSlot) GetSlotId() int32

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

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

+ func (p *TSeriesPartitionSlot) String() string

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

+ type TSetSpaceQuotaReq struct

+ Database []string

+ SpaceLimit *TSpaceQuota

+ func NewTSetSpaceQuotaReq() *TSetSpaceQuotaReq

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

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

+ func (p *TSetSpaceQuotaReq) GetSpaceLimit() *TSpaceQuota

+ func (p *TSetSpaceQuotaReq) IsSetSpaceLimit() bool

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

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

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

+ func (p *TSetSpaceQuotaReq) String() string

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

+ type TSetTTLReq struct

+ StorageGroupPathPattern []string

+ TTL int64

+ func NewTSetTTLReq() *TSetTTLReq

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

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

+ func (p *TSetTTLReq) GetTTL() int64

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

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

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

+ func (p *TSetTTLReq) String() string

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

+ type TSetThrottleQuotaReq struct

+ ThrottleQuota *TThrottleQuota

+ UserName string

+ func NewTSetThrottleQuotaReq() *TSetThrottleQuotaReq

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

+ func (p *TSetThrottleQuotaReq) GetThrottleQuota() *TThrottleQuota

+ func (p *TSetThrottleQuotaReq) GetUserName() string

+ func (p *TSetThrottleQuotaReq) IsSetThrottleQuota() bool

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

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

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

+ func (p *TSetThrottleQuotaReq) String() string

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

+ type TSettleReq struct

+ Paths []string

+ func NewTSettleReq() *TSettleReq

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

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

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

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

+ func (p *TSettleReq) String() string

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

+ type TSpaceQuota struct

+ DeviceNum *int64

+ DiskSize *int64

+ TimeserieNum *int64

+ var TSetSpaceQuotaReq_SpaceLimit_DEFAULT *TSpaceQuota

+ func NewTSpaceQuota() *TSpaceQuota

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

+ func (p *TSpaceQuota) GetDeviceNum() int64

+ func (p *TSpaceQuota) GetDiskSize() int64

+ func (p *TSpaceQuota) GetTimeserieNum() int64

+ func (p *TSpaceQuota) IsSetDeviceNum() bool

+ func (p *TSpaceQuota) IsSetDiskSize() bool

+ func (p *TSpaceQuota) IsSetTimeserieNum() bool

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

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

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

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

+ func (p *TSpaceQuota) String() string

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

+ type TThrottleQuota struct

+ CpuLimit *int32

+ MemLimit *int64

+ ThrottleLimit map[ThrottleType]*TTimedQuota

+ var TSetThrottleQuotaReq_ThrottleQuota_DEFAULT *TThrottleQuota

+ func NewTThrottleQuota() *TThrottleQuota

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

+ func (p *TThrottleQuota) GetCpuLimit() int32

+ func (p *TThrottleQuota) GetMemLimit() int64

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

+ func (p *TThrottleQuota) IsSetCpuLimit() bool

+ func (p *TThrottleQuota) IsSetMemLimit() bool

+ func (p *TThrottleQuota) IsSetThrottleLimit() bool

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

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

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

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

+ func (p *TThrottleQuota) String() string

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

+ type TTimePartitionSlot struct

+ StartTime int64

+ func NewTTimePartitionSlot() *TTimePartitionSlot

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

+ func (p *TTimePartitionSlot) GetStartTime() int64

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

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

+ func (p *TTimePartitionSlot) String() string

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

+ type TTimedQuota struct

+ SoftLimit int64

+ TimeUnit int64

+ func NewTTimedQuota() *TTimedQuota

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

+ func (p *TTimedQuota) GetSoftLimit() int64

+ func (p *TTimedQuota) GetTimeUnit() int64

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

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

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

+ func (p *TTimedQuota) String() string

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

+ type ThrottleType int64

+ const ThrottleType_READ_NUMBER

+ const ThrottleType_READ_SIZE

+ const ThrottleType_REQUEST_NUMBER

+ const ThrottleType_REQUEST_SIZE

+ const ThrottleType_WRITE_NUMBER

+ const ThrottleType_WRITE_SIZE

+ func ThrottleTypeFromString(s string) (ThrottleType, error)

+ func ThrottleTypePtr(v ThrottleType) *ThrottleType

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

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

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

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

+ func (p ThrottleType) String() string

+ type TrainingState int64

+ const TrainingState_DROPPING

+ const TrainingState_FAILED

+ const TrainingState_FINISHED

+ const TrainingState_PENDING

+ const TrainingState_RUNNING

+ func TrainingStateFromString(s string) (TrainingState, error)

+ func TrainingStatePtr(v TrainingState) *TrainingState

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

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

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

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

+ func (p TrainingState) String() string

v1.1.1-tsbs

May 15, 2023

v1.1.0-tsbs

May 17, 2023