acceptance

Documentation

Overview

Package acceptance provides infrascturctures for acceptance testing networks implementations.

Index

• type Agent
  • func NewAgent(engine akita.Engine, freq akita.Freq, name string, numPorts int, test *Test) *Agent
  • func (a *Agent) Tick(now akita.VTimeInSec) bool
• type Test
  • func NewTest() *Test
  • func (t *Test) GenerateMsgs(n uint64)
  • func (t *Test) MustHaveReceivedAllMsgs()
  • func (t *Test) RegisterAgent(agent *Agent)
  • func (t *Test) ReportBandwidthAchieved(now akita.VTimeInSec)

Types

type Agent

type Agent struct {
	*akita.TickingComponent

	Ports      []akita.Port
	MsgsToSend []akita.Msg
	// contains filtered or unexported fields
}

Agent can send and receive request.

func NewAgent

func NewAgent(
	engine akita.Engine,
	freq akita.Freq,
	name string,
	numPorts int,
	test *Test,
) *Agent

NewAgent creates a new agent.

func (*Agent) Tick

func (a *Agent) Tick(now akita.VTimeInSec) bool

Tick tries to receive requests and send requests out.

type Test

type Test struct {
	// contains filtered or unexported fields
}

Test is a test case.

func NewTest

func NewTest() *Test

NewTest creates a new test.

func (*Test) GenerateMsgs

func (t *Test) GenerateMsgs(n uint64)

GenerateMsgs generates n message from a random source port to a random destination port.

func (*Test) MustHaveReceivedAllMsgs

func (t *Test) MustHaveReceivedAllMsgs()

MustHaveReceivedAllMsgs asserts that all the messages sent are received.

func (*Test) RegisterAgent

func (t *Test) RegisterAgent(agent *Agent)

RegisterAgent adds an agent to the Test

func (*Test) ReportBandwidthAchieved

func (t *Test) ReportBandwidthAchieved(now akita.VTimeInSec)

ReportBandwidthAchieved dumps the bandwidth observed by each agents.