connmgr

Jul 30, 2020

Changes in this version

+ var DefaultResolution = 1 * time.Minute

+ func NewDecayer(cfg *DecayerCfg, mgr *BasicConnMgr) (*decayer, error)

+ type BasicConnManagerConfig struct

type BasicConnMgr

+ func (cm *BasicConnMgr) IsProtected(id peer.ID, tag string) (protected bool)

+ func (d BasicConnMgr) RegisterDecayingTag(name string, interval time.Duration, decayFn connmgr.DecayFn, ...) (connmgr.DecayingTag, error)

+ type DecayerCfg struct

+ Clock clock.Clock

+ Resolution time.Duration

+ func (cfg *DecayerCfg) WithDefaults() *DecayerCfg

+ type Option func(*BasicConnManagerConfig) error

+ func DecayerConfig(opts *DecayerCfg) Option

Jun 10, 2019

Changes in this version

+ var SilencePeriod = 10 * time.Second

+ type BasicConnMgr struct

+ func NewConnManager(ctx context.Context, wg *sync.WaitGroup, logger *zap.Logger, low, hi int, ...) *BasicConnMgr

+ func (cm *BasicConnMgr) Close() error

+ func (cm *BasicConnMgr) GetInfo() CMInfo

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

+ func (cm *BasicConnMgr) Notifee() network.Notifiee

+ func (cm *BasicConnMgr) Protect(id peer.ID, tag string)

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

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

+ func (cm *BasicConnMgr) Unprotect(id peer.ID, tag string) (protected bool)

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

+ func (cm *BasicConnMgr) UpsertTag(p peer.ID, tag string, upsert func(int) int)

+ type CMInfo struct

+ ConnCount int

+ GracePeriod time.Duration

+ HighWater int

+ LastTrim time.Time

+ LowWater int