Documentation
¶
Index ¶
- func BuildDocs(sr result.ScenarioResults, uuid string) ([]interface{}, error)
- func Connect(url, index string, skip bool) (*indexers.Indexer, error)
- func WriteCSVResult(r result.ScenarioResults) error
- func WriteJSONResult(r result.ScenarioResults) error
- func WritePromCSVResult(r result.ScenarioResults) error
- type Doc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildDocs ¶
func BuildDocs(sr result.ScenarioResults, uuid string) ([]interface{}, error)
BuildDocs returns the documents that need to be indexed or an error.
func WriteCSVResult ¶
func WriteCSVResult(r result.ScenarioResults) error
WriteCSVResult will write the throughput result to the local filesystem
func WriteJSONResult ¶ added in v0.1.3
func WriteJSONResult(r result.ScenarioResults) error
WriteJSONResult sends the results as JSON to stdout
func WritePromCSVResult ¶
func WritePromCSVResult(r result.ScenarioResults) error
WritePromCSVResult writes the prom data in CSV format
Types ¶
type Doc ¶
type Doc struct {
UUID string `json:"uuid"`
Timestamp time.Time `json:"timestamp"`
HostNetwork bool `json:"hostNetwork"`
Driver string `json:"driver"`
Parallelism int `json:"parallelism"`
Profile string `json:"profile"`
Duration int `json:"duration"`
Samples int `json:"samples"`
Messagesize int `json:"messageSize"`
Throughput float64 `json:"throughput"`
Latency float64 `json:"latency"`
TputMetric string `json:"tputMetric"`
LtcyMetric string `json:"ltcyMetric"`
Metadata result.Metadata `json:"metadata"`
ServerNodeCPU metrics.NodeCPU `json:"serverCPU"`
ServerPodCPU []metrics.PodCPU `json:"serverPods"`
ClientNodeCPU metrics.NodeCPU `json:"clientCPU"`
ClientPodCPU []metrics.PodCPU `json:"clientPods"`
}
Doc struct of the JSON document to be indexed
Source Files
Click to show internal directories.
Click to hide internal directories.