connmgr

README

go-libp2p-connmgr

A package to help manage connections in go-libp2p

Table of Contents

• Install
• Usage
• API
• Contribute
• License

Install

make install

Examples

// TODO:

Contribute

PRs are welcome!

Small note: If editing the Readme, please conform to the standard-readme specification.

License

MIT © Whyrusleeping

Documentation

Index

• type BasicConnMgr
  • func NewConnManager(low, hi int, grace time.Duration) *BasicConnMgr
  • func (cm *BasicConnMgr) GetInfo() CMInfo
  • func (cm *BasicConnMgr) GetTagInfo(p peer.ID) *ifconnmgr.TagInfo
  • func (cm *BasicConnMgr) Notifee() inet.Notifiee
  • func (cm *BasicConnMgr) TagPeer(p peer.ID, tag string, val int)
  • func (cm *BasicConnMgr) TrimOpenConns(ctx context.Context)
  • func (cm *BasicConnMgr) UntagPeer(p peer.ID, tag string)
• type CMInfo

Types

type BasicConnMgr

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

func NewConnManager

func NewConnManager(low, hi int, grace time.Duration) *BasicConnMgr

func (*BasicConnMgr) GetInfo

func (cm *BasicConnMgr) GetInfo() CMInfo

func (*BasicConnMgr) GetTagInfo

func (cm *BasicConnMgr) GetTagInfo(p peer.ID) *ifconnmgr.TagInfo

func (*BasicConnMgr) Notifee

func (cm *BasicConnMgr) Notifee() inet.Notifiee

func (*BasicConnMgr) TagPeer

func (cm *BasicConnMgr) TagPeer(p peer.ID, tag string, val int)

func (*BasicConnMgr) TrimOpenConns

func (cm *BasicConnMgr) TrimOpenConns(ctx context.Context)

func (*BasicConnMgr) UntagPeer

func (cm *BasicConnMgr) UntagPeer(p peer.ID, tag string)

type CMInfo

type CMInfo struct {
	LowWater    int
	HighWater   int
	LastTrim    time.Time
	GracePeriod time.Duration
	ConnCount   int
}