load

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient() *Client
  • func (client *Client) Close() error
  • func (client *Client) Pause()
  • func (client *Client) Resume()
  • func (client *Client) SendLoad() error
  • func (client *Client) SetPayload(size uint)
  • func (client *Client) StartLoad(bytePerSecond uint64)
• type LoadPacket
  • func (packet *LoadPacket) PrintReceived()
  • func (packet *LoadPacket) Size() uint
  • func (packet *LoadPacket) String() string
• type LoadStats
  • func RegisterServer(server *protocols.Server) (*LoadStats, error)

Constants

const (
	PacketSize = 105 // Reported by tcpdump, size of LoadPacket with empty Payload. Varies between 105-107.
)

Variables

var (
	Protocol     *loadProtocol
	MiniProtocol = protocols.NewMiniProtocolTransport(Protocol, protocols.UdpTransportB(2048))
)

Types

type Client

type Client struct {
	protocols.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient() *Client

func (*Client) Close

func (client *Client) Close() error

func (*Client) Pause

func (client *Client) Pause()

func (*Client) Resume

func (client *Client) Resume()

func (*Client) SendLoad

func (client *Client) SendLoad() error

func (*Client) SetPayload

func (client *Client) SetPayload(size uint)

func (*Client) StartLoad

func (client *Client) StartLoad(bytePerSecond uint64)

type LoadPacket

type LoadPacket struct {
	Seq       uint
	Payload   []byte
	Timestamp time.Time
}

func (*LoadPacket) PrintReceived

func (packet *LoadPacket) PrintReceived()

func (*LoadPacket) Size

func (packet *LoadPacket) Size() uint

func (*LoadPacket) String

func (packet *LoadPacket) String() string

type LoadStats

type LoadStats struct {
	Received *stats.Stats
	Missed   *stats.Stats

	Handler func(packet *LoadPacket)
	// contains filtered or unexported fields
}

func RegisterServer

func RegisterServer(server *protocols.Server) (*LoadStats, error)