tgdef

Documentation

Overview

Package tgdef contains common definitions and helpers for traffic generator.

Index

• Constants
• func GatherWorkers[W ealthread.ThreadWithRole](list []W) (workers []ealthread.ThreadWithRole)
• func LaunchWorkers[W ealthread.Thread](workers []W)
• func StopWorkers[W ealthread.Thread](workers []W) error
• type Consumer
• type Module
• type Producer

Constants

const (
	RoleConsumer = "CONSUMER"
	RoleProducer = "PRODUCER"
)

Role names.

Functions

func GatherWorkers

func GatherWorkers[W ealthread.ThreadWithRole](list []W) (workers []ealthread.ThreadWithRole)

GatherWorkers helps implementing Module.Workers.

func LaunchWorkers

func LaunchWorkers[W ealthread.Thread](workers []W)

LaunchWorkers helps implementing Module.Launch.

func StopWorkers

func StopWorkers[W ealthread.Thread](workers []W) error

StopWorkers helps implementing Module.Stop.

Types

type Consumer

type Consumer interface {
	Module
	ConnectRxQueues(demuxD, demuxN *iface.InputDemux)
}

Consumer represents a consumer module.

type Module

type Module interface {
	io.Closer

	Face() iface.Face

	Workers() (list []ealthread.ThreadWithRole)
	Launch()
	Stop() error
}

Module represents a traffic generator module.

type Producer

type Producer interface {
	Module
	ConnectRxQueues(demuxI *iface.InputDemux)
}

Producer represents a producer module.