operation

Documentation

Index

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

Functions

func AsBatch

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

func AsBatch2

func AsBatch2(hostEvent *hostMetricsEvent2) ([]*write.Point, error)

func Banner

func Banner(msg string) model.Stage

func Closer

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

func Influx2MetricsReporter

func Influx2MetricsReporter() model.Stage

func InfluxMetricsReporter

func InfluxMetricsReporter() model.Stage

func Iperf

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

func IperfClient

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

func IperfUdp

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

func Joiner

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

func LoadInfluxConfig

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

func NewInflux2DBMetricsHandler

func NewInflux2DBMetricsHandler(cfg *influx2Config) (model.MetricsHandler, error)

func NewInfluxDBMetricsHandler

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

func Persist

func Persist() model.Stage

func Retrieve

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

func Sar

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

func SarCloser

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

func StreamSarMetrics

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

func Tcpdump

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

func TcpdumpCloser

func TcpdumpCloser(host string) model.Stage

func Timer

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

Types

type EndpointSelectorF

type EndpointSelectorF func(m *model.Model) string

type Phase

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

func NewPhase

func NewPhase() Phase