flowcontrol

package

v1.5.6-0...-0fac8cb Latest Latest Go to latest Published: Jan 4, 2017 License: GPL-3.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package flowcontrol implements a client side flow control mechanism

This section is empty.

This section is empty.

This section is empty.

type ClientManager struct {
	// contains filtered or unexported fields
}

func NewClientManager(rcTarget, maxSimReq, maxRcSum uint64) *ClientManager

func (self *ClientManager) Stop()

type ClientNode struct {
	// contains filtered or unexported fields
}

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 {
	// contains filtered or unexported fields
}

func NewServerNode(params *ServerParams) *ServerNode

func (peer *ServerNode) CanSend(maxCost uint64) uint64

func (peer *ServerNode) GotReply(reqID, bv uint64)

func (peer *ServerNode) SendRequest(reqID, maxCost uint64)

blocks until request can be sent

type ServerParams struct {
	BufLimit, MinRecharge uint64
}