perf

package

v1.0.13 Latest Latest Go to latest Published: Apr 2, 2025 License: GPL-3.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/akshaykhairmode/wscli

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewDefaultMessageGetter(msg string) (messageGetter, error)
func NewMessage(fpath string) (messageGetter, error)
type DefaultMessageGetter
- func (m *DefaultMessageGetter) Get(data any) ([]byte, func())
- func (m *DefaultMessageGetter) GetTemplateString() string
type File
- func (m *File) Get(_ any) ([]byte, func())
- func (m *File) GetTemplateString() string
type FileOutput
- func NewFileOutput(path string) *FileOutput
- func (fo *FileOutput) Start()
- func (fo *FileOutput) Stop()
- func (fo *FileOutput) UpdateTableAndLogs(data []string, errors errMsg)
type Generator
- func New(pconfig config.Perf) (*Generator, error)
- func (g *Generator) Run(showTview bool)
type Metrics
- func NewMetrics(totalConns int64, out string) *Metrics
- func (m *Metrics) DecrActiveConnections()
- func (m *Metrics) IncrActiveConnections()
- func (m *Metrics) IncrDroppedConnections()
- func (m *Metrics) IncrFailedMessages()
- func (m *Metrics) IncrReceivedMessages()
- func (m *Metrics) IncrSentMessages()
- func (m *Metrics) SetAvgConnectTime(dur time.Duration)
- func (m *Metrics) SetAvgMessageTime(dur time.Duration)
type Printer
type Sequence
type Tview
- func NewTview() *Tview
- func (tv *Tview) Start()
- func (tv *Tview) Stop()
- func (tv *Tview) UpdateTableAndLogs(data []string, errors errMsg)

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())

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())

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(pconfig 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

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