benchmarkconn

type Benchmark interface {
	Writer(net.Conn, ...Counter) error
	Reader(net.Conn, ...Counter) error
	Result() map[string]any
}

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

type Counter interface {
	CountNow() // CountNow forcibly make the counter take a measurement immediately and save it to the result

	Start()
	Stop()
	Result() map[time.Time]any // Result values must be printable and/or JSON-serializable
}

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

type CounterReport interface {
	Add(time time.Time, value any)
	Result() map[time.Time]any
}

type IntervalBenchmark struct {
	MessageSize   int           `json:"message_size" yaml:"message_size"`     // MessageSize defines how many bytes to write for each send attempt
	TotalMessages uint64        `json:"total_messages" yaml:"total_messages"` // TotalMessages defines how many messages to send in total
	Interval      time.Duration `json:"interval" yaml:"interval"`             // Interval defines how long to wait between each send attempt. If this value is too low, it is possible that the actual interval will be much higher due to system limitations
	Echo          bool          `json:"echo" yaml:"echo"`                     // Echo defines whether the receiver should echo back the received message
	// contains filtered or unexported fields
}

type PressuredBenchmark struct {
	MessageSize   int    `json:"message_size" yaml:"message_size"`     // MessageSize defines how many bytes to write for each send attempt
	TotalMessages uint64 `json:"total_messages" yaml:"total_messages"` // TotalMessages defines how many messages to send in total
	// contains filtered or unexported fields
}