Documentation ¶
Index ¶
- Constants
- Variables
- type BenchmarkRunner
- func (b *BenchmarkRunner) DatabaseName() string
- func (b *BenchmarkRunner) DebugLevel() int
- func (b *BenchmarkRunner) DoPrintResponses() bool
- func (b *BenchmarkRunner) GetBufferedReader() *bufio.Reader
- func (b *BenchmarkRunner) Run(queryPool *sync.Pool, processorCreateFn ProcessorCreate)
- func (b *BenchmarkRunner) SetLimit(limit uint64)
- type BenchmarkRunnerConfig
- type Cassandra
- type ClickHouse
- type CrateDB
- type HTTP
- type LoaderTestResult
- type Mongo
- type Processor
- type ProcessorCreate
- type Query
- type SiriDB
- type Stat
- type TimescaleDB
- type Timestream
Constants ¶
const BenchmarkTestResultVersion = "0.1"
Variables ¶
var CassandraPool = sync.Pool{ New: func() interface{} { return &Cassandra{ HumanLabel: []byte{}, HumanDescription: []byte{}, MeasurementName: []byte{}, FieldName: []byte{}, AggregationType: []byte{}, ForEveryN: []byte{}, WhereClause: []byte{}, OrderBy: []byte{}, TagSets: [][]string{}, } }, }
CassandraPool is a sync.Pool of Cassandra Query types
var ClickHousePool = sync.Pool{ New: func() interface{} { return &ClickHouse{ HumanLabel: make([]byte, 0, 1024), HumanDescription: make([]byte, 0, 1024), Table: make([]byte, 0, 1024), SqlQuery: make([]byte, 0, 1024), } }, }
ClickHousePool is a sync.Pool of ClickHouse Query types
var CrateDBPool = sync.Pool{ New: func() interface{} { return &CrateDB{ HumanLabel: make([]byte, 0, 1024), HumanDescription: make([]byte, 0, 1024), Table: make([]byte, 0, 1024), SqlQuery: make([]byte, 0, 1024), } }, }
var HTTPPool = sync.Pool{ New: func() interface{} { return &HTTP{ HumanLabel: []byte{}, HumanDescription: []byte{}, Method: []byte{}, Path: []byte{}, Body: []byte{}, RawQuery: []byte{}, StartTimestamp: 0, EndTimestamp: 0, } }, }
HTTPPool is a sync.Pool of HTTP Query types
var MongoPool = sync.Pool{ New: func() interface{} { return &Mongo{ HumanLabel: []byte{}, HumanDescription: []byte{}, CollectionName: []byte{}, BsonDoc: []bson.M{}, } }, }
MongoPool is a sync.Pool of Mongo Query types
var SiriDBPool = sync.Pool{ New: func() interface{} { return &SiriDB{ HumanLabel: make([]byte, 0, 1024), HumanDescription: make([]byte, 0, 1024), SqlQuery: make([]byte, 0, 1024), } }, }
var TimescaleDBPool = sync.Pool{ New: func() interface{} { return &TimescaleDB{ HumanLabel: make([]byte, 0, 1024), HumanDescription: make([]byte, 0, 1024), Hypertable: make([]byte, 0, 1024), SqlQuery: make([]byte, 0, 1024), } }, }
TimescaleDBPool is a sync.Pool of TimescaleDB Query types
var TimestreamPool = sync.Pool{ New: func() interface{} { return &Timestream{ HumanLabel: make([]byte, 0, 1024), HumanDescription: make([]byte, 0, 1024), Table: make([]byte, 0, 50), SqlQuery: make([]byte, 0, 1024), } }, }
TimestreamPool is a sync.Pool of Timestream Query types
Functions ¶
This section is empty.
Types ¶
type BenchmarkRunner ¶
type BenchmarkRunner struct { BenchmarkRunnerConfig // contains filtered or unexported fields }
BenchmarkRunner contains the common components for running a query benchmarking program against a database.
func NewBenchmarkRunner ¶
func NewBenchmarkRunner(config BenchmarkRunnerConfig) *BenchmarkRunner
NewBenchmarkRunner creates a new instance of BenchmarkRunner which is common functionality to be used by query benchmarker programs
func (*BenchmarkRunner) DatabaseName ¶
func (b *BenchmarkRunner) DatabaseName() string
DatabaseName returns the name of the database to run queries against
func (*BenchmarkRunner) DebugLevel ¶
func (b *BenchmarkRunner) DebugLevel() int
DebugLevel returns the level of debug messages for this benchmark
func (*BenchmarkRunner) DoPrintResponses ¶
func (b *BenchmarkRunner) DoPrintResponses() bool
DoPrintResponses indicates whether responses for queries should be printed
func (*BenchmarkRunner) GetBufferedReader ¶
func (b *BenchmarkRunner) GetBufferedReader() *bufio.Reader
GetBufferedReader returns the buffered Reader that should be used by the loader
func (*BenchmarkRunner) Run ¶
func (b *BenchmarkRunner) Run(queryPool *sync.Pool, processorCreateFn ProcessorCreate)
Run does the bulk of the benchmark execution. It launches a gorountine to track stats, creates workers to process queries, read in the input, execute the queries, and then does cleanup.
func (*BenchmarkRunner) SetLimit ¶
func (b *BenchmarkRunner) SetLimit(limit uint64)
SetLimit changes the number of queries to run, with 0 being all of them
type BenchmarkRunnerConfig ¶
type BenchmarkRunnerConfig struct { DBName string `mapstructure:"db-name"` Limit uint64 `mapstructure:"max-queries"` LimitRPS uint64 `mapstructure:"max-rps"` MemProfile string `mapstructure:"memprofile"` HDRLatenciesFile string `mapstructure:"hdr-latencies"` Workers uint `mapstructure:"workers"` PrintResponses bool `mapstructure:"print-responses"` Debug int `mapstructure:"debug"` FileName string `mapstructure:"file"` BurnIn uint64 `mapstructure:"burn-in"` PrintInterval uint64 `mapstructure:"print-interval"` PrewarmQueries bool `mapstructure:"prewarm-queries"` ResultsFile string `mapstructure:"results-file"` }
BenchmarkRunnerConfig is the configuration of the benchmark runner.
func (BenchmarkRunnerConfig) AddToFlagSet ¶
func (c BenchmarkRunnerConfig) AddToFlagSet(fs *pflag.FlagSet)
AddToFlagSet adds command line flags needed by the BenchmarkRunnerConfig to the flag set.
type Cassandra ¶
type Cassandra struct { HumanLabel []byte HumanDescription []byte MeasurementName []byte // e.g. "cpu" FieldName []byte // e.g. "usage_user" AggregationType []byte // e.g. "avg" or "sum". used literally in the cassandra query. TimeStart time.Time TimeEnd time.Time GroupByDuration time.Duration ForEveryN []byte // e.g. "hostname,1" WhereClause []byte // e.g. "usage_user,>,90.0" OrderBy []byte // e.g. "timestamp_ns DESC" Limit int TagSets [][]string // semantically, each subgroup is OR'ed and they are all AND'ed together // contains filtered or unexported fields }
Cassandra encodes a Cassandra request. This will be serialized for use by the tsbs_run_queries_cassandra program.
func NewCassandra ¶
func NewCassandra() *Cassandra
NewCassandra returns a new Cassandra Query instance
func (*Cassandra) HumanDescriptionName ¶
HumanDescriptionName returns the human readable description of this Query
func (*Cassandra) HumanLabelName ¶
HumanLabelName returns the human readable name of this Query
type ClickHouse ¶
type ClickHouse struct { HumanLabel []byte HumanDescription []byte Table []byte // e.g. "cpu" SqlQuery []byte // contains filtered or unexported fields }
ClickHouse encodes a ClickHouse query. This will be serialized for use by the tsbs_run_queries_clickhouse program.
func NewClickHouse ¶
func NewClickHouse() *ClickHouse
NewClickHouse returns a new ClickHouse Query instance
func (*ClickHouse) HumanDescriptionName ¶
func (ch *ClickHouse) HumanDescriptionName() []byte
HumanDescriptionName returns the human readable description of this Query
func (*ClickHouse) HumanLabelName ¶
func (ch *ClickHouse) HumanLabelName() []byte
HumanLabelName returns the human readable name of this Query
func (*ClickHouse) Release ¶
func (ch *ClickHouse) Release()
Release resets and returns this Query to its pool
func (*ClickHouse) String ¶
func (ch *ClickHouse) String() string
String produces a debug-ready description of a Query.
type CrateDB ¶
type CrateDB struct { HumanLabel []byte HumanDescription []byte Table []byte // e.g. "cpu" SqlQuery []byte // contains filtered or unexported fields }
CrateDB encodes a CrateDB request. This will be serialized for use by the tsbs_run_queries_cratedb program.
func NewCrateDB ¶
func NewCrateDB() *CrateDB
func (*CrateDB) HumanDescriptionName ¶
func (*CrateDB) HumanLabelName ¶
type HTTP ¶
type HTTP struct { HumanLabel []byte HumanDescription []byte Method []byte Path []byte Body []byte RawQuery []byte StartTimestamp int64 EndTimestamp int64 // contains filtered or unexported fields }
HTTP encodes an HTTP request. This will typically by serialized for use by the appropriate tsbs_run_queries program.
func (*HTTP) HumanDescriptionName ¶
HumanDescriptionName returns the human readable description of this Query
func (*HTTP) HumanLabelName ¶
HumanLabelName returns the human readable name of this Query
type LoaderTestResult ¶
type LoaderTestResult struct { // Format Configs ResultFormatVersion string `json:"ResultFormatVersion"` // RunnerConfig Configs RunnerConfig BenchmarkRunnerConfig `json:"RunnerConfig"` // Run info StartTime int64 `json:"StartTime` EndTime int64 `json:"EndTime"` DurationMillis int64 `json:"DurationMillis"` // Totals Totals map[string]interface{} `json:"Totals"` }
LoaderTestResult aggregates the results of an query benchmark in a common format across targets
type Mongo ¶
type Mongo struct { HumanLabel []byte HumanDescription []byte CollectionName []byte BsonDoc []bson.M // contains filtered or unexported fields }
Mongo encodes a Mongo request. This will be serialized for use by the tsbs_run_queries_mongo program.
func (*Mongo) HumanDescriptionName ¶
HumanDescriptionName returns the human readable description of this Query
func (*Mongo) HumanLabelName ¶
HumanLabelName returns the human readable name of this Query
type Processor ¶
type Processor interface { // Init initializes at global state for the Processor, possibly based on its worker number / ID Init(workerNum int) // ProcessQuery handles a given query and reports its stats ProcessQuery(q Query, isWarm bool) ([]*Stat, error) }
Processor is an interface that handles the setup of a query processing worker and executes queries one at a time
type ProcessorCreate ¶
type ProcessorCreate func() Processor
ProcessorCreate is a function that creates a new Processor (called in Run)
type Query ¶
type Query interface { Release() HumanLabelName() []byte HumanDescriptionName() []byte GetID() uint64 SetID(uint64) fmt.Stringer }
Query is an interface used for encoding a benchmark query for different databases
type SiriDB ¶
type SiriDB struct { HumanLabel []byte HumanDescription []byte SqlQuery []byte // contains filtered or unexported fields }
func (*SiriDB) HumanDescriptionName ¶
HumanDescriptionName returns the human readable description of this Query
func (*SiriDB) HumanLabelName ¶
HumanLabelName returns the human readable name of this Query
type Stat ¶
type Stat struct {
// contains filtered or unexported fields
}
Stat represents one statistical measurement, typically used to store the latency of a query (or part of query).
func GetPartialStat ¶
func GetPartialStat() *Stat
GetPartialStat returns a partial Stat for use from a pool
type TimescaleDB ¶
type TimescaleDB struct { HumanLabel []byte HumanDescription []byte Hypertable []byte // e.g. "cpu" SqlQuery []byte // contains filtered or unexported fields }
TimescaleDB encodes a TimescaleDB request. This will be serialized for use by the tsbs_run_queries_timescaledb program.
func NewTimescaleDB ¶
func NewTimescaleDB() *TimescaleDB
NewTimescaleDB returns a new TimescaleDB Query instance
func (*TimescaleDB) HumanDescriptionName ¶
func (q *TimescaleDB) HumanDescriptionName() []byte
HumanDescriptionName returns the human readable description of this Query
func (*TimescaleDB) HumanLabelName ¶
func (q *TimescaleDB) HumanLabelName() []byte
HumanLabelName returns the human readable name of this Query
func (*TimescaleDB) Release ¶
func (q *TimescaleDB) Release()
Release resets and returns this Query to its pool
func (*TimescaleDB) String ¶
func (q *TimescaleDB) String() string
String produces a debug-ready description of a Query.
type Timestream ¶
type Timestream struct { HumanLabel []byte HumanDescription []byte Table []byte // e.g. "cpu" SqlQuery []byte // contains filtered or unexported fields }
Timestream encodes a Timestream request. This will be serialized for use by the tsbs_run_queries_timestream program.
func NewTimestream ¶
func NewTimestream() *Timestream
NewTimestream returns a new Timestream Query instance
func (*Timestream) HumanDescriptionName ¶
func (q *Timestream) HumanDescriptionName() []byte
HumanDescriptionName returns the human readable description of this Query
func (*Timestream) HumanLabelName ¶
func (q *Timestream) HumanLabelName() []byte
HumanLabelName returns the human readable name of this Query
func (*Timestream) Release ¶
func (q *Timestream) Release()
Release resets and returns this Query to its pool
func (*Timestream) String ¶
func (q *Timestream) String() string
String produces a debug-ready description of a Query.