Method GetPerfSession

admin-cli/util/pegasus_node.go:206–213

(addr string, ntype session.NodeType)

}

func (m *PegasusNodeManager) GetPerfSession(addr string, ntype session.NodeType) *aggregate.PerfSession {
	node, err := m.GetNode(addr, ntype)
	if err != nil {
		panic(fmt.Sprintf("Get PerfSession %s error %s", addr, err))
	}

	return aggregate.WrapPerf(addr, node.session)
}