operation

Documentation

Index

• func AsBatch(hostEvent *hostMetricsEvent) (*influxdb.BatchPoints, error)
• func Banner(msg string) model.OperatingStage
• func Closer(ch chan struct{}) model.OperatingStage
• func InfluxMetricsReporter() model.OperatingStage
• func Iperf(scenarioName string, endpoint EndpointSelectorF, ...) model.OperatingStage
• func IperfClient(hostSpec, address string, port int) model.OperatingStage
• func IperfUdp(scenarioName, endpoint, serverHosts, clientHosts, bandwidth string, ...) model.OperatingStage
• func Joiner(joiners []chan struct{}) model.OperatingStage
• func LoadInfluxConfig(src map[interface{}]interface{}) (*influxConfig, error)
• func NewInfluxDBMetricsHandler(cfg *influxConfig) (model.MetricsHandler, error)
• func Persist() model.OperatingStage
• func Retrieve(host, path, extension string) model.OperatingStage
• func Sar(scenario string, host *model.Host, intervalSeconds int, joiner chan struct{}) model.OperatingStage
• func SarCloser(host *model.Host) model.OperatingStage
• func StreamSarMetrics(host *model.Host, intervalSeconds, reportIntervalCount int, runPhase Phase, ...) model.OperatingStage
• func Tcpdump(scenarioName, host string, snaplen int, joiner chan struct{}) model.OperatingStage
• func TcpdumpCloser(host string) model.OperatingStage
• func Timer(duration time.Duration, closer chan struct{}) model.OperatingStage
• type EndpointSelectorF
• type Phase
  • func NewPhase() Phase

Functions

func AsBatch

func AsBatch(hostEvent *hostMetricsEvent) (*influxdb.BatchPoints, error)

func Banner

func Banner(msg string) model.OperatingStage

func Closer

func Closer(ch chan struct{}) model.OperatingStage

func InfluxMetricsReporter

func InfluxMetricsReporter() model.OperatingStage

func Iperf

func Iperf(scenarioName string, endpoint EndpointSelectorF, serverHosts, clientHosts string, seconds int) model.OperatingStage

func IperfClient

func IperfClient(hostSpec, address string, port int) model.OperatingStage

func IperfUdp

func IperfUdp(scenarioName, endpoint, serverHosts, clientHosts, bandwidth string, seconds int) model.OperatingStage

func Joiner

func Joiner(joiners []chan struct{}) model.OperatingStage

func LoadInfluxConfig

func LoadInfluxConfig(src map[interface{}]interface{}) (*influxConfig, error)

func NewInfluxDBMetricsHandler

func NewInfluxDBMetricsHandler(cfg *influxConfig) (model.MetricsHandler, error)

func Persist

func Persist() model.OperatingStage

func Retrieve

func Retrieve(host, path, extension string) model.OperatingStage

func Sar

func Sar(scenario string, host *model.Host, intervalSeconds int, joiner chan struct{}) model.OperatingStage

func SarCloser

func SarCloser(host *model.Host) model.OperatingStage

func StreamSarMetrics

func StreamSarMetrics(host *model.Host, intervalSeconds, reportIntervalCount int, runPhase Phase, cleanupPhase Phase) model.OperatingStage

func Tcpdump

func Tcpdump(scenarioName, host string, snaplen int, joiner chan struct{}) model.OperatingStage

func TcpdumpCloser

func TcpdumpCloser(host string) model.OperatingStage

func Timer

func Timer(duration time.Duration, closer chan struct{}) model.OperatingStage

Types

type EndpointSelectorF

type EndpointSelectorF func(m *model.Model) string

type Phase

type Phase interface {
	model.OperatingStage
	GetCloser() <-chan struct{}
	AddJoiner() chan struct{}
}

func NewPhase

func NewPhase() Phase