Versions in this module Expand all Collapse all v1 v1.9.8 Jun 28, 2023 Changes in this version + func NewThrottledListener(listener net.Listener, maxConnsPerSec float64) net.Listener + type BandwidthThrottlerConfig struct + MaxBurstSize uint64 + RefillRate uint64 + type DialThrottler interface + Acquire func(ctx context.Context) error + func NewDialThrottler(throttleLimit int) DialThrottler + func NewNoDialThrottler() DialThrottler + type InboundConnUpgradeThrottler interface + Dispatch func() + ShouldUpgrade func(ip ips.IPPort) bool + Stop func() + func NewInboundConnUpgradeThrottler(log logging.Logger, config InboundConnUpgradeThrottlerConfig) InboundConnUpgradeThrottler + type InboundConnUpgradeThrottlerConfig struct + MaxRecentConnsUpgraded int + UpgradeCooldown time.Duration + type InboundMsgThrottler interface + Acquire func(ctx context.Context, msgSize uint64, nodeID ids.NodeID) ReleaseFunc + AddNode func(nodeID ids.NodeID) + RemoveNode func(nodeID ids.NodeID) + func NewInboundMsgThrottler(log logging.Logger, namespace string, registerer prometheus.Registerer, ...) (InboundMsgThrottler, error) + func NewNoInboundThrottler() InboundMsgThrottler + type InboundMsgThrottlerConfig struct + CPUThrottlerConfig SystemThrottlerConfig + DiskThrottlerConfig SystemThrottlerConfig + MaxProcessingMsgsPerNode uint64 + type MsgByteThrottlerConfig struct + AtLargeAllocSize uint64 + NodeMaxAtLargeBytes uint64 + VdrAllocSize uint64 + type OutboundMsgThrottler interface + Acquire func(msg message.OutboundMessage, nodeID ids.NodeID) bool + Release func(msg message.OutboundMessage, nodeID ids.NodeID) + func NewNoOutboundThrottler() OutboundMsgThrottler + func NewSybilOutboundMsgThrottler(log logging.Logger, namespace string, registerer prometheus.Registerer, ...) (OutboundMsgThrottler, error) + type ReleaseFunc func() + type SystemThrottler interface + Acquire func(ctx context.Context, nodeID ids.NodeID) + func NewSystemThrottler(namespace string, reg prometheus.Registerer, config SystemThrottlerConfig, ...) (SystemThrottler, error) + type SystemThrottlerConfig struct + Clock mockable.Clock + MaxRecheckDelay time.Duration v1.9.8-rc.9 Jun 28, 2023
Go to main page