loop3

Documentation

Index

• Constants
• Variables
• func StartMetricsReporter(configFile string, metrics *Metrics, closer chan struct{}) error
• type Block
  • func (block *Block) Rx(p *protocol) error
  • func (block *Block) Tx(p *protocol) error
• type Message
• type Metrics
• type Result
  • func (r *Result) Rx(p *protocol) error
  • func (r *Result) Tx(p *protocol) error
• type Scenario
  • func LoadScenario(path string) (*Scenario, error)
  • func (scenario *Scenario) String() string
• type Test
• type Workload

Constants

const (
	BlockTypePlain           byte = 1
	BlockTypeLatencyRequest       = 2
	BlockTypeLatencyResponse      = 3
)

Variables

var BytesRxRate = metrics.NewMeter()

var BytesTxRate = metrics.NewMeter()

var ConnectionTime = metrics.NewTimer()

var MagicHeader = []byte{0xCA, 0xFE, 0xF0, 0x0D}

var MsgLatency = metrics.NewTimer()

var MsgRxRate = metrics.NewMeter()

var MsgTxRate = metrics.NewMeter()

Functions

func StartMetricsReporter

func StartMetricsReporter(configFile string, metrics *Metrics, closer chan struct{}) error

Types

type Block

type Block struct {
	Type      byte
	Sequence  uint32
	Hash      []byte
	Data      []byte
	Timestamp time.Time
}

func (*Block) Rx

func (block *Block) Rx(p *protocol) error

func (*Block) Tx

func (block *Block) Tx(p *protocol) error

type Message

type Message interface {
	Tx(p *protocol) error
	Rx(p *protocol) error
}

type Metrics

type Metrics struct {
	Service        string        `yaml:"service"`
	ReportInterval time.Duration `yaml:"interval"`
	ClientId       string        `yaml:"clientId"`
}

type Result

type Result struct {
	Success bool
	Message string
}

func (*Result) Rx

func (r *Result) Rx(p *protocol) error

func (*Result) Tx

func (r *Result) Tx(p *protocol) error

type Scenario

type Scenario struct {
	Workloads       []*Workload `yaml:"workloads"`
	ConnectionDelay int32       `yaml:"connectionDelay"`
	Metrics         *Metrics    `yaml:"metrics"`
}

func LoadScenario

func LoadScenario(path string) (*Scenario, error)

func (*Scenario) String

func (scenario *Scenario) String() string

type Test

type Test struct {
	TxRequests       int32 `yaml:"txRequests"`
	TxPacing         int32 `yaml:"txPacing"`
	TxMaxJitter      int32 `yaml:"txMaxJitter"`
	RxTimeout        int32 `yaml:"rxTimeout"`
	PayloadMinBytes  int32 `yaml:"payloadMinBytes"`
	PayloadMaxBytes  int32 `yaml:"payloadMaxBytes"`
	LatencyFrequency int32 `yaml:"latencyFrequency"`
}

type Workload

type Workload struct {
	Name        string `yaml:"name"`
	Concurrency int32  `yaml:"concurrency"`
	Dialer      Test   `yaml:"dialer"`
	Listener    Test   `yaml:"listener"`
}