Documentation ¶
Index ¶
Constants ¶
View Source
const ( DataPartitionViewUrl = "/client/dataPartitions" GetClusterInfoURL = "/admin/getIp" ActionGetDataPartitionView = "ActionGetDataPartitionView" MinWritableDataPartitionNum = 10 )
Variables ¶
View Source
var ( MasterHelper = util.NewMasterHelper() LocalIP, _ = util.GetLocalIP() )
Functions ¶
Types ¶
type ClusterInfo ¶
type ClusterInfo struct {
Cluster string
}
type DataPartition ¶
type DataPartition struct { PartitionID uint32 Status int8 ReplicaNum uint8 PartitionType string Hosts []string Metrics *DataPartitionMetrics }
func (*DataPartition) GetAllAddrs ¶
func (dp *DataPartition) GetAllAddrs() (m string)
func (*DataPartition) String ¶
func (dp *DataPartition) String() string
type DataPartitionMetrics ¶
type DataPartitionMetrics struct { WriteCnt uint64 ReadCnt uint64 SumWriteLatency uint64 SumReadLatency uint64 WriteLatency float64 ReadLatency float64 }
func NewDataPartitionMetrics ¶
func NewDataPartitionMetrics() *DataPartitionMetrics
type DataPartitionSlice ¶
type DataPartitionSlice []*DataPartition
func (DataPartitionSlice) Len ¶
func (ds DataPartitionSlice) Len() int
func (DataPartitionSlice) Less ¶
func (ds DataPartitionSlice) Less(i, j int) bool
func (DataPartitionSlice) Swap ¶
func (ds DataPartitionSlice) Swap(i, j int)
type DataPartitionView ¶
type DataPartitionView struct {
DataPartitions []*DataPartition
}
type Wrapper ¶
func NewDataPartitionWrapper ¶
func (*Wrapper) GetClusterName ¶
func (*Wrapper) GetDataPartition ¶
func (w *Wrapper) GetDataPartition(partitionID uint32) (*DataPartition, error)
func (*Wrapper) GetWriteDataPartition ¶
func (w *Wrapper) GetWriteDataPartition(exclude []uint32) (*DataPartition, error)
func (*Wrapper) UmpWarningKey ¶
Click to show internal directories.
Click to hide internal directories.