perf

package

v0.0.8 Latest Latest Go to latest Published: Mar 3, 2025 License: GPL-3.0 Imports: 20 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
type DefaultMessageGetter
- func (m *DefaultMessageGetter) Get() []byte
type File
- func (m *File) Get() []byte
type Generator
- func New(config config.Perf) (*Generator, error)
- func (g *Generator) Run()
type MessageGetter
- func NewDefaultMessageGetter(msg string) (MessageGetter, error)
- func NewMessage(fpath string) (MessageGetter, error)
type Metrics
- func NewMetrics(totalConns int64) *Metrics

Constants ¶

View Source

const (
	TotalConnections      = "Total"
	ActiveConnections     = "Active"
	TotalSentMessages     = "Sent"
	TotalReceivedMessages = "Received"
	TotalFailedMessages   = "Failed"

	ConnectionMeanTime = "C_Mean"
	ConnectionP95Time  = "C_P95"
	ConnectionP99Time  = "C_P99"

	MessageMeanTime = "M_Mean"
	MessageP95Time  = "M_P95"
	MessageP99Time  = "M_P99"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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() []byte

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() []byte

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

type MessageGetter ¶ added in v0.0.8

type MessageGetter interface {
	Get() []byte
}

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)

type Metrics ¶

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

func NewMetrics ¶

func NewMetrics(totalConns int64) *Metrics

func (*Metrics) DecrActiveConnections ¶

func (m *Metrics) DecrActiveConnections()

func (*Metrics) IncrActiveConnections ¶

func (m *Metrics) IncrActiveConnections()

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)

Source Files ¶

View all Source files

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