benchmark

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2020 License: AGPL-3.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Benchmark

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

func NewBenchmark

func NewBenchmark(cli *client.Client, concurrency int, duration time.Duration, timeout time.Duration) *Benchmark

func (*Benchmark) Run

func (b *Benchmark) Run(ctx context.Context) *ResultSet

func (*Benchmark) Send

func (b *Benchmark) Send(ctx context.Context, resCh chan *Result)

type FaultDetector

type FaultDetector struct {
	sync.RWMutex

	P2PNode  p2p.Node
	Group    *types.NotaryGroup
	DagStore nodestore.DagStore
	// contains filtered or unexported fields
}

func (*FaultDetector) Start

func (fd *FaultDetector) Start(ctx context.Context) error

func (*FaultDetector) Stop

func (fd *FaultDetector) Stop()

type Result

type Result struct {
	Duration    int
	Error       error
	Transaction *services.AddBlockRequest
}

type ResultSet

type ResultSet struct {
	FirstRound int64
	Rounds     *durationSet

	Errors    []string
	Measured  int
	Successes int
	Failures  int
	// contains filtered or unexported fields
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL