bench

Mar 13, 2024

Changes in this version

type Common

+ RpsLimiter *rate.Limiter

type Delete

+ ListExisting bool

+ ListFlat bool

+ ListPrefix string

Jul 14, 2023

Changes in this version

type Operations

+ func (o Operations) NErrors() int

+ func (o Operations) SortByOpType()

+ func (o Operations) SortSplitByOpType() map[string]Operations

Jun 15, 2023

Changes in this version

+ type Fanout struct

+ Copies int

+ func (u *Fanout) Cleanup(ctx context.Context)

+ func (u *Fanout) Prepare(ctx context.Context) error

+ func (u *Fanout) Start(ctx context.Context, wait chan struct{}) (Operations, error)

Jun 8, 2023

Changes in this version

type Common

+ ExtraOut []chan<- Operation

Jun 6, 2023

Changes in this version

type Collector

+ func NewNullCollector() *Collector

type Common

+ Collector *Collector

+ DiscardOutput bool

May 17, 2023

Changes in this version

type Operations

+ func (o Operations) SortByEndpoint()

+ func (o Operations) SortSplitByEndpoint() map[string]Operations

Apr 12, 2023

Changes in this version

+ type Snowball struct

+ Collector *Collector

+ Compress bool

+ Duplicate bool

+ NumObjs int

+ WindowSize int

+ func (s *Snowball) Cleanup(ctx context.Context)

+ func (s *Snowball) Prepare(ctx context.Context) error

+ func (s *Snowball) Start(ctx context.Context, wait chan struct{}) (Operations, error)

Mar 21, 2023

Changes in this version

type CmpRequests

+ StdDev time.Duration

type Get

+ ListExisting bool

+ ListFlat bool

+ ListPrefix string

type Operations

+ func (o Operations) StdDev() time.Duration

type TTFB

+ StdDev time.Duration

Jan 13, 2023

Changes in this version

type Segment

+ ReqAvg float64

Dec 2, 2022

Changes in this version

+ type S3Zip struct

+ Collector *Collector

+ CreateFiles int

+ ZipObjName string

+ func (g *S3Zip) Cleanup(ctx context.Context)

+ func (g *S3Zip) Prepare(ctx context.Context) error

+ func (g *S3Zip) Start(ctx context.Context, wait chan struct{}) (Operations, error)

Jul 15, 2022

Changes in this version

type Common

+ ClientIdx int

+ Custom map[string]string

+ ExtraFlags map[string]string

+ type Multipart struct

+ Collector *Collector

+ CreateParts int

+ GetOpts minio.GetObjectOptions

+ ObjName string

+ PartStart int

+ UploadID string

+ func (g *Multipart) AfterPrepare(ctx context.Context) error

+ func (g *Multipart) Cleanup(ctx context.Context)

+ func (g *Multipart) InitOnce(ctx context.Context) error

+ func (g *Multipart) Prepare(ctx context.Context) error

+ func (g *Multipart) Start(ctx context.Context, wait chan struct{}) (Operations, error)

Jun 30, 2022

Changes in this version

type TTFB

+ Percentiles [101]time.Duration

Dec 16, 2021

Changes in this version

type Get

+ Versions int

type List

+ Versions int

type Stat

+ Versions int

Nov 23, 2021

Changes in this version

type Operations

+ func (o Operations) FilterLast() Operations

Nov 9, 2021

Changes in this version

+ type CmpReqs struct

+ After CmpRequests

+ Before CmpRequests

+ func (c *CmpReqs) Compare(before, after Operations)

+ func (c *CmpReqs) String() string

+ type CmpRequests struct

+ Average time.Duration

+ AvgObjSize int64

+ Best time.Duration

+ Median time.Duration

+ P25 time.Duration

+ P75 time.Duration

+ P90 time.Duration

+ P99 time.Duration

+ Requests int

+ Worst time.Duration

type Comparison

+ Reqs CmpReqs

Oct 21, 2021

Changes in this version

type Common

+ Locking bool

+ type Retention struct

+ Collector *Collector

+ CreateObjects int

+ Versions int

+ func (g *Retention) Cleanup(ctx context.Context)

+ func (g *Retention) Prepare(ctx context.Context) error

+ func (g *Retention) Start(ctx context.Context, wait chan struct{}) (Operations, error)

Oct 12, 2021

Changes in this version

type List

+ Metadata bool

Aug 17, 2021

Changes in this version

type TTFB

+ P25 time.Duration

+ P75 time.Duration

+ P90 time.Duration

+ P99 time.Duration

Mar 8, 2021

Changes in this version

type Operations

+ func (o Operations) Clone() Operations

+ func (o Operations) SortByEndTime()

Feb 22, 2021

Changes in this version

type Operations

+ func (o Operations) FilterFirst() Operations

+ func (o Operations) IsMultiTouch() bool

Dec 8, 2020

Changes in this version

type Get

+ RandomRanges bool

Nov 24, 2020

Changes in this version

type Operations

+ func (o Operations) HasError() bool

Nov 19, 2020

Changes in this version

type Operations

+ func (o Operations) Clients() int

Sep 12, 2020

Changes in this version

type Common

+ Error func(data ...interface{})

+ Versioned bool

+ func (c *Common) ErrorF(format string, data ...interface{})

type Operations

+ func (o Operations) Duration() time.Duration

Jul 28, 2020

Changes in this version

+ type Versioned struct

+ Collector *Collector

+ CreateObjects int

+ Dist *VersionedDistribution

+ GetOpts minio.GetObjectOptions

+ StatOpts minio.StatObjectOptions

+ func (g *Versioned) Cleanup(ctx context.Context)

+ func (g *Versioned) Prepare(ctx context.Context) error

+ func (g *Versioned) Start(ctx context.Context, wait chan struct{}) (Operations, error)

+ type VersionedDistribution struct

+ Distribution map[string]float64

+ func (m *VersionedDistribution) Generate(allocObjs int) error

+ func (m *VersionedDistribution) Objects() generator.Objects

Apr 30, 2020

Changes in this version

type Operations

+ func (o Operations) FilterSuccessful() Operations

Feb 11, 2020

Changes in this version

type Operations

+ func (o Operations) FirstObjSize() int64

+ func (o Operations) IsMixed() bool

+ func (o Operations) SingleSizeSegment() SizeSegment

type Segments

+ func (s Segments) Clone() Segments

type SizeSegment

+ func (s SizeSegment) SizesString() (lo, hi string)

type Throughput

+ func (t Throughput) Float() float64

Feb 4, 2020

Changes in this version

type Common

+ ClientMode bool

type MixedDistribution

+ func (m *MixedDistribution) Objects() generator.Objects

+ type Select struct

+ Collector *Collector

+ CreateObjects int

+ SelectOpts minio.SelectObjectOptions

+ func (g *Select) Cleanup(ctx context.Context)

+ func (g *Select) Prepare(ctx context.Context) error

+ func (g *Select) Start(ctx context.Context, wait chan struct{}) (Operations, error)

Jan 20, 2020

Changes in this version

+ type Benchmark interface

+ Cleanup func(ctx context.Context)

+ GetCommon func() *Common

+ Prepare func(ctx context.Context) error

+ Start func(ctx context.Context, wait chan struct{}) (Operations, error)

+ type CmpSegment struct

+ After *Segment

+ Before *Segment

+ ObjPerSec float64

+ OpsEndedPerSec float64

+ ThroughputPerSec float64

+ func (c *CmpSegment) Compare(before, after Segment)

+ func (c CmpSegment) String() string

+ type Collector struct

+ func NewCollector() *Collector

+ func (c *Collector) AutoTerm(ctx context.Context, op string, threshold float64, wantSamples, splitInto int, ...) context.Context

+ func (c *Collector) Close() Operations

+ func (c *Collector) Receiver() chan<- Operation

+ type Common struct

+ AutoTermDur time.Duration

+ AutoTermScale float64

+ Bucket string

+ Clear bool

+ Client func() (cl *minio.Client, done func())

+ Concurrency int

+ Location string

+ PrepareProgress chan float64

+ PutOpts minio.PutObjectOptions

+ Source func() generator.Source

+ func (c *Common) GetCommon() *Common

+ type Comparison struct

+ Average CmpSegment

+ Fastest CmpSegment

+ Median CmpSegment

+ Op string

+ Slowest CmpSegment

+ TTFB *TTFBCmp

+ func Compare(before, after Operations, analysis time.Duration) (*Comparison, error)

+ type Delete struct

+ BatchSize int

+ Collector *Collector

+ CreateObjects int

+ func (d *Delete) Cleanup(ctx context.Context)

+ func (d *Delete) Prepare(ctx context.Context) error

+ func (d *Delete) Start(ctx context.Context, wait chan struct{}) (Operations, error)

+ type Get struct

+ Collector *Collector

+ CreateObjects int

+ GetOpts minio.GetObjectOptions

+ func (g *Get) Cleanup(ctx context.Context)

+ func (g *Get) Prepare(ctx context.Context) error

+ func (g *Get) Start(ctx context.Context, wait chan struct{}) (Operations, error)

+ type List struct

+ Collector *Collector

+ CreateObjects int

+ NoPrefix bool

+ func (d *List) Cleanup(ctx context.Context)

+ func (d *List) Prepare(ctx context.Context) error

+ func (d *List) Start(ctx context.Context, wait chan struct{}) (Operations, error)

+ type Mixed struct

+ Collector *Collector

+ CreateObjects int

+ Dist *MixedDistribution

+ GetOpts minio.GetObjectOptions

+ StatOpts minio.StatObjectOptions

+ func (g *Mixed) Cleanup(ctx context.Context)

+ func (g *Mixed) Prepare(ctx context.Context) error

+ func (g *Mixed) Start(ctx context.Context, wait chan struct{}) (Operations, error)

+ type MixedDistribution struct

+ Distribution map[string]float64

+ func (m *MixedDistribution) Generate(allocObjs int) error

+ type Operation struct

+ ClientID string

+ End time.Time

+ Endpoint string

+ Err string

+ File string

+ FirstByte *time.Time

+ ObjPerOp int

+ OpType string

+ Size int64

+ Start time.Time

+ Thread uint16

+ func (o Operation) Aggregate(s *Segment)

+ func (o Operation) BytesPerSec() Throughput

+ func (o Operation) Duration() time.Duration

+ func (o Operation) String() string

+ func (o Operation) TTFB() time.Duration

+ type Operations []Operation

+ func OperationsFromCSV(r io.Reader) (Operations, error)

+ func (o Operations) ActiveTimeRange(allThreads bool) (start, end time.Time)

+ func (o Operations) AvgDuration() time.Duration

+ func (o Operations) AvgSize() int64

+ func (o Operations) ByEndpoint() map[string]Operations

+ func (o Operations) ByOp() map[string]Operations

+ func (o Operations) CSV(w io.Writer) error

+ func (o Operations) Endpoints() []string

+ func (o Operations) Errors() []string

+ func (o Operations) FilterByEndpoint(endpoint string) Operations

+ func (o Operations) FilterByHasTTFB(hasTTFB bool) Operations

+ func (o Operations) FilterByOp(opType string) Operations

+ func (o Operations) FilterErrors() Operations

+ func (o Operations) FilterInsideRange(start, end time.Time) Operations

+ func (o Operations) FirstObjPerOp() int

+ func (o Operations) FirstOpType() string

+ func (o Operations) Hosts() int

+ func (o Operations) IsMultiOp() bool

+ func (o Operations) Median(m float64) Operation

+ func (o Operations) MinMaxSize() (min, max int64)

+ func (o Operations) MultipleSizes() bool

+ func (o Operations) OffsetThreads(n uint16) uint16

+ func (o Operations) OpThroughput() Throughput

+ func (o Operations) OpTypes() []string

+ func (o Operations) Segment(so SegmentOptions) Segments

+ func (o Operations) SetClientID(id string)

+ func (o Operations) SortByDuration()

+ func (o Operations) SortByStartTime()

+ func (o Operations) SortByTTFB()

+ func (o Operations) SortByThroughput()

+ func (o Operations) SplitSizes(minShare float64) []SizeSegment

+ func (o Operations) TTFB(start, end time.Time) TTFB

+ func (o Operations) Threads() int

+ func (o Operations) TimeRange() (start, end time.Time)

+ func (o Operations) Total(allThreads bool) Segment

+ type Put struct

+ func (u *Put) Cleanup(ctx context.Context)

+ func (u *Put) Prepare(ctx context.Context) error

+ func (u *Put) Start(ctx context.Context, wait chan struct{}) (Operations, error)

+ type Segment struct

+ EndsBefore time.Time

+ Errors int

+ FullOps int

+ Host string

+ Objects float64

+ ObjsPerOp int

+ OpType string

+ OpsEnded int

+ OpsStarted int

+ PartialOps int

+ Start time.Time

+ TotalBytes int64

+ func (s Segment) CSV(w *csv.Writer, idx int) error

+ func (s Segment) Duration() time.Duration

+ func (s Segment) ShortString() string

+ func (s Segment) SpeedPerSec() (mb, ops, objs float64)

+ func (s Segment) String() string

+ type SegmentOptions struct

+ AllThreads bool

+ From time.Time

+ MultiOp bool

+ PerSegDuration time.Duration

+ type Segments []Segment

+ func (s Segments) CSV(w io.Writer) error

+ func (s Segments) Median(m float64) Segment

+ func (s Segments) Print(w io.Writer) error

+ func (s Segments) SortByObjsPerSec()

+ func (s Segments) SortByOpsEnded()

+ func (s Segments) SortByThroughput()

+ func (s Segments) SortByTime()

+ type SizeSegment struct

+ Biggest int64

+ BiggestLog10 int

+ Ops Operations

+ Smallest int64

+ SmallestLog10 int

+ func (s SizeSegment) SizeString() string

+ type Stat struct

+ Collector *Collector

+ CreateObjects int

+ StatOpts minio.StatObjectOptions

+ func (g *Stat) Cleanup(ctx context.Context)

+ func (g *Stat) Prepare(ctx context.Context) error

+ func (g *Stat) Start(ctx context.Context, wait chan struct{}) (Operations, error)

+ type TTFB struct

+ Average time.Duration

+ Best time.Duration

+ Median time.Duration

+ Worst time.Duration

+ func (t TTFB) Compare(after TTFB) *TTFBCmp

+ func (t TTFB) String() string

+ type TTFBCmp struct

+ After TTFB

+ Before TTFB

+ func (t *TTFBCmp) String() string

+ type Throughput float64

+ func (t Throughput) String() string