test

package
v1.0.13 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DoSomeLogging 

func DoSomeLogging(cfg DoSomeLoggingCfg) (logged int32, filtered int32)

DoSomeLogging performs some concurrent logging on a preconfigured Logr.

func StringRnd 

func StringRnd(length int) string

StringRnd returns a pseudo-random string of the specified length.

Types

type Buffer 

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

Buffer is a simple buffer implementing io.Writer

func (*Buffer) Bytes 

func (b *Buffer) Bytes() []byte

Bytes returns buffer contents as a slice.

func (*Buffer) String 

func (b *Buffer) String() string

String returns the buffer as a string.

func (*Buffer) Write 

func (b *Buffer) Write(data []byte) (int, error)

Write adds data to the buffer.

type DoSomeLoggingCfg 

type DoSomeLoggingCfg struct {
	// Lgr is a preconfigured Logr instance.
	Lgr *logr.Logr
	// Goroutines is number of goroutines to start.
	Goroutines int
	// Loops is number of loops per goroutine.
	Loops int
	// GoodToken is some text that is output for log statements that
	// should be output.
	GoodToken string
	// BadToken is text that is output for log statements that should be
	// filtered out.
	BadToken string
	// Lvl is the Level to use for log statements.
	Lvl logr.Level
	// Delay is amount of time to pause between loops.
	Delay time.Duration
}

DoSomeLoggingCfg is configuration for `DoSomeLogging` utility.

type FailingTarget added in v1.0.6 

type FailingTarget struct {
	logr.Basic
}

FailingTarget is a test target that always fails.

func NewFailingTarget added in v1.0.6 

func NewFailingTarget(filter logr.Filter, formatter logr.Formatter) *FailingTarget

NewFailingTarget creates a target that always fails.

func (*FailingTarget) Write added in v1.0.6 

func (ft *FailingTarget) Write(rec *logr.LogRec) error

Write simply fails.

type SlowTarget 

type SlowTarget struct {
	logr.Basic

	Delay time.Duration
	// contains filtered or unexported fields
}

SlowTarget outputs log records to any `io.Writer` with configurable delay to simulate slower targets. Modify SlowTarget.Delay to determine the pause per log record.

func NewSlowTarget 

func NewSlowTarget(filter logr.Filter, formatter logr.Formatter, out io.Writer, maxQueue int) *SlowTarget

NewSlowTarget creates a new SlowTarget.

func (*SlowTarget) Write 

func (st *SlowTarget) Write(rec *logr.LogRec) error

Write converts the log record to bytes, via the Formatter, and outputs to the io.Writer.

type TestCounter added in v1.0.6 

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

func (*TestCounter) Add added in v1.0.6 

func (c *TestCounter) Add(val float64)

func (*TestCounter) Inc added in v1.0.6 

func (c *TestCounter) Inc()

type TestGauge added in v1.0.6 

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

func (*TestGauge) Add added in v1.0.6 

func (g *TestGauge) Add(val float64)

func (*TestGauge) Set added in v1.0.6 

func (g *TestGauge) Set(val float64)

func (*TestGauge) Sub added in v1.0.6 

func (g *TestGauge) Sub(val float64)

type TestMetrics added in v1.0.6 

type TestMetrics struct {
	QueueSize float64
	Logged    float64
	Errors    float64
	Dropped   float64
	Blocked   float64
}

type TestMetricsCollector added in v1.0.6 

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

func NewTestMetricsCollector added in v1.0.6 

func NewTestMetricsCollector() *TestMetricsCollector

func (*TestMetricsCollector) BlockedCounter added in v1.0.6 

func (c *TestMetricsCollector) BlockedCounter(target string) (logr.Counter, error)

func (*TestMetricsCollector) DroppedCounter added in v1.0.6 

func (c *TestMetricsCollector) DroppedCounter(target string) (logr.Counter, error)

func (*TestMetricsCollector) ErrorCounter added in v1.0.6 

func (c *TestMetricsCollector) ErrorCounter(target string) (logr.Counter, error)

func (*TestMetricsCollector) Get added in v1.0.6 

func (c *TestMetricsCollector) Get(target string) TestMetrics

func (*TestMetricsCollector) LoggedCounter added in v1.0.6 

func (c *TestMetricsCollector) LoggedCounter(target string) (logr.Counter, error)

func (*TestMetricsCollector) QueueSizeGauge added in v1.0.6 

func (c *TestMetricsCollector) QueueSizeGauge(target string) (logr.Gauge, error)

Source Files

View all Source files

Directories

Path Synopsis
cmd
simple
testapp1

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.