bench

Documentation

Index

• func PrintTrace(w io.Writer, trace []TraceStep) (n int, err error)
• func ReadReq(ctx context.Context, args *issueArgs, rng *rand.Rand, wg *sync.WaitGroup, ...)
• func WriteReq(ctx context.Context, args *issueArgs, rng *rand.Rand, wg *sync.WaitGroup, ...)
• type Config
• type Loader
  • func (l *Loader) Run(ctx context.Context) error
• type Logger
• type Runner
  • func (r *Runner) Run(parentCtx context.Context) error
• type TraceStep
  • func ParseTrace(r io.Reader) ([]TraceStep, error)
  • func (t *TraceStep) String() string
• type WorkloadReqFunc

Functions

func PrintTrace

func PrintTrace(w io.Writer, trace []TraceStep) (n int, err error)

func ReadReq

func ReadReq(ctx context.Context, args *issueArgs, rng *rand.Rand, wg *sync.WaitGroup, start time.Time)

func WriteReq

func WriteReq(ctx context.Context, args *issueArgs, rng *rand.Rand, wg *sync.WaitGroup, start time.Time)

Types

type Config

type Config struct {
	RecordCount int64 `json:"recordCount"`
	KeySize     int   `json:"keySize"`
	ValSize     int   `json:"valSize"`
	// contains filtered or unexported fields
}

type Loader

type Loader struct {
	Log             Logger
	DB              db.DB
	Config          Config
	Rand            *rand.Rand
	NumWorkers      int
	AllowedFailFrac float64

	LoadStart int64
	LoadCount int64
	// contains filtered or unexported fields
}

func (*Loader) Run

func (l *Loader) Run(ctx context.Context) error

type Logger

type Logger interface {
	Print(v ...interface{})
	Printf(format string, v ...interface{})
}

type Runner

type Runner struct {
	Log    Logger
	DB     db.DB
	Config Config
	Rand   *rand.Rand
	Trace  []TraceStep

	ReadRecorder  *recorders.MultiLatency
	ReadWriter    recorders.MultiLogWriter
	WriteRecorder *recorders.MultiLatency
	WriteWriter   recorders.MultiLogWriter
	// contains filtered or unexported fields
}

func (*Runner) Run

func (r *Runner) Run(parentCtx context.Context) error

type TraceStep

type TraceStep struct {
	Duration     time.Duration
	ReadKeyDist  keyDist
	WriteKeyDist keyDist
	ArrivalDist  arrivalDist
	RWRatio      float32
	AvgQPS       uint32
}

func ParseTrace

func ParseTrace(r io.Reader) ([]TraceStep, error)

func (*TraceStep) String

func (t *TraceStep) String() string

type WorkloadReqFunc

type WorkloadReqFunc func(ctx context.Context, args *issueArgs, rng *rand.Rand, wg *sync.WaitGroup, start time.Time)

A WorkloadReqFunc executes one request in a workload. If wg is not nil, Done() will be called once on wg once the function is complete.