parse

Documentation

Index

• Constants
• func ProcessInputs(inputStr map[string]string, inputNum map[string]int64, input map[string]string, ...) []byte
• func ProcessOnlineQueryContext(useNativeSql bool, staticUnderscoreExprs bool, queryName string, ...) *commonv1.OnlineQueryContext
• func ProcessOutputs(output []string) []*commonv1.OutputExpr
• func ReadJSONFile(filePath string) []byte
• func ReadParquetFile(featuresFile string, chunkSize int64) ([][]byte, error)
• type BufferWriteSeeker
  • func (b *BufferWriteSeeker) Bytes() []byte
  • func (b *BufferWriteSeeker) Seek(offset int64, whence int) (int64, error)
  • func (b *BufferWriteSeeker) Write(p []byte) (n int, err error)
• type ConstPacer
• type QueryRun
  • func ParseScheduleFile(scheduleFile string, rampDuration time.Duration) []QueryRun
  • func QueryRateOptions(rps uint, benchmarkDuration time.Duration, rampDuration time.Duration, ...) []QueryRun
• type RawPipelineStep
• type StepPacer

Constants

const DefaultLoadRampStart = 2

Functions

func ProcessInputs

func ProcessInputs(inputStr map[string]string, inputNum map[string]int64, input map[string]string, chunkSize int64) []byte

func ProcessOnlineQueryContext

func ProcessOnlineQueryContext(useNativeSql bool, staticUnderscoreExprs bool, queryName string, queryNameVersion string, tags []string) *commonv1.OnlineQueryContext

func ProcessOutputs

func ProcessOutputs(output []string) []*commonv1.OutputExpr

func ReadJSONFile

func ReadJSONFile(filePath string) []byte

func ReadParquetFile

func ReadParquetFile(featuresFile string, chunkSize int64) ([][]byte, error)

Types

type BufferWriteSeeker

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

func (*BufferWriteSeeker) Bytes

func (b *BufferWriteSeeker) Bytes() []byte

func (*BufferWriteSeeker) Seek

func (b *BufferWriteSeeker) Seek(offset int64, whence int) (int64, error)

func (*BufferWriteSeeker) Write

func (b *BufferWriteSeeker) Write(p []byte) (n int, err error)

type ConstPacer

type ConstPacer struct {
	RPS      uint64 `json:"rps"`
	Duration string `json:"duration"`
}

type QueryRun

type QueryRun struct {
	Options  []runner.Option
	Duration time.Duration
	Type     string
}

func ParseScheduleFile

func ParseScheduleFile(scheduleFile string, rampDuration time.Duration) []QueryRun

func QueryRateOptions

func QueryRateOptions(rps uint, benchmarkDuration time.Duration, rampDuration time.Duration, totalRequests uint, scheduleFile string) []QueryRun

type RawPipelineStep

type RawPipelineStep struct {
	Type   string           `json:"type"`
	Params *json.RawMessage `json:"params"`
}

type StepPacer

type StepPacer struct {
	StepSize     int64  `json:"step_size"`
	StepStart    uint64 `json:"step_start"`
	Duration     string `json:"duration"`
	StepDuration string `json:"step_duration"`
}