benchworkload

type BandwidthConfig struct {
	Direction      string        `json:"direction"`
	Streams        int           `json:"streams_per_direction"`
	BytesPerSecond int64         `json:"bytes_per_second_per_direction"`
	Start          time.Time     `json:"start"`
	Duration       time.Duration `json:"duration"`
}

type BandwidthResult struct {
	Direction              string        `json:"direction"`
	StreamsPerDirection    int           `json:"streams_per_direction"`
	TargetBytesPerSecond   int64         `json:"target_bytes_per_second_per_direction"`
	TargetDuration         time.Duration `json:"target_duration"`
	StartedAt              time.Time     `json:"started_at"`
	Elapsed                time.Duration `json:"elapsed"`
	ExpectedUploadBytes    int64         `json:"expected_upload_bytes"`
	UploadBytes            int64         `json:"upload_bytes"`
	ExpectedDownloadBytes  int64         `json:"expected_download_bytes"`
	DownloadBytes          int64         `json:"download_bytes"`
	UploadBytesPerSecond   float64       `json:"upload_bytes_per_second"`
	DownloadBytesPerSecond float64       `json:"download_bytes_per_second"`
	Failures               int           `json:"failures"`
	FailureSamples         []string      `json:"failure_samples,omitempty"`
}

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

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

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

type Histogram struct {
	BoundsMilliseconds  []float64 `json:"bounds_milliseconds"`
	Counts              []uint64  `json:"counts"`
	Count               uint64    `json:"count"`
	SumMilliseconds     float64   `json:"sum_milliseconds"`
	MinimumMilliseconds float64   `json:"minimum_milliseconds"`
	MaximumMilliseconds float64   `json:"maximum_milliseconds"`
}

type Phase struct {
	Name        string           `json:"name"`
	Start       time.Time        `json:"start"`
	Duration    time.Duration    `json:"duration"`
	URLs        []string         `json:"urls"`
	Bandwidth   *BandwidthConfig `json:"bandwidth,omitempty"`
	Combined    bool             `json:"combined,omitempty"`
	Direct      bool             `json:"direct,omitempty"`
	HeldStreams int              `json:"held_streams,omitempty"`
	CloseHeld   bool             `json:"close_held,omitempty"`
	OpenHeld    bool             `json:"open_held,omitempty"`
	Done        bool             `json:"done,omitempty"`
}

type PublishedPublicURL struct {
	Index      int             `json:"index"`
	Ready      publisher.Event `json:"ready"`
	Activation time.Duration   `json:"activation"`
}

type PublisherConfig struct {
	Server, LoginToken, Domain, StateRoot, Target string
	HTTPClient                                    *http.Client
	RelayTLS                                      *tls.Config
	AllowedIPPrefixes                             []string
	// mixed forces alternating QUIC/TLS-TCP cohorts; auto uses production fallback.
	Transport    string
	Parallel     int
	RequestLimit int
	// StartParallel overrides Parallel for activation only; shutdown stays bounded separately.
	StartParallel             int
	ReadyTimeout, StopTimeout time.Duration
	DrainTime                 time.Duration
	OnFailure                 func()
	OnActivationFailure       func(index int)
	Observe                   func(int, publisher.Event) error
}

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

type RequestResult struct {
	URL          string        `json:"url,omitempty"`
	Scheduled    time.Time     `json:"scheduled"`
	Started      time.Time     `json:"started"`
	FirstByte    time.Time     `json:"first_body_byte,omitzero"`
	QueueDelay   time.Duration `json:"queue_delay"`
	DNS          time.Duration `json:"dns"`
	Connect      time.Duration `json:"connect"`
	TLS          time.Duration `json:"tls"`
	Duration     time.Duration `json:"duration"`
	Bytes        int64         `json:"bytes"`
	Error        string        `json:"error,omitempty"`
	Timeout      bool          `json:"timeout,omitempty"`
	QueueExpired bool          `json:"queue_expired,omitempty"`
}

type ShutdownResult struct {
	StartedAt                     time.Time     `json:"started_at"`
	Duration                      time.Duration `json:"duration"`
	Attempts, Successes, Failures int
	Timings                       []time.Duration `json:"timings"`
}

type Visitor struct {
	Roots        *x509.CertPool
	Address      string
	Resolver     *net.Resolver
	PayloadBytes int
}

type VisitorConfig struct {
	Rate, Workers, QueueSlots int
	Start                     time.Time
	Duration                  time.Duration
	// OnResult is serialized and is intended for scenario-specific observations.
	OnResult func(RequestResult)
}

type VisitorResult struct {
	StartedAt      time.Time       `json:"started_at"`
	OfferDuration  time.Duration   `json:"offer_duration"`
	DrainDuration  time.Duration   `json:"drain_duration"`
	Workers        int             `json:"workers"`
	QueueSlots     int             `json:"queue_slots"`
	Rate           int             `json:"rate"`
	Scheduled      int             `json:"scheduled"`
	Started        int             `json:"started"`
	Completed      int             `json:"completed"`
	Successes      int             `json:"successes"`
	Failures       int             `json:"failures"`
	Timeouts       int             `json:"timeouts"`
	Missed         int             `json:"missed"`
	QueueExpired   int             `json:"queue_expired"`
	Bytes          int64           `json:"bytes"`
	QueueDelay     Histogram       `json:"queue_delay"`
	DNS            Histogram       `json:"dns"`
	Connect        Histogram       `json:"connect"`
	TLS            Histogram       `json:"tls"`
	FirstByte      Histogram       `json:"first_body_byte"`
	Total          Histogram       `json:"total"`
	FailuresSample []RequestResult `json:"failure_samples,omitempty"`
}