Versions in this module Expand all Collapse all v1 v1.5.6 Dec 23, 2019 Changes in this version + type ClientManager struct + func NewClientManager(rcTarget, maxSimReq, maxRcSum uint64) *ClientManager + func (self *ClientManager) Stop() + type ClientNode struct + func NewClientNode(cm *ClientManager, params *ServerParams) *ClientNode + func (peer *ClientNode) AcceptRequest() (uint64, bool) + func (peer *ClientNode) Remove(cm *ClientManager) + func (peer *ClientNode) RequestProcessed(cost uint64) (bv, realCost uint64) + type ServerNode struct + func NewServerNode(params *ServerParams) *ServerNode + func (peer *ServerNode) CanSend(maxCost uint64) (time.Duration, float64) + func (peer *ServerNode) GotReply(reqID, bv uint64) + func (peer *ServerNode) QueueRequest(reqID, maxCost uint64) + type ServerParams struct + BufLimit uint64 + MinRecharge uint64
Go to main page