telematics

Documentation

Index

• func NewBenchmark(cfg engine.BenchmarkConfig) engine.IBenchmark
• type Benchmark
  • func (b *Benchmark) Close() error
  • func (b *Benchmark) CreatePluginConfig() interface{}
  • func (b *Benchmark) GetDefaultFlags() (*pflag.FlagSet, interface{})
  • func (b *Benchmark) GetStat() engine.Stat
  • func (b *Benchmark) IsNil() bool
  • func (b *Benchmark) Run(writerFinCh <-chan error, cfg engine.Config, meta *metadata.Metadata, ...) error
• type Config
• type QueryInfo
• type Stat
  • func (s *Stat) AddSubStat(ss engine.Stat)
  • func (s *Stat) GetCurrentProgress(_ ...interface{}) map[string]interface{}
  • func (s *Stat) GetFormattedSummary() string
  • func (s *Stat) GetName() string
  • func (s *Stat) GetProgress() string
  • func (s *Stat) GetProgressWithJSONStr() string
  • func (s *Stat) GetProgressWithListStr() string
  • func (s *Stat) GetSubStats() []engine.Stat
  • func (s *Stat) GetSummary() string
  • func (s *Stat) Reset()

Functions

func NewBenchmark

func NewBenchmark(cfg engine.BenchmarkConfig) engine.IBenchmark

Types

type Benchmark

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

func (*Benchmark) Close

func (b *Benchmark) Close() error

func (*Benchmark) CreatePluginConfig

func (b *Benchmark) CreatePluginConfig() interface{}

func (*Benchmark) GetDefaultFlags

func (b *Benchmark) GetDefaultFlags() (*pflag.FlagSet, interface{})

func (*Benchmark) GetStat

func (b *Benchmark) GetStat() engine.Stat

func (*Benchmark) IsNil

func (b *Benchmark) IsNil() bool

func (*Benchmark) Run

func (b *Benchmark) Run(writerFinCh <-chan error, cfg engine.Config, meta *metadata.Metadata, execFunc engine.ExecBenchFunc) error

type Config

type Config struct {
	Parallel           []int    `mapstructure:"benchmark-parallel"`
	RunQueryNames      []string `mapstructure:"benchmark-run-query-names"`
	CombinationQueries string   `mapstructure:"benchmark-combination-queries"`
	CustomQueries      []string `mapstructure:"benchmark-custom-queries"`
	RunTimes           int64    `mapstructure:"benchmark-run-times"`
	RunTimeInSecond    uint64   `mapstructure:"benchmark-runtime-in-second"`
	ProgressFormat     string   `mapstructure:"benchmark-progress-format"`

	// hidden
	TimestampStart     string `mapstructure:"benchmark-ts-start"`
	TimestampEnd       string `mapstructure:"benchmark-ts-end"`
	SimpleMetricsCount int64  `mapstructure:"benchmark-simple-metrics-count"`
	JSONMetricsCount   int64  `mapstructure:"benchmark-json-metrics-count"`

	NumOfParsedCombinationQueries int
}

type QueryInfo

type QueryInfo struct {
	QueryName   string `json:"query_name"`
	CustomQuery string `json:"custom_query"`
	Stats       string `json:"stats"`
}

type Stat

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

func (*Stat) AddSubStat

func (s *Stat) AddSubStat(ss engine.Stat)

func (*Stat) GetCurrentProgress

func (s *Stat) GetCurrentProgress(_ ...interface{}) map[string]interface{}

func (*Stat) GetFormattedSummary

func (s *Stat) GetFormattedSummary() string

func (*Stat) GetName

func (s *Stat) GetName() string

func (*Stat) GetProgress

func (s *Stat) GetProgress() string

func (*Stat) GetProgressWithJSONStr

func (s *Stat) GetProgressWithJSONStr() string

func (*Stat) GetProgressWithListStr

func (s *Stat) GetProgressWithListStr() string

func (*Stat) GetSubStats

func (s *Stat) GetSubStats() []engine.Stat

func (*Stat) GetSummary

func (s *Stat) GetSummary() string

func (*Stat) Reset

func (s *Stat) Reset()