wrapper

package
v0.0.0-...-71dd0ca Latest Latest
Warning

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

Go to latest
Published: Oct 12, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

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

func NewGetDataPartitionMetricsPacket

func NewGetDataPartitionMetricsPacket(partitionid uint32) (p *proto.Packet)

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

type Wrapper struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDataPartitionWrapper

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

func (*Wrapper) GetClusterName

func (w *Wrapper) GetClusterName() string

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

func (w *Wrapper) UmpWarningKey() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL