aggregate

type Aggregated struct {
	// MixedServerStats and MixedThroughputByHost is populated only when data is mixed.
	MixedServerStats      *Throughput           `json:"mixed_server_stats,omitempty"`
	MixedThroughputByHost map[string]Throughput `json:"mixed_throughput_by_host,omitempty"`
	Type                  string                `json:"type"`
	Operations            []Operation           `json:"operations,omitempty"`
	Mixed                 bool                  `json:"mixed"`
}

type LiveAggregate struct {
	Title string
	// Total requests
	TotalRequests int `json:"total_requests"`
	// Total objects
	TotalObjects int `json:"total_objects"`
	// Total errors
	TotalErrors int `json:"total_errors"`
	// Total bytes
	TotalBytes int64 `json:"total_bytes"`
	// Concurrency is the number of threads seen.
	Concurrency int `json:"concurrency"`

	// Unfiltered start time of this operation segment.
	StartTime time.Time `json:"start_time"`
	// Unfiltered end time of this operation segment.
	EndTime time.Time `json:"end_time"`

	// Subset of errors.
	FirstErrors []string `json:"first_errors"`
	// Numbers of hosts
	Hosts MapAsSlice `json:"hosts"`
	// Number of warp clients.
	Clients MapAsSlice `json:"clients"`

	// Throughput information.
	Throughput Throughput `json:"throughput"`

	// ThroughputByHost information. Without segments.
	ThroughputByHost map[string]Throughput `json:"throughput_by_host"`

	// ThroughputByClient information. Without segments.
	ThroughputByClient map[string]Throughput `json:"throughput_by_client"`

	// Requests segmented.
	// Indexed by client.
	Requests map[string]RequestSegments `json:"requests_by_client"`
	// contains filtered or unexported fields
}

type MapAsSlice map[string]struct{}

type MultiSizedRequests struct {
	// ByHost contains request information by host.
	// This data is not segmented.
	ByHost map[string]RequestSizeRange `json:"by_host,omitempty"`

	// BySize contains request times separated by sizes
	BySize RequestSizeRanges `json:"by_size"`

	// Total number of requests.
	Requests int `json:"requests"`

	// Average object size
	AvgObjSize int64 `json:"avg_obj_size"`

	// Skipped if too little data.
	Skipped bool `json:"skipped,omitempty"`

	// MergedEntries is a counter for the number of merged entries contained in this result.
	MergedEntries int `json:"merged_entries"`
}

type Operation struct {
	// Throughput information.
	Throughput Throughput `json:"throughput"`
	// Unfiltered start time of this operation segment.
	StartTime time.Time `json:"start_time"`
	// Unfiltered end time of this operation segment.
	EndTime time.Time `json:"end_time"`
	// Throughput by host.
	ThroughputByHost map[string]Throughput `json:"throughput_by_host"`
	// Populated if requests are of difference object sizes.
	MultiSizedRequests *MultiSizedRequests `json:"multi_sized_requests,omitempty"`
	// Populated if requests are all of same object size.
	SingleSizedRequests *SingleSizedRequests `json:"single_sized_requests,omitempty"`
	// Operation type
	Type string `json:"type"`
	// HostNames are sorted names of hosts
	HostNames []string `json:"host_names"`
	// Subset of errors.
	FirstErrors []string `json:"first_errors"`
	// Numbers of hosts
	Hosts int `json:"hosts"`
	// Number of warp clients.
	Clients int `json:"clients"`
	// Concurrency - total number of threads running.
	Concurrency int `json:"concurrency"`
	// Total errors recorded.
	Errors int `json:"errors"`
	// Objects per operation.
	ObjectsPerOperation int `json:"objects_per_operation"`
	// N is the number of operations.
	N int `json:"n"`
	// Skipped if too little data
	Skipped bool `json:"skipped"`
}

type Options struct {
	DurFunc     SegmentDurFn
	SkipDur     time.Duration
	Prefiltered bool
}

type Realtime struct {
	DataVersion int    `json:"v"`
	Commandline string `json:"commandline"`
	Final       bool   `json:"final"`
	WarpVersion string `json:"warp_version,omitempty"`
	WarpCommit  string `json:"warp_commit,omitempty"`
	WarpDate    string `json:"warp_date,omitempty"`

	Total    LiveAggregate             `json:"total"`
	ByOpType map[string]*LiveAggregate `json:"by_op_type,omitempty"`
	// These are really not used.
	ByHost        map[string]*LiveAggregate         `json:"by_host,omitempty"`
	ByObjLog2Size map[int]*LiveAggregate            `json:"by_obj_log_2_size,omitempty"`
	ByClient      map[string]*LiveAggregate         `json:"by_client,omitempty"`
	ByCategory    map[bench.Category]*LiveAggregate `json:"by_category,omitempty"`
}

type ReportOptions struct {
	Details  bool
	Color    bool
	SkipReqs bool
	OnlyOps  map[string]struct{}
}

type RequestSegment struct {
	StartTime time.Time `json:"start_time"`
	EndTime   time.Time `json:"end_time"`

	// Populated if requests are of difference object sizes.
	Multi *MultiSizedRequests `json:"multi_sized_requests,omitempty"`

	// Populated if requests are all of same object size.
	Single *SingleSizedRequests `json:"single_sized_requests,omitempty"`
}

type RequestSegments []RequestSegment

type RequestSizeRange struct {
	// Time to first byte if applicable.
	FirstByte *TTFB `json:"first_byte,omitempty"`

	// FirstAccess is filled if the same object is accessed multiple times.
	// This records the first touch of the object.
	FirstAccess *RequestSizeRange `json:"first_access,omitempty"`

	MinSizeString string `json:"min_size_string"`
	MaxSizeString string `json:"max_size_string"`

	// BpsPct is BPS percentiles.
	BpsPct *[101]float64 `json:"bps_percentiles,omitempty"`

	BpsMedian         float64 `json:"bps_median"`
	AvgDurationMillis float64 `json:"avg_duration_millis"`

	// Stats:
	BpsAverage float64 `json:"bps_average"`
	// Number of requests in this range.
	Requests   int     `json:"requests"`
	Bps90      float64 `json:"bps_90"`
	Bps99      float64 `json:"bps_99"`
	BpsFastest float64 `json:"bps_fastest"`
	BpsSlowest float64 `json:"bps_slowest"`

	// Average payload size of requests in bytes.
	AvgObjSize int `json:"avg_obj_size"`
	// Maximum size in request size range (not included).
	MaxSize int `json:"max_size"`
	// Minimum size in request size range.
	MinSize int `json:"min_size"`

	// MergedEntries is a counter for the number of merged entries contained in this result.
	MergedEntries int `json:"merged_entries"`
}

type RequestSizeRanges []RequestSizeRange

type SegmentDurFn func(total time.Duration) time.Duration

type SegmentSmall struct {
	// Start time of the segment.
	Start time.Time `json:"start"`
	// Bytes per second during the time segment.
	BPS float64 `json:"bytes_per_sec"`

	// Objects per second during the time segment.
	OPS float64 `json:"obj_per_sec"`

	// Errors logged during the time segment.
	Errors int `json:"errors,omitempty"`
}

type SegmentsSmall []SegmentSmall

type SingleSizedRequests struct {
	// Request times by host.
	ByHost map[string]SingleSizedRequests `json:"by_host,omitempty"`

	// FirstAccess is filled if the same object is accessed multiple times.
	// This records the first access of the object.
	FirstAccess *SingleSizedRequests `json:"first_access,omitempty"`

	// FirstAccess is filled if the same object is accessed multiple times.
	// This records the last access of the object.
	LastAccess *SingleSizedRequests `json:"last_access,omitempty"`

	// Time to first byte if applicable.
	FirstByte *TTFB `json:"first_byte,omitempty"`

	// Host names, sorted.
	HostNames MapAsSlice `json:"host_names,omitempty"`

	// DurPct is duration percentiles (milliseconds).
	DurPct *[101]float64 `json:"dur_percentiles_millis,omitempty"`

	// Median request duration.
	DurMedianMillis float64 `json:"dur_median_millis"`

	// Fastest request time.
	FastestMillis float64 `json:"fastest_millis"`

	// Slowest request time.
	SlowestMillis float64 `json:"slowest_millis"`

	// StdDev is the standard deviation of requests.
	StdDev float64 `json:"std_dev_millis"`

	// 99% request time.
	Dur99Millis float64 `json:"dur_99_millis"`

	// 90% request time.
	Dur90Millis float64 `json:"dur_90_millis"`

	// Average request duration.
	DurAvgMillis float64 `json:"dur_avg_millis"`

	// Total number of requests.
	Requests int `json:"requests"`

	// Object size per operation. Can be 0.
	ObjSize int64 `json:"obj_size"`

	// Skipped if too little data.
	Skipped bool `json:"skipped,omitempty"`

	// MergedEntries is a counter for the number of merged entries contained in this result.
	MergedEntries int `json:"merged_entries"`
}

type TTFB struct {
	AverageMillis     float64       `json:"average_millis"`
	FastestMillis     float64       `json:"fastest_millis"`
	P25Millis         float64       `json:"p25_millis"`
	MedianMillis      float64       `json:"median_millis"`
	P75Millis         float64       `json:"p75_millis"`
	P90Millis         float64       `json:"p90_millis"`
	P99Millis         float64       `json:"p99_millis"`
	SlowestMillis     float64       `json:"slowest_millis"`
	StdDevMillis      float64       `json:"std_dev_millis"`
	PercentilesMillis *[101]float64 `json:"percentiles_millis,omitempty"`
}

type Throughput struct {
	// Start time of the measurement.
	StartTime time.Time `json:"start_time"`
	// End time of the measurement.
	EndTime time.Time `json:"end_time"`
	// Time segmented throughput summary.
	Segmented *ThroughputSegmented `json:"segmented,omitempty"`
	// Errors recorded.
	Errors int `json:"errors"`
	// Time period of the throughput measurement.
	MeasureDurationMillis int `json:"measure_duration_millis"`
	// Total bytes.
	Bytes float64 `json:"bytes"`
	// Total objects
	Objects float64 `json:"objects"`
	// Number of full operations
	Operations int `json:"ops"`
}

type ThroughputSegmented struct {
	// Start time of fastest time segment.
	FastestStart time.Time `json:"fastest_start"`
	// 50% Median....
	MedianStart time.Time `json:"median_start"`
	// Slowest ...
	SlowestStart time.Time `json:"slowest_start"`
	// Will contain how segments are sorted.
	// Will be 'bps' (bytes per second) or 'ops' (objects per second).
	SortedBy string `json:"sorted_by"`

	// All segments, sorted
	Segments SegmentsSmall `json:"segments"`

	// Time of each segment.
	SegmentDurationMillis int `json:"segment_duration_millis"`

	// Fastest segment bytes per second. Can be 0. In that case segments are sorted by objects per second.
	FastestBPS float64 `json:"fastest_bps"`
	// Fastest segment in terms of objects per second.
	FastestOPS float64 `json:"fastest_ops"`
	MedianBPS  float64 `json:"median_bps"`
	MedianOPS  float64 `json:"median_ops"`
	SlowestBPS float64 `json:"slowest_bps"`
	SlowestOPS float64 `json:"slowest_ops"`
}

type UpdateReq struct {
	C     chan<- *Realtime `json:"-"`
	Reset bool             `json:"reset"` // Does not return result.
	Final bool             `json:"final"` // Blocks until final value is ready.
}