Documentation
¶
Index ¶
- type BaseMeasurement
- func NewAppPushability(pushAndDeleteAppCommandGeneratorFunc func() []cmdStartWaiter.CmdStartWaiter, ...) BaseMeasurement
- func NewHTTPAvailability(url string, client *http.Client) BaseMeasurement
- func NewRecentLogs(recentLogsCommandGeneratorFunc func() []cmdStartWaiter.CmdStartWaiter, ...) BaseMeasurement
- func NewStatsAvailability(statsAvailabilityCommandGeneratorFunc func() []cmdStartWaiter.CmdStartWaiter, ...) BaseMeasurement
- func NewStreamingLogs(...) BaseMeasurement
- func NewSyslogDrain(recentLogsCommandGeneratorFunc func() []cmdStartWaiter.CmdStartWaiter, ...) BaseMeasurement
- func NewTCPAvailability(url string, port int) BaseMeasurement
- type Measurement
- type ResultSet
- type ShouldRetryFunc
- type Summary
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseMeasurement ¶
type BaseMeasurement interface {
Name() string
PerformMeasurement() (string, string, string, bool)
SummaryPhrase() string
}
func NewAppPushability ¶
func NewAppPushability( pushAndDeleteAppCommandGeneratorFunc func() []cmdStartWaiter.CmdStartWaiter, runner cmdRunner.CmdRunner, runnerOutBuf *bytes.Buffer, runnerErrBuf *bytes.Buffer, ) BaseMeasurement
func NewHTTPAvailability ¶
func NewHTTPAvailability(url string, client *http.Client) BaseMeasurement
func NewRecentLogs ¶
func NewRecentLogs( recentLogsCommandGeneratorFunc func() []cmdStartWaiter.CmdStartWaiter, runner cmdRunner.CmdRunner, runnerOutBuf *bytes.Buffer, runnerErrBuf *bytes.Buffer, appLogValidator appLogValidator.AppLogValidator, ) BaseMeasurement
func NewStatsAvailability ¶
func NewStatsAvailability( statsAvailabilityCommandGeneratorFunc func() []cmdStartWaiter.CmdStartWaiter, runner cmdRunner.CmdRunner, runnerOutBuf *bytes.Buffer, runnerErrBuf *bytes.Buffer, ) BaseMeasurement
func NewStreamingLogs ¶
func NewStreamingLogs( streamLogsCommandGeneratorFunc func() (context.Context, context.CancelFunc, []cmdStartWaiter.CmdStartWaiter), runner cmdRunner.CmdRunner, runnerOutBuf *bytes.Buffer, runnerErrBuf *bytes.Buffer, appLogValidator appLogValidator.AppLogValidator, ) BaseMeasurement
func NewSyslogDrain ¶
func NewSyslogDrain( recentLogsCommandGeneratorFunc func() []cmdStartWaiter.CmdStartWaiter, runner cmdRunner.CmdRunner, runnerOutBuf *bytes.Buffer, runnerErrBuf *bytes.Buffer, appLogValidator appLogValidator.AppLogValidator, ) BaseMeasurement
func NewTCPAvailability ¶
func NewTCPAvailability(url string, port int) BaseMeasurement
type Measurement ¶
type Measurement interface {
Name() string
Start()
Stop()
Results() ResultSet
Failed() bool
Summary() string
SummaryData() Summary
}
func NewPeriodic ¶
func NewPeriodic( logger *log.Logger, clock clock.Clock, freq time.Duration, baseMeasurement BaseMeasurement, resultSet ResultSet, allowedFailures int, shouldRetryFunc ShouldRetryFunc, ) Measurement
func NewPeriodicWithoutMeasuringImmediately ¶
func NewPeriodicWithoutMeasuringImmediately( logger *log.Logger, clock clock.Clock, freq time.Duration, baseMeasurement BaseMeasurement, resultSet ResultSet, allowedFailures int, shouldRetryFunc ShouldRetryFunc, ) Measurement
type ResultSet ¶
type ResultSet interface {
RecordSuccess()
RecordFailure()
SuccessesSinceLastFailure() (int, time.Time)
Successful() int
Failed() int
Total() int
}
func NewResultSet ¶
func NewResultSet() ResultSet
type ShouldRetryFunc ¶
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.