wrapper

Nov 13, 2019

Changes in this version

+ var MinWriteAbleDataPartitionCnt = 10

type DataPartition

+ func (dp *DataPartition) CheckAllHostsIsAvail(exclude map[string]struct{})

type Wrapper

+ func (w *Wrapper) FollowerRead() bool

Apr 2, 2019

Changes in this version

+ var LocalIP string

+ var MasterHelper = util.NewMasterHelper()

+ type DataPartition struct

+ Metrics *DataPartitionMetrics

+ PartitionType string

+ RandomWrite bool

+ func (dp *DataPartition) GetAllAddrs() string

+ func (dp *DataPartition) String() string

+ type DataPartitionMetrics struct

+ ReadLatency float64

+ WriteLatency float64

+ func NewDataPartitionMetrics() *DataPartitionMetrics

+ type DataPartitionSorter []*DataPartition

+ func (ds DataPartitionSorter) Len() int

+ func (ds DataPartitionSorter) Less(i, j int) bool

+ func (ds DataPartitionSorter) Swap(i, j int)

+ type DataPartitionView struct

+ DataPartitions []*DataPartition

+ type Wrapper struct

+ func NewDataPartitionWrapper(volName, masterHosts string) (w *Wrapper, err error)

+ func (w *Wrapper) GetClusterName() string

+ func (w *Wrapper) GetDataPartition(partitionID uint64) (*DataPartition, error)

+ func (w *Wrapper) GetDataPartitionForWrite(exclude []uint64) (*DataPartition, error)

+ func (w *Wrapper) WarningMsg() string