archive

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

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 Connect

func Connect(url, index string, skip bool) (*indexers.Indexer, error)

Connect returns a client connected to the desired cluster.

func WriteCSVResult

func WriteCSVResult(r result.ScenarioResults) error

WriteCSVResult will write the throughput result to the local filesystem

func WriteJSONResult

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