blast

Documentation

Overview

The blast package implements a benchmark where a fixed number of requests are sent to the server in their own thread (e.g. blasting the server with requests) and the total amount of time to respond to all requests is measured. This benchmark is primarily intended for computing throughput in messages per second.

Index

• type Blast
  • func New(opts *options.Options) *Blast
  • func (b *Blast) Client() (_ *ensign.Client, err error)
  • func (b *Blast) Close()
  • func (b *Blast) Prepare(ctx context.Context) (err error)
  • func (b *Blast) Results() (benchmarks.Metrics, error)
  • func (b *Blast) Run(ctx context.Context) (err error)
• type EventFactory
  • func MakeEventFactory(size int, topicID ulid.ULID) EventFactory

Types

type Blast

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

Blast implements the benchmark interface and runs a throughput-oriented benchmark that fires off a workload with a fixed number of requests and measures the amount of time that the server responds to all requests.

func New

func New(opts *options.Options) *Blast

func (*Blast) Client

func (b *Blast) Client() (_ *ensign.Client, err error)

func (*Blast) Close

func (b *Blast) Close()

func (*Blast) Prepare

func (b *Blast) Prepare(ctx context.Context) (err error)

func (*Blast) Results

func (b *Blast) Results() (benchmarks.Metrics, error)

func (*Blast) Run

func (b *Blast) Run(ctx context.Context) (err error)

Note: this is prototype trash-pumpkin code.

type EventFactory

type EventFactory func() *api.EventWrapper

func MakeEventFactory

func MakeEventFactory(size int, topicID ulid.ULID) EventFactory