benchmark

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

type AppendReport struct {
	RequestsPerSecond float64 `json:"requestsPerSecond"`
	BytesPerSecond    float64 `json:"bytesPerSecond"`
	Duration          float64 `json:"duration"`
}

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

type EndToEndReport struct {
	Latency float64 `json:"latency"`
}

type JsonEncoder struct{}

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

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

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

type Option interface {
	// contains filtered or unexported methods
}

type Report struct {
	AppendReport    `json:"append"`
	SubscribeReport `json:"subscribe"`
	EndToEndReport  `json:"endToEnd"`
}

type ReportEncoder interface {
	Encode(trs TargetReports) ([]byte, error)
}

type StringEncoder struct{}

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

type SubscribeReport struct {
	LogsPerSecond  float64 `json:"logsPerSecond"`
	BytesPerSecond float64 `json:"bytesPerSecond"`
}

type Target struct {
	TopicID          types.TopicID     `json:"topicId"`
	LogStreamID      types.LogStreamID `json:"logStreamId"`
	MessageSize      uint
	BatchSize        uint
	AppendersCount   uint
	SubscribersCount uint
	PipelineSize     int
	SubscribeSize    int
}

type TargetReport struct {
	Target string `json:"target"`
	Recent Report `json:"recent"`
	Total  Report `json:"total"`
}

type TargetReports struct {
	Reports []TargetReport `json:"reports"`
}