Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TCPSender ¶
type TCPSender struct {
// contains filtered or unexported fields
}
TCPSender sends gibberish to a TCP endpoint at full speed.
func NewTCPSender ¶
func NewTCPSender(dialer net.Dialer, network, address string, retryInterval time.Duration) *TCPSender
NewTCPSender creates a new TCPSender.
type ThrottledSender ¶
type ThrottledSender struct {
// contains filtered or unexported fields
}
ThrottledSender sends gibberish to a TCP or UDP endpoint at a specified speed.
func NewThrottledSender ¶
func NewThrottledSender(listenConfig net.ListenConfig, dialer net.Dialer, network, address string, packetSize, txSpeedMbps int, retryInterval time.Duration) (*ThrottledSender, error)
NewThrottledSender creates a new ThrottledSender.
func (*ThrottledSender) Run ¶
func (s *ThrottledSender) Run(ctx context.Context, logger *zap.Logger)
Run starts sending gibberish until the context is done.
func (*ThrottledSender) RunParallel ¶
RunParallel starts multiple sending goroutines that finish when the context is done.
Click to show internal directories.
Click to hide internal directories.