loadtest

package

Go to main page

Versions in this module

v0

v0.9.0

Jan 29, 2020

Changes in this version

+ const KVStoreClientIDLen

+ type AggregateStats struct

+ AvgDataRate float64

+ AvgTxRate float64

+ TotalBytes int64

+ TotalTimeSeconds float64

+ TotalTxs int

+ func (s *AggregateStats) Compute()

+ func (s *AggregateStats) String() string

type ClientFactory

+ ValidateConfig func(cfg Config) error

type Config

+ func (c Config) MaxTxsPerEndpoint() uint64

type KVStoreClientFactory

+ func (f *KVStoreClientFactory) ValidateConfig(cfg Config) error

type Transactor

+ func (t *Transactor) GetTxBytes() int64

v0.8.0

Jan 21, 2020

Changes in this version

type MasterConfig

+ LoadTestID int

v0.7.1

Jan 21, 2020

Changes in this version

+ func ExecuteStandalone(cfg Config) error

type Config

+ NoTrapInterrupts bool

+ StatsOutputFile string

type TransactorGroup

+ func (g *TransactorGroup) WriteAggregateStats(filename string) error

v0.7.0

Sep 11, 2019

v0.6.2

Sep 11, 2019

v0.6.1

Sep 11, 2019

v0.6.0

Sep 11, 2019

Changes in this version

type Config

+ MinConnectivity int

v0.5.1

Sep 11, 2019

Changes in this version

+ const SelectAnyEndpoints

+ const SelectDiscoveredEndpoints

+ const SelectSuppliedEndpoints

type Config

+ MaxEndpoints int

v0.5.0

Sep 10, 2019

Changes in this version

+ const SelectCrawledEndpoints

+ const SelectGivenEndpoints

type Config

+ EndpointSelectMethod string

+ ExpectPeers int

+ PeerConnectTimeout int

v0.4.2

Jul 26, 2019

Changes in this version

+ const CLIVersion

v0.4.1

Jul 24, 2019

Changes in this version

type MasterConfig

+ ShutdownWait int

type SlaveConfig

+ ID string

v0.4.0

Jul 22, 2019

Changes in this version

+ type CLIConfig struct

+ AppLongDesc string

+ AppName string

+ AppShortDesc string

+ DefaultClientFactory string

type Client

+ GenerateTx func() ([]byte, error)

type Config

+ BroadcastTxMethod string

+ ClientFactory string

+ Connections int

+ Count int

+ Endpoints []string

+ Rate int

+ SendPeriod int

+ Size int

+ Time int

+ func (c Config) ToJSON() string

+ type KVStoreClient struct

+ func (c *KVStoreClient) GenerateTx() ([]byte, error)

+ type KVStoreClientFactory struct

+ func NewKVStoreClientFactory() *KVStoreClientFactory

+ func (f *KVStoreClientFactory) NewClient() (Client, error)

type Master

+ func (m *Master) ReceiveSlaveUpdate(msg slaveMsg)

+ func (m *Master) RegisterRemoteSlave(rs *remoteSlave) error

+ func (m *Master) UnregisterRemoteSlave(id string, err error)

type MasterConfig

+ BindAddr string

+ SlaveConnectTimeout int

+ func (c MasterConfig) ToJSON() string

type Slave

+ func (s *Slave) Config() Config

+ func (s *Slave) ID() string

type SlaveConfig

+ MasterAddr string

+ MasterConnectTimeout int

+ func (c SlaveConfig) ToJSON() string

+ type Transactor struct

+ func NewTransactor(remoteAddr string, config *Config) (*Transactor, error)

+ func (t *Transactor) Cancel()

+ func (t *Transactor) GetTxCount() int

+ func (t *Transactor) GetTxRate() float64

+ func (t *Transactor) SetProgressCallback(id int, interval time.Duration, callback func(int, int))

+ func (t *Transactor) Start()

+ func (t *Transactor) Wait() error

+ type TransactorGroup struct

+ func NewTransactorGroup() *TransactorGroup

+ func (g *TransactorGroup) Add(remoteAddr string, config *Config) error

+ func (g *TransactorGroup) AddAll(cfg *Config) error

+ func (g *TransactorGroup) Cancel()

+ func (g *TransactorGroup) SetProgressCallback(interval time.Duration, callback func(*TransactorGroup, int))

+ func (g *TransactorGroup) Start()

+ func (g *TransactorGroup) Wait() error

v0.3.0

May 14, 2019

Changes in this version

+ const DefaultOutageSimTargetPort

+ const DefaultOutageSimTimeout

+ const EnvOutageSimPassword

+ const EnvOutageSimUser

+ const EnvPrefix

+ type MasterAuthConfig struct

+ Enabled bool

+ PasswordHash string

+ Username string

type MasterConfig

+ Auth MasterAuthConfig

+ type NodeOutageSimulator struct

+ func NewNodeOutageSimulator(moniker string, outageSimURL *url.URL, username, password, plan string) (*NodeOutageSimulator, error)

+ func (s *NodeOutageSimulator) Cancel()

+ func (s *NodeOutageSimulator) Start(errc chan error)

+ func (s *NodeOutageSimulator) Wait()

+ type NodeStatus string

+ const NodeDown

+ const NodeUp

+ type NodeStatusUpdate struct

+ Next *NodeStatusUpdate

+ Status NodeStatus

+ Wait time.Duration

+ func NewNodeStatusUpdate(client *http.Client, outageSimURL *url.URL, username, password string, ...) *NodeStatusUpdate

+ func (u *NodeStatusUpdate) Cancel()

+ func (u *NodeStatusUpdate) Join()

+ func (u *NodeStatusUpdate) Start(errc chan error)

+ type OutageSimulator struct

+ func NewOutageSimulator(plan, username, password string, nodeURLs map[string]string) (*OutageSimulator, error)

+ func (s *OutageSimulator) Cancel()

+ func (s *OutageSimulator) Start(errc chan error)

+ func (s *OutageSimulator) Wait()

+ type ParseableURL url.URL

+ func (p *ParseableURL) MarshalText() (text []byte, err error)

+ func (p *ParseableURL) String() string

+ func (p *ParseableURL) UnmarshalText(text []byte) error

type Summary

+ func RunStandalone(configFile string) (summary *Summary, err error)

type TestNetworkConfig

+ OutageSim TestNetworkOutageSimConfig

+ func (c *TestNetworkConfig) TargetsAsMap() (m map[string]TestNetworkTargetConfig)

+ type TestNetworkOutageSimConfig struct

+ Enabled bool

+ Password string

+ Plan string

+ TargetPort int

+ Username string

+ func (c *TestNetworkOutageSimConfig) Validate() error

v0.2.0

May 7, 2019

Changes in this version

+ const DefaultSlaveClientsKillMaxWait

+ const DefaultSlaveKillCheckInterval

+ const DefaultSlaveLongPollTimeout

+ const DefaultSlaveUpdateTimeout

type ErrorCode

+ const ErrCLIFailure

type Master

+ func (m *Master) Kill()

+ func (m *Master) Run() (*Summary, error)

type MasterConfig

+ WaitAfterFinished timeutils.ParseableDuration

type Slave

+ func (s *Slave) Kill()

+ func (s *Slave) Run() (*Summary, error)

type SlaveConfig

+ ExpectMasterWithin timeutils.ParseableDuration

+ ExpectStartWithin timeutils.ParseableDuration

+ WaitAfterFinished timeutils.ParseableDuration

+ type Summary struct

+ Interactions int64

+ TotalTestTime time.Duration

+ func (s *Summary) Log(logger logging.Logger)

+ type TestNetworkAutodetectConfig struct

+ Enabled bool

+ ExpectTargets int

+ ExpectTargetsWithin timeutils.ParseableDuration

+ SeedNode string

+ TargetSeedNode bool

+ func (c *TestNetworkAutodetectConfig) Validate() error

type TestNetworkConfig

+ Autodetect TestNetworkAutodetectConfig

v0.1.0

Apr 12, 2019

Changes in this version

+ const DefaultHealthCheckInterval

+ const DefaultHistogramBinCount

+ const DefaultMaxMissedHealthCheckPeriod

+ const DefaultMaxMissedHealthChecks

+ const SingleTestSummaryPlot

+ func AddStatistic(stats *messages.SummaryStats, timeTaken time.Duration, err error)

+ func ErrorMessageForCode(code ErrorCode, additionalInfo ...string) string

+ func FlattenResponseTimeHistogram(h *messages.ResponseTimeHistogram, indent string) (string, string)

+ func GetSupportedClientFactoryIDs() []string

+ func IsErrorCode(err error, code ErrorCode) bool

+ func LogStats(logger logging.Logger, stats *messages.CombinedStats)

+ func LogSummaryStats(logger logging.Logger, logPrefix string, stats *messages.SummaryStats, ...)

+ func MakeTxKV() ([]byte, []byte, []byte)

+ func MergeCombinedStats(dest, src *messages.CombinedStats)

+ func MergeSummaryStats(dest, src *messages.SummaryStats)

+ func NewMaster(cfg *Config, probe Probe) (*actor.PID, *actor.RootContext, error)

+ func NewResponseTimeHistogram(timeout time.Duration) *messages.ResponseTimeHistogram

+ func NewSlave(cfg *Config, probe Probe) (*actor.PID, *actor.RootContext, error)

+ func NewSummaryStats(timeout time.Duration, totalClients int64) *messages.SummaryStats

+ func ParseSummaryStats(rows [][]string) (*messages.SummaryStats, int, int64, error)

+ func PlotSingleTestSummaryResults(inputDir, outputDir string) error

+ func RandomSleep(minSleep, maxSleep time.Duration)

+ func ReadCombinedStats(r io.Reader) (*messages.CombinedStats, error)

+ func ReadCombinedStatsFromFile(csvFile string) (*messages.CombinedStats, error)

+ func RegisterClientFactory(id string, factory ClientFactory)

+ func RenderSingleTestSummaryPlot(cfg *Config, stats *messages.CombinedStats, ...) (string, error)

+ func Run()

+ func RunMaster(configFile string) error

+ func RunMasterWithConfig(cfg *Config) error

+ func RunSlave(configFile string) error

+ func RunSlaveWithConfig(cfg *Config) error

+ func SummarizeCombinedStats(stats *messages.CombinedStats) *messages.CombinedStats

+ func SummarizeSummaryStats(stats *messages.SummaryStats) *messages.SummaryStats

+ func WriteCombinedStats(writer io.Writer, stats *messages.CombinedStats) error

+ func WriteCombinedStatsToFile(outputFile string, stats *messages.CombinedStats) error

+ func WriteSummaryStats(writer *csv.Writer, indentCount int, linePrefix string, ...) error

+ type CalculatedStats struct

+ AbsPerSec float64

+ AvgTimePerClient float64

+ AvgTotalClientTime float64

+ CountPerClient float64

+ FailureRate float64

+ PerSec float64

+ PerSecPerClient float64

+ TopErrors []*FlattenedError

+ func CalculateStats(stats *messages.SummaryStats, totalTestTime int64) *CalculatedStats

+ type Client interface

+ GetStats func() *messages.CombinedStats

+ Interact func()

+ type ClientConfig struct

+ InteractionTimeout ParseableDuration

+ MaxInteractions int

+ MaxTestTime ParseableDuration

+ RequestTimeout ParseableDuration

+ RequestWaitMax ParseableDuration

+ RequestWaitMin ParseableDuration

+ Spawn int

+ SpawnRate float64

+ Type string

+ func (c *ClientConfig) Validate() error

+ type ClientFactory interface

+ NewClient func(params ClientParams) Client

+ NewStats func(params ClientParams) *messages.CombinedStats

+ func GetClientFactory(id string) ClientFactory

+ type ClientParams struct

+ InteractionTimeout time.Duration

+ RequestTimeout time.Duration

+ RequestWaitMax time.Duration

+ RequestWaitMin time.Duration

+ TargetNodes []string

+ TotalClients int64

+ type Config struct

+ Clients ClientConfig

+ Master MasterConfig

+ Slave SlaveConfig

+ TestNetwork TestNetworkConfig

+ func LoadConfig(filename string) (*Config, error)

+ func ParseConfig(data string) (*Config, error)

+ func (c *Config) Validate() error

+ type Error struct

+ Code ErrorCode

+ Message string

+ Upstream error

+ func NewError(code ErrorCode, upstream error, additionalInfo ...string) *Error

+ func (e Error) Error() string

+ type ErrorCode int

+ const ErrFailedToCreateActor

+ const ErrFailedToDecodeConfig

+ const ErrFailedToReadConfigFile

+ const ErrInvalidConfig

+ const ErrKilled

+ const ErrMasterFailed

+ const ErrSlaveFailed

+ const ErrStatsSanityCheckFailed

+ const ErrTimedOutWaitingForSlaves

+ const NoError

+ type FlattenedError struct

+ Count int64

+ ErrorType string

+ func FlattenedSortedErrors(stats *messages.SummaryStats) []*FlattenedError

+ type Master struct

+ func (m *Master) Receive(ctx actor.Context)

+ type MasterConfig struct

+ Bind string

+ ExpectSlaves int

+ ExpectSlavesWithin ParseableDuration

+ ResultsDir string

+ func (m *MasterConfig) Validate() error

+ type MetricFamilyData struct

+ Data []float64

+ Help string

+ ID string

+ Timestamps []float64

+ type NodePrometheusStats map[string]map[int64]float64

+ func GetNodePrometheusStats(c *http.Client, endpoint *PrometheusEndpoint, ts int64) (NodePrometheusStats, map[string]string, error)

+ func (s NodePrometheusStats) ExtractTimestamps() []int64

+ func (s NodePrometheusStats) Merge(src NodePrometheusStats)

+ type NoopClient struct

+ func NewNoopClient(factory *NoopClientFactory) *NoopClient

+ func (c *NoopClient) GetStats() *messages.CombinedStats

+ func (c *NoopClient) Interact()

+ type NoopClientFactory struct

+ func (f *NoopClientFactory) NewClient(params ClientParams) Client

+ func (f *NoopClientFactory) NewStats(_ ClientParams) *messages.CombinedStats

+ type NoopProbe struct

+ func (p *NoopProbe) OnShutdown(ctx actor.Context, err error)

+ func (p *NoopProbe) OnStartup(ctx actor.Context)

+ func (p *NoopProbe) OnStopped(ctx actor.Context)

+ type ParseableDuration time.Duration

+ func (d *ParseableDuration) UnmarshalText(text []byte) error

+ type Probe interface

+ OnShutdown func(ctx actor.Context, err error)

+ OnStartup func(ctx actor.Context)

+ OnStopped func(ctx actor.Context)

+ type PrometheusEndpoint struct

+ ID string

+ URL string

+ type PrometheusStats struct

+ MetricFamilyDescriptions map[string]string

+ StartTime time.Time

+ TargetNodesStats map[string]NodePrometheusStats

+ func NewPrometheusStats(logger logging.Logger) *PrometheusStats

+ func (ps *PrometheusStats) Dump(outputPath string) error

+ func (ps *PrometheusStats) Merge(s nodePrometheusStats)

+ func (ps *PrometheusStats) RunCollectors(cfg *Config, shutdownc, donec chan bool, logger logging.Logger)

+ type RPCClient struct

+ func NewRPCClient(factory *RPCClientFactory, targetURLs []string, ...) *RPCClient

+ func (c *RPCClient) GetStats() *messages.CombinedStats

+ func (c *RPCClient) Interact()

+ type RPCClientFactory struct

+ func (f *RPCClientFactory) NewClient(params ClientParams) Client

+ func (f *RPCClientFactory) NewStats(params ClientParams) *messages.CombinedStats

+ type SingleTestNodeChart struct

+ Hostnames template.JS

+ ID template.JS

+ NodesData template.JS

+ Title template.JS

+ type SingleTestSummaryContext struct

+ ClientMaxInteractions template.HTML

+ ClientRequestTimeout template.HTML

+ ClientRequestWaitMax template.HTML

+ ClientRequestWaitMin template.HTML

+ ClientSpawn template.HTML

+ ClientSpawnRate template.HTML

+ ClientType template.HTML

+ ErrorCounts []SingleTestSummaryErrorCount

+ InteractionsCount template.HTML

+ InteractionsErrorRate template.HTML

+ InteractionsErrors template.HTML

+ InteractionsMaxTime template.HTML

+ InteractionsMinTime template.HTML

+ InteractionsPerSec template.HTML

+ InteractionsResponseTimesBins template.JS

+ InteractionsResponseTimesCounts template.JS

+ InteractionsTotalClients template.HTML

+ NodeCharts []SingleTestNodeChart

+ Requests []SingleTestSummaryRequestParams

+ SlaveNodeCount template.HTML

+ TotalTestTime template.HTML

+ func NewSingleTestSummaryContext(cfg *Config, stats *messages.CombinedStats, ...) SingleTestSummaryContext

+ type SingleTestSummaryErrorCount struct

+ Count template.HTML

+ Description template.HTML

+ type SingleTestSummaryRequestParams struct

+ Count template.HTML

+ ErrorCounts []SingleTestSummaryErrorCount

+ ErrorRate template.HTML

+ Errors template.HTML

+ MaxTime template.HTML

+ MinTime template.HTML

+ Name template.HTML

+ PerSec template.HTML

+ ResponseTimesBins template.JS

+ ResponseTimesCounts template.JS

+ type Slave struct

+ func (s *Slave) Receive(ctx actor.Context)

+ type SlaveConfig struct

+ Bind string

+ Master string

+ UpdateInterval ParseableDuration

+ func (s *SlaveConfig) Validate() error

+ type StandardProbe struct

+ func NewStandardProbe() *StandardProbe

+ func (p *StandardProbe) OnShutdown(ctx actor.Context, err error)

+ func (p *StandardProbe) OnStartup(ctx actor.Context)

+ func (p *StandardProbe) OnStopped(ctx actor.Context)

+ func (p *StandardProbe) Wait() error

+ type TestNetworkConfig struct

+ EnablePrometheus bool

+ PrometheusPollInterval ParseableDuration

+ PrometheusPollTimeout ParseableDuration

+ Targets []TestNetworkTargetConfig

+ func (c *TestNetworkConfig) GetTargetRPCURLs() []string

+ func (c *TestNetworkConfig) Validate() error

+ type TestNetworkTargetConfig struct

+ ID string

+ Outages string

+ PrometheusURLs string

+ URL string

+ func (c *TestNetworkTargetConfig) Validate(i int) error

+ func (c TestNetworkTargetConfig) GetPrometheusEndpoints() []*PrometheusEndpoint

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