benchmark

Documentation

Index

• func AnalyzeBenchmarkRuns(label string, times []float64)
• func BulkStat(parallelism int, files []string) float64
• func CountCpus() int
• func ReadLines(name string) []string
• func RunBulkStat(runs int, threads int, sleepTime time.Duration, files []string) (results []float64)
• type LatencyMap
  • func NewLatencyMap() *LatencyMap
  • func (m *LatencyMap) Add(name string, dt time.Duration)
  • func (m *LatencyMap) Counts() map[string]int
  • func (m *LatencyMap) Get(name string) (count int, dt time.Duration)
• type StatFs
  • func NewStatFs() *StatFs
  • func (me *StatFs) Add(name string, a *fuse.Attr)
  • func (me *StatFs) AddFile(name string)
  • func (me *StatFs) GetAttr(name string, context *fuse.Context) (*fuse.Attr, fuse.Status)
  • func (me *StatFs) OpenDir(name string, context *fuse.Context) (stream []fuse.DirEntry, status fuse.Status)

Functions

func AnalyzeBenchmarkRuns

func AnalyzeBenchmarkRuns(label string, times []float64)

func BulkStat

func BulkStat(parallelism int, files []string) float64

Used for benchmarking. Returns milliseconds.

func CountCpus

func CountCpus() int

func ReadLines

func ReadLines(name string) []string

func RunBulkStat

func RunBulkStat(runs int, threads int, sleepTime time.Duration, files []string) (results []float64)

Types

type LatencyMap

type LatencyMap struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewLatencyMap

func NewLatencyMap() *LatencyMap

func (*LatencyMap) Add

func (m *LatencyMap) Add(name string, dt time.Duration)

func (*LatencyMap) Counts

func (m *LatencyMap) Counts() map[string]int

func (*LatencyMap) Get

func (m *LatencyMap) Get(name string) (count int, dt time.Duration)

type StatFs

type StatFs struct {
	pathfs.FileSystem
	// contains filtered or unexported fields
}

func NewStatFs

func NewStatFs() *StatFs

func (*StatFs) Add

func (me *StatFs) Add(name string, a *fuse.Attr)

func (*StatFs) AddFile

func (me *StatFs) AddFile(name string)

func (*StatFs) GetAttr

func (me *StatFs) GetAttr(name string, context *fuse.Context) (*fuse.Attr, fuse.Status)

func (*StatFs) OpenDir

func (me *StatFs) OpenDir(name string, context *fuse.Context) (stream []fuse.DirEntry, status fuse.Status)