Versions in this module Expand all Collapse all v0 v0.1.1 Sep 9, 2020 Changes in this version + const Inf + var FormatString1 = "%s,%d\n" + var RedisAIPool = sync.Pool + func ConvertByteSliceToFloatSlice(transactionDataString []byte) []float32 + func ConvertSliceStringToFloat(transactionDataString []string) []float32 + func Float32bytes(float float32) []byte + func RandReferenceData(n int) []float32 + func Uint64frombytes(bytes []byte) uint64 + type BenchmarkRunner struct + func NewBenchmarkRunner() *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) IgnoreErrors() bool + func (b *BenchmarkRunner) Run(queryPool *sync.Pool, processorCreateFn ProcessorCreate, rowSizeBytes int) + func (b *BenchmarkRunner) SetLimit(limit uint64) + func (b *BenchmarkRunner) UseReferenceDataMysql() bool + func (b *BenchmarkRunner) UseReferenceDataRedis() bool + type LoadRunner struct + func NewLoadRunner() *LoadRunner + func (b *LoadRunner) GetBufferedReader() *bufio.Reader + func (b *LoadRunner) RunLoad(queryPool *sync.Pool, LoaderCreateFn LoaderCreate, rowBenchmarkNBytes int) + func (b *LoadRunner) SetLimit(limit uint64) + type Loader interface + Close func() + Init func(workerNum int, wg *sync.WaitGroup) + ProcessLoadQuery func(q []byte, debug int) ([]*Stat, uint64, error) + type LoaderCreate func() Loader + type Processor interface + Close func() + Init func(workerNum int, totalWorkers int, wg *sync.WaitGroup, m chan uint64, ...) + ProcessInferenceQuery func(q []byte, isWarm bool, workerNum int, useReferenceDataRedis bool, ...) ([]*Stat, error) + type ProcessorCreate func() Processor + type RedisAI struct + HumanDescription []byte + HumanLabel []byte + RedisQuery []byte + func (q *RedisAI) GetID() uint64 + func (q *RedisAI) HumanDescriptionName() []byte + func (q *RedisAI) HumanLabelName() []byte + func (q *RedisAI) Release() + func (q *RedisAI) SetID(n uint64) + func (q *RedisAI) String() string + type Stat struct + func GetStat() *Stat + func (s *Stat) Init(label []byte, value int64, totalResults uint64, timedOut bool, query string) *Stat
Go to main page