Versions in this module Expand all Collapse all v0 v0.23.5 Nov 8, 2022 Changes in this version + var DefaultResolution = 1 * time.Minute + func NewDecayer(cfg *DecayerCfg, mgr *BasicConnMgr) (*decayer, error) + type BasicConnMgr struct + func NewConnManager(low, hi int, opts ...Option) (*BasicConnMgr, error) + func (cm *BasicConnMgr) Close() error + func (cm *BasicConnMgr) GetInfo() CMInfo + func (cm *BasicConnMgr) GetTagInfo(p peer.ID) *connmgr.TagInfo + func (cm *BasicConnMgr) IsProtected(id peer.ID, tag string) (protected bool) + 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(_ 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) + func (d BasicConnMgr) RegisterDecayingTag(name string, interval time.Duration, decayFn connmgr.DecayFn, ...) (connmgr.DecayingTag, error) + type CMInfo struct + ConnCount int + GracePeriod time.Duration + HighWater int + LastTrim time.Time + LowWater int + type DecayerCfg struct + Clock clock.Clock + Resolution time.Duration + func (cfg *DecayerCfg) WithDefaults() *DecayerCfg + type Option func(*config) error + func DecayerConfig(opts *DecayerCfg) Option + func WithClock(c clock.Clock) Option + func WithEmergencyTrim(enable bool) Option + func WithGracePeriod(p time.Duration) Option + func WithSilencePeriod(p time.Duration) Option