Versions in this module Expand all Collapse all v1 v1.0.1 Apr 26, 2021 Changes in this version + func SortStructsByField(structs []interface{}, key string) v1.0.0 Dec 9, 2020 Changes in this version + func FormatDate(date int64) string + func GetNodeStats(perfClient *aggregate.PerfClient) (map[string]*aggregate.NodeStat, error) + func GetPartitionStat(perfSession *aggregate.PerfSession, counter string, gpid string) int64 + func Str2Gpid(gpid string) (*base.Gpid, error) + type PegasusNode struct + Hostname string + IP net.IP + Port int + Type session.NodeType + func (n *PegasusNode) CombinedAddr() string + func (n *PegasusNode) Replica() *session.ReplicaSession + func (n *PegasusNode) Session() session.NodeSession + func (n *PegasusNode) String() string + func (n *PegasusNode) TCPAddr() string + type PegasusNodeManager struct + MetaAddresses []string + func NewPegasusNodeManager(metaAddrs []string, replicaAddrs []string) *PegasusNodeManager + func (m *PegasusNodeManager) GetAllNodes(ntype session.NodeType) []*PegasusNode + func (m *PegasusNodeManager) GetNode(addr string, ntype session.NodeType) (*PegasusNode, error) + func (m *PegasusNodeManager) GetPerfSession(addr string, ntype session.NodeType) *aggregate.PerfSession + func (m *PegasusNodeManager) MustGetReplica(addr string) *PegasusNode
Go to main page