type AppConfig struct {Namestring `json:"name"`URLstring `json:"url"`}

type Config struct {// AgentID is the workspace agent ID to which to connect.AgentIDuuid.UUID `json:"agent_id"`// BytesPerTick is the number of bytes to send to the agent per tick.BytesPerTickint64 `json:"bytes_per_tick"`// Duration is the total duration for which to send traffic to the agent.Durationtime.Duration `json:"duration"`// TickInterval specifies the interval between ticks (that is, attempts to// send data to workspace agents).TickIntervaltime.Duration `json:"tick_interval"`ReadMetricsConnMetrics `json:"-"`WriteMetricsConnMetrics `json:"-"`SSHbool `json:"ssh"`// Echo controls whether the agent should echo the data it receives.// If false, the agent will discard the data. Note that setting this// to true will double the amount of data read from the agent for// PTYs (e.g. reconnecting pty or SSH connections that request PTY).Echobool `json:"echo"`AppAppConfig `json:"app"`WebClient *codersdk.Client}

func (Config)Validate¶

func (cConfig) Validate()error

type ConnMetrics interface {AddError(float64)ObserveLatency(float64)AddTotal(float64)}

type Metrics struct {BytesReadTotalprometheus.CounterVecBytesWrittenTotalprometheus.CounterVecReadErrorsTotalprometheus.CounterVecWriteErrorsTotalprometheus.CounterVecReadLatencySecondsprometheus.HistogramVecWriteLatencySecondsprometheus.HistogramVecLabelNames          []string}

funcNewMetrics¶

func NewMetrics(regprometheus.Registerer, labelNames ...string) *Metrics

func (*Metrics)ReadMetrics¶

func (m *Metrics) ReadMetrics(lvs ...string)ConnMetrics

func (*Metrics)WriteMetrics¶

func (m *Metrics) WriteMetrics(lvs ...string)ConnMetrics

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

funcNewRunner¶

func NewRunner(client *codersdk.Client, cfgConfig) *Runner

func NewRunner(client *codersdk.Client, cfg Config, metrics *Metrics) *Runner {

func (*Runner)Cleanup¶

func (*Runner) Cleanup(context.Context,string,io.Writer)error

Cleanup does nothing, successfully.

func (*Runner)Run¶

func (r *Runner) Run(ctxcontext.Context, _string, logsio.Writer) (errerror)