runner

Documentation

Index

• type BucketWithObject
• type ExecutionContext
• type Operation
• type Runner
  • func NewRunner(execContext *ExecutionContext, opeRatio []float64, timeInMs int64, ...) *Runner
  • func NewRunnerFromLoadFile(loadFileName string, opeRatio []float64, timeInMs int64, profiler bool, ...) *Runner
  • func (r *Runner) Run(cancel chan struct{}) error
  • func (r *Runner) SaveContext(saveFileName string) error
• type Worker
  • func (w *Worker) Delete() error
  • func (w *Worker) Get() error
  • func (w *Worker) List() error
  • func (w *Worker) Put(multipartThresh int) error
  • func (w *Worker) ShowInfo()

Types

type BucketWithObject

type BucketWithObject struct {
	BucketName string             `json:"bucketName"`
	ObjectMeta *object.ObjectMeta `json:"objectMeta"`
}

type ExecutionContext

type ExecutionContext struct {
	Endpoint      string   `json:"endpoint"`
	BucketNames   []string `json:"bucketNames"`
	NumObj        int      `json:"numObj"`
	NumWorker     int      `json:"numWorker"`
	MinSize       int      `json:"minSize"`
	MaxSize       int      `json:"maxSize"`
	StartWorkerID int      `json:"startWorkerID"`
	Workers       []Worker `json:"workers"`
}

type Operation

type Operation int

const (
	Put Operation = iota
	Get
	Delete
	List
	NumOperation
)

type Runner

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

func NewRunner

func NewRunner(execContext *ExecutionContext, opeRatio []float64, timeInMs int64,
	profiler bool, loadFileName string, processID, multipartThresh int,
	caCertFileName string) *Runner

func NewRunnerFromLoadFile

func NewRunnerFromLoadFile(loadFileName string, opeRatio []float64, timeInMs int64,
	profiler bool, multipartThresh int, caCertFileName string) *Runner

func (*Runner) Run

func (r *Runner) Run(cancel chan struct{}) error

func (*Runner) SaveContext

func (r *Runner) SaveContext(saveFileName string) error

type Worker

type Worker struct {
	BucketsWithObject []*BucketWithObject `json:"bucketsWithObject"`
	// contains filtered or unexported fields
}

func (*Worker) Delete

func (w *Worker) Delete() error

func (*Worker) Get

func (w *Worker) Get() error

func (*Worker) List

func (w *Worker) List() error

func (*Worker) Put

func (w *Worker) Put(multipartThresh int) error

func (*Worker) ShowInfo

func (w *Worker) ShowInfo()