fsbench

Documentation

Index

• Constants
• Variables
• type AggregatedStatus
  • func NewAggregatedStatus() *AggregatedStatus
  • func (s *AggregatedStatus) Add(a Status)
  • func (s *AggregatedStatus) Sum(a *AggregatedStatus)
• type Benchmark
  • func NewBenchmark(fs fs.Client, c *Config) *Benchmark
  • func (b *Benchmark) Init()
  • func (b *Benchmark) Run() *BenchmarkStatus
  • func (b *Benchmark) Status() *BenchmarkStatus
• type BenchmarkStatus
  • func NewBenchmarkStatus() *BenchmarkStatus
• type Config
• type RandomReader
  • func NewRandomReader() *RandomReader
  • func (r *RandomReader) Read(b []byte) (int, error)
• type Status
  • func NewStatus(fs flowrate.Status) Status
• type Worker
  • func NewWorker(fs fs.Client, c *WorkerConfig) *Worker
  • func (w *Worker) Read() error
  • func (w *Worker) Write() error
• type WorkerConfig
• type WorkerMode

Constants

const (
	KB = 1024
	MB = 1024 * KB
	GB = 1024 * MB
)

const (
	DirectoryLength = 2
	FilenameLength  = 32
	FileExtension   = ".rand"
)

Variables

var (
	RandomSampleSize int64 = 10 * MB
)

Types

type AggregatedStatus

type AggregatedStatus struct {
	Status
	Files            int                  // Number of files transferred
	Errors           int                  // Number of errors
	HistogramAvgRate *histogram.Histogram `json:"-"`
}

func NewAggregatedStatus

func NewAggregatedStatus() *AggregatedStatus

func (*AggregatedStatus) Add

func (s *AggregatedStatus) Add(a Status)

func (*AggregatedStatus) Sum

func (s *AggregatedStatus) Sum(a *AggregatedStatus)

type Benchmark

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

func NewBenchmark

func NewBenchmark(fs fs.Client, c *Config) *Benchmark

func (*Benchmark) Init

func (b *Benchmark) Init()

func (*Benchmark) Run

func (b *Benchmark) Run() *BenchmarkStatus

func (*Benchmark) Status

func (b *Benchmark) Status() *BenchmarkStatus

type BenchmarkStatus

type BenchmarkStatus struct {
	RStatus *AggregatedStatus
	WStatus *AggregatedStatus
}

func NewBenchmarkStatus

func NewBenchmarkStatus() *BenchmarkStatus

type Config

type Config struct {
	Mode           WorkerMode
	Workers        int
	Files          int
	DirectoryDepth int
	BlockSize      int64
	FixedFileSize  int64
	MeanFileSize   int64
	StdDevFileSize float64
}

type RandomReader

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

func NewRandomReader

func NewRandomReader() *RandomReader

func (*RandomReader) Read

func (r *RandomReader) Read(b []byte) (int, error)

type Status

type Status struct {
	Duration time.Duration // Time period covered by the statistics
	Bytes    int64         // Total number of bytes transferred
	AvgRate  int64         // Average transfer rate (Bytes / Duration)
}

func NewStatus

func NewStatus(fs flowrate.Status) Status

type Worker

type Worker struct {
	WStatus *AggregatedStatus
	RStatus *AggregatedStatus
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(fs fs.Client, c *WorkerConfig) *Worker

func (*Worker) Read

func (w *Worker) Read() error

func (*Worker) Write

func (w *Worker) Write() error

type WorkerConfig

type WorkerConfig struct {
	Files          int
	DirectoryDepth int
	BlockSize      int64
	FixedFileSize  int64
	MeanFileSize   int64
	StdDevFileSize float64
}

type WorkerMode

type WorkerMode int

const (
	WriteMode WorkerMode = 1
	ReadMode  WorkerMode = 2
)