Documentation
¶
Index ¶
Constants ¶
View Source
const ( BlockTypePlain byte = 1 BlockTypeLatencyRequest byte = 2 BlockTypeLatencyResponse byte = 3 )
Variables ¶
View Source
var BytesRxRate = metrics.NewMeter()
View Source
var BytesTxRate = metrics.NewMeter()
View Source
var ConnectionTime = metrics.NewTimer()
View Source
var MagicHeader = []byte{0xCA, 0xFE, 0xF0, 0x0D}
View Source
var MsgLatency = metrics.NewTimer()
View Source
var MsgRxRate = metrics.NewMeter()
View Source
var MsgTxRate = metrics.NewMeter()
Functions ¶
func StartMetricsReporter ¶ added in v0.16.5
Types ¶
type RandHashedBlock ¶ added in v0.17.6
type RandHashedBlock struct { Type byte Sequence uint32 Hash []byte Data []byte Timestamp time.Time }
func (*RandHashedBlock) PrepForSend ¶ added in v0.17.6
func (block *RandHashedBlock) PrepForSend(p *protocol)
func (*RandHashedBlock) Rx ¶ added in v0.17.6
func (block *RandHashedBlock) Rx(p *protocol) error
func (*RandHashedBlock) Tx ¶ added in v0.17.6
func (block *RandHashedBlock) Tx(p *protocol) error
func (*RandHashedBlock) Verify ¶ added in v0.17.6
func (block *RandHashedBlock) Verify(p *protocol) error
type Scenario ¶
type Scenario struct { Workloads []*Workload `yaml:"workloads"` ConnectionDelay int32 `yaml:"connectionDelay"` Metrics *Metrics `yaml:"metrics"` }
func LoadScenario ¶
type SeqBlock ¶ added in v0.17.6
type SeqBlock []byte
func (SeqBlock) PrepForSend ¶ added in v0.17.6
func (s SeqBlock) PrepForSend(*protocol)
type Test ¶
type Test struct { TxRequests int32 `yaml:"txRequests"` TxPacing time.Duration `yaml:"txPacing"` TxMaxJitter time.Duration `yaml:"txMaxJitter"` TxPauseEvery time.Duration `yaml:"txPauseEvery"` TxPauseFor time.Duration `yaml:"txPauseFor"` RxTimeout int32 `yaml:"rxTimeout"` RxPacing time.Duration `yaml:"rxPacing"` RxMaxJitter time.Duration `yaml:"rxMaxJitter"` RxPauseEvery time.Duration `yaml:"rxPauseEvery"` RxPauseFor time.Duration `yaml:"rxPauseFor"` PayloadMinBytes int32 `yaml:"payloadMinBytes"` PayloadMaxBytes int32 `yaml:"payloadMaxBytes"` LatencyFrequency int32 `yaml:"latencyFrequency"` BlockType string `yaml:"blockType"` }
Source Files
¶
Click to show internal directories.
Click to hide internal directories.