workloads

Documentation

Index

• Variables
• func ExtractWorkload(embedConfig embed.FS, configDir string, workload string, rootCfg ...string) error
• func IndexMetadata(indexer indexers.Indexer, metadata BenchmarkMetadata)
• type BenchmarkMetadata
• type Config
• type WorkloadHelper
  • func NewWorkloadHelper(config Config, embedConfig embed.FS, ...) WorkloadHelper
  • func (wh *WorkloadHelper) Run(workload string, metricsProfiles []string, alertsProfiles []string)

Variables

var ConfigSpec config.Spec

Functions

func ExtractWorkload

func ExtractWorkload(embedConfig embed.FS, configDir string, workload string, rootCfg ...string) error

ExtractWorkload extracts the given workload and metrics profile to the current directory

func IndexMetadata

func IndexMetadata(indexer indexers.Indexer, metadata BenchmarkMetadata)

IndexMetadata indexes metadata using given indexer.

Types

type BenchmarkMetadata

type BenchmarkMetadata struct {
	ocpmetadata.ClusterMetadata
	UUID            string                 `json:"uuid"`
	Benchmark       string                 `json:"benchmark"`
	Timestamp       time.Time              `json:"timestamp"`
	EndDate         time.Time              `json:"endDate"`
	Passed          bool                   `json:"passed"`
	ExecutionErrors string                 `json:"executionErrors"`
	UserMetadata    map[string]interface{} `json:"metadata,omitempty"`
}

type Config

type Config struct {
	UUID            string
	Timeout         time.Duration
	MetricsEndpoint string
	UserMetadata    string
	ConfigDir       string
	PrometheusURL   string
	PrometheusToken string
}

type WorkloadHelper

type WorkloadHelper struct {
	Config
	Metadata BenchmarkMetadata

	MetadataAgent   ocpmetadata.Metadata
	MetricsMetadata map[string]interface{}
	// contains filtered or unexported fields
}

func NewWorkloadHelper

func NewWorkloadHelper(config Config, embedConfig embed.FS, kubeClientProvider *config.KubeClientProvider) WorkloadHelper

NewWorkloadHelper initializes workloadHelper

func (*WorkloadHelper) Run

func (wh *WorkloadHelper) Run(workload string, metricsProfiles []string, alertsProfiles []string)