client

Oct 7, 2024

Changes in this version

type Emitter

+ OnStreamComplete func(streamID int, server string)

+ OnSummary func(results map[spec.SubtestKind]Result)

type HumanReadable

+ func (HumanReadable) OnStreamComplete(streamID int, server string)

+ func (HumanReadable) OnSummary(results map[spec.SubtestKind]Result)

type Result

+ ByteLimit int

+ CongestionControl string

+ Length time.Duration

+ RTT uint32

+ Streams int

+ Subtest spec.SubtestKind

type Throughput1Client

+ func (c *Throughput1Client) PrintSummary()

Jan 3, 2024

Changes in this version

+ const DefaultLength

+ const DefaultScheme

+ const DefaultStreams

+ const DefaultWebSocketHandshakeTimeout

+ var ErrNoTargets = errors.New("no targets available")

+ type Config struct

+ ByteLimit int

+ CongestionControl string

+ Delay time.Duration

+ Emitter Emitter

+ Length time.Duration

+ MeasurementID string

+ NoVerify bool

+ NumStreams int

+ Scheme string

+ Server string

+ type Emitter interface

+ OnComplete func(streamID int, server string)

+ OnConnect func(server string)

+ OnDebug func(msg string)

+ OnError func(err error)

+ OnMeasurement func(id int, m model.WireMeasurement)

+ OnResult func(Result)

+ OnStart func(server string, kind spec.SubtestKind)

+ type HumanReadable struct

+ Debug bool

+ func (HumanReadable) OnComplete(streamID int, server string)

+ func (HumanReadable) OnConnect(server string)

+ func (HumanReadable) OnError(err error)

+ func (HumanReadable) OnMeasurement(id int, m model.WireMeasurement)

+ func (HumanReadable) OnResult(r Result)

+ func (HumanReadable) OnStart(server string, kind spec.SubtestKind)

+ func (e HumanReadable) OnDebug(msg string)

+ type Locator interface

+ Nearest func(ctx context.Context, service string) ([]v2.Target, error)

+ type Result struct

+ Elapsed time.Duration

+ Goodput float64

+ MinRTT uint32

+ Throughput float64

+ type Throughput1Client struct

+ ClientName string

+ ClientVersion string

+ func New(clientName, clientVersion string, config Config) *Throughput1Client

+ func (c *Throughput1Client) Download(ctx context.Context)

+ func (c *Throughput1Client) Upload(ctx context.Context)