Versions in this module Expand all Collapse all v1 v1.2.0 Mar 25, 2022 v1.1.0 Jun 9, 2021 v1.0.3 May 8, 2021 v1.0.2 May 6, 2021 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) map[string]float64 + func SortStructsByField(structs []interface{}, key string) + func Str2Gpid(gpid string) (*base.Gpid, error) + type PegasusNode struct + Hostname string + IP net.IP + Port int + Type session.NodeType + func NewNodeFromTCPAddr(addr string, ntype session.NodeType) *PegasusNode + func (n *PegasusNode) CombinedAddr() string + func (n *PegasusNode) RPCAddress() *base.RPCAddress + 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