archive

Documentation

Index

• func Connect(url string, skip bool) (*opensearch.Client, error)
• func IndexDocs(client *opensearch.Client, docs []Doc) error
• func WriteCSVResult(r result.ScenarioResults) error
• func WriteJSONResult(r result.ScenarioResults) error
• func WritePromCSVResult(r result.ScenarioResults) error
• type Doc
  • func BuildDocs(sr result.ScenarioResults, uuid string) ([]Doc, error)

Functions

func Connect

func Connect(url string, skip bool) (*opensearch.Client, error)

Connect returns a client connected to the desired cluster.

func IndexDocs

func IndexDocs(client *opensearch.Client, docs []Doc) error

IndexDocs indexes results from k8s-netperf returns failures if any happen.

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

func BuildDocs

func BuildDocs(sr result.ScenarioResults, uuid string) ([]Doc, error)

BuildDocs returns the documents that need to be indexed or an error.