benchmark

Documentation

Index

• Constants
• func MustEncode(enc ReportEncoder, trs TargetReports) string
• func NewMessage(size uint) []byte
• type AppendMetrics
• type AppendReport
  • func NewAppendReportFromMetrics(metrics AppendMetrics, interval time.Duration) AppendReport
• type Benchmark
  • func New(opts ...Option) (bm *Benchmark, err error)
  • func (bm *Benchmark) Close() error
  • func (bm *Benchmark) Run() error
• type EndToEndReport
• type JsonEncoder
  • func (je JsonEncoder) Encode(trs TargetReports) ([]byte, error)
• type Loader
  • func NewLoader(cfg loaderConfig) (loader *Loader, err error)
  • func (loader *Loader) Close() error
  • func (loader *Loader) Run(ctx context.Context) (err error)
• type LoaderMetrics
  • func (lm *LoaderMetrics) Flush() TargetReport
  • func (lm *LoaderMetrics) ReportAppendMetrics(m AppendMetrics) bool
  • func (lm *LoaderMetrics) ReportSubscribeMetrics(m SubscribeMetrics) bool
  • func (lm *LoaderMetrics) Reset(now time.Time)
• type Metrics
  • func (m Metrics) Flush() TargetReports
• type Option
  • func WithClusterID(cid types.ClusterID) Option
  • func WithDuration(duration time.Duration) Option
  • func WithMetadataRepository(addrs []string) Option
  • func WithReportEncoder(enc ReportEncoder) Option
  • func WithReportInterval(reportInterval time.Duration) Option
  • func WithSingleConnPerTarget() Option
  • func WithTargets(targets ...Target) Option
• type Report
• type ReportEncoder
• type StringEncoder
  • func (se StringEncoder) Encode(trs TargetReports) ([]byte, error)
• type SubscribeMetrics
• type SubscribeReport
  • func NewSubscribeReportFromMetrics(metrics SubscribeMetrics, interval time.Duration) SubscribeReport
• type Target
  • func (tgt Target) String() string
  • func (tgt Target) Valid() error
• type TargetReport
• type TargetReports

Constants

const (
	DefaultMessageSize    = 0
	DefaultBatchSize      = 1
	DefaultConcurrency    = 0
	DefaultDuration       = 1 * time.Minute
	DefaultReportInterval = 3 * time.Second
)

Functions

func MustEncode

func MustEncode(enc ReportEncoder, trs TargetReports) string

func NewMessage

func NewMessage(size uint) []byte

Types

type AppendMetrics

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

type AppendReport

type AppendReport struct {
	RequestsPerSecond float64 `json:"requestsPerSecond"`
	BytesPerSecond    float64 `json:"bytesPerSecond"`
	Duration          float64 `json:"duration"`
}

func NewAppendReportFromMetrics

func NewAppendReportFromMetrics(metrics AppendMetrics, interval time.Duration) AppendReport

type Benchmark

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

func New

func New(opts ...Option) (bm *Benchmark, err error)

New creates a new Benchmark and returns it. Users must call Close to release resources if it returns successfully.

func (*Benchmark) Close

func (bm *Benchmark) Close() error

Close releases resources acquired by Benchmark and Loader.

func (*Benchmark) Run

func (bm *Benchmark) Run() error

Run starts Loaders and metric reporter. It blocks until the loaders are finished.

type EndToEndReport

type EndToEndReport struct {
	Latency float64 `json:"latency"`
}

type JsonEncoder

type JsonEncoder struct{}

func (JsonEncoder) Encode

func (je JsonEncoder) Encode(trs TargetReports) ([]byte, error)

type Loader

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

func NewLoader

func NewLoader(cfg loaderConfig) (loader *Loader, err error)

func (*Loader) Close

func (loader *Loader) Close() error

func (*Loader) Run

func (loader *Loader) Run(ctx context.Context) (err error)

Run starts goroutines that append log entries and subscribe to them.

type LoaderMetrics

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

func (*LoaderMetrics) Flush

func (lm *LoaderMetrics) Flush() TargetReport

func (*LoaderMetrics) ReportAppendMetrics

func (lm *LoaderMetrics) ReportAppendMetrics(m AppendMetrics) bool

func (*LoaderMetrics) ReportSubscribeMetrics

func (lm *LoaderMetrics) ReportSubscribeMetrics(m SubscribeMetrics) bool

func (*LoaderMetrics) Reset

func (lm *LoaderMetrics) Reset(now time.Time)

type Metrics

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

func (Metrics) Flush

func (m Metrics) Flush() TargetReports

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithClusterID

func WithClusterID(cid types.ClusterID) Option

func WithDuration

func WithDuration(duration time.Duration) Option

func WithMetadataRepository

func WithMetadataRepository(addrs []string) Option

func WithReportEncoder

func WithReportEncoder(enc ReportEncoder) Option

func WithReportInterval

func WithReportInterval(reportInterval time.Duration) Option

func WithSingleConnPerTarget

func WithSingleConnPerTarget() Option

func WithTargets

func WithTargets(targets ...Target) Option

type Report

type Report struct {
	AppendReport    `json:"append"`
	SubscribeReport `json:"subscribe"`
	EndToEndReport  `json:"endToEnd"`
}

type ReportEncoder

type ReportEncoder interface {
	Encode(trs TargetReports) ([]byte, error)
}

type StringEncoder

type StringEncoder struct{}

func (StringEncoder) Encode

func (se StringEncoder) Encode(trs TargetReports) ([]byte, error)

type SubscribeMetrics

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

type SubscribeReport

type SubscribeReport struct {
	LogsPerSecond  float64 `json:"logsPerSecond"`
	BytesPerSecond float64 `json:"bytesPerSecond"`
}

func NewSubscribeReportFromMetrics

func NewSubscribeReportFromMetrics(metrics SubscribeMetrics, interval time.Duration) SubscribeReport

type Target

type Target struct {
	TopicID          types.TopicID     `json:"topicId"`
	LogStreamID      types.LogStreamID `json:"logStreamId"`
	MessageSize      uint
	BatchSize        uint
	AppendersCount   uint
	SubscribersCount uint
	PipelineSize     int
}

func (Target) String

func (tgt Target) String() string

func (Target) Valid

func (tgt Target) Valid() error

type TargetReport

type TargetReport struct {
	Target string `json:"target"`
	Recent Report `json:"recent"`
	Total  Report `json:"total"`
}

type TargetReports

type TargetReports struct {
	Reports []TargetReport `json:"reports"`
}