perf

package
v1.0.12 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2025 License: GPL-3.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TotalConnections      = "Total"
	ActiveConnections     = "Active"
	DroppedConnections    = "Dropped"
	TotalSentMessages     = "M-Sent"
	TotalReceivedMessages = "M-Received"
	TotalFailedMessages   = "M-Failed"

	ConnectionMeanTime = "C-Mean"
	ConnectionP95Time  = "C-P95"
	ConnectionP99Time  = "C-P99"

	MessageMeanTime = "M-Mean"
	MessageP95Time  = "M-P95"
	MessageP99Time  = "M-P99"

	StartTime = "StartTime"
	Uptime    = "Uptime"
)

Variables

View Source 
var LogBuffer = bytes.NewBuffer(nil)

Functions

func NewDefaultMessageGetter added in v0.0.8 

func NewDefaultMessageGetter(msg string) (messageGetter, error)

func NewMessage added in v0.0.8 

func NewMessage(fpath string) (messageGetter, error)

Types

type DefaultMessageGetter added in v0.0.8 

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

func (*DefaultMessageGetter) Get added in v0.0.8 

func (m *DefaultMessageGetter) Get(data any) []byte

func (*DefaultMessageGetter) GetTemplateString added in v1.0.9 

func (m *DefaultMessageGetter) GetTemplateString() string

type File added in v0.0.8 

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

func (*File) Get added in v0.0.8 

func (m *File) Get(_ any) []byte

func (*File) GetTemplateString added in v1.0.9 

func (m *File) GetTemplateString() string

type FileOutput added in v1.0.0 

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

func NewFileOutput added in v1.0.0 

func NewFileOutput(path string) *FileOutput

func (*FileOutput) Start added in v1.0.0 

func (fo *FileOutput) Start()

func (*FileOutput) Stop added in v1.0.0 

func (fo *FileOutput) Stop()

func (*FileOutput) UpdateTableAndLogs added in v1.0.0 

func (fo *FileOutput) UpdateTableAndLogs(data []string, errors errMsg)

type Generator 

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

func New 

func New(config config.Perf) (*Generator, error)

func (*Generator) Run 

func (g *Generator) Run(showTview bool)

type Metrics 

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

func NewMetrics 

func NewMetrics(totalConns int64, out string) *Metrics

func (*Metrics) DecrActiveConnections 

func (m *Metrics) DecrActiveConnections()

func (*Metrics) IncrActiveConnections 

func (m *Metrics) IncrActiveConnections()

func (*Metrics) IncrDroppedConnections added in v1.0.0 

func (m *Metrics) IncrDroppedConnections()

func (*Metrics) IncrFailedMessages 

func (m *Metrics) IncrFailedMessages()

func (*Metrics) IncrReceivedMessages 

func (m *Metrics) IncrReceivedMessages()

func (*Metrics) IncrSentMessages 

func (m *Metrics) IncrSentMessages()

func (*Metrics) SetAvgConnectTime 

func (m *Metrics) SetAvgConnectTime(dur time.Duration)

func (*Metrics) SetAvgMessageTime 

func (m *Metrics) SetAvgMessageTime(dur time.Duration)

type Printer added in v1.0.0 

type Printer interface {
	UpdateTableAndLogs(data []string, errors errMsg)
	Start()
	Stop()
}

type Sequence added in v1.0.9 

type Sequence struct {
	Seq uint64
}

type Tview added in v1.0.0 

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

func NewTview added in v1.0.0 

func NewTview() *Tview

func (*Tview) Start added in v1.0.0 

func (tv *Tview) Start()

func (*Tview) Stop added in v1.0.0 

func (tv *Tview) Stop()

func (*Tview) UpdateTableAndLogs added in v1.0.0 

func (tv *Tview) UpdateTableAndLogs(data []string, errors errMsg)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.