test

Documentation

Index

• func DoSomeLogging(cfg DoSomeLoggingCfg) (logged int32, filtered int32)
• func StringRnd(length int) string
• type Buffer
  • func (b *Buffer) Bytes() []byte
  • func (b *Buffer) String() string
  • func (b *Buffer) Write(data []byte) (int, error)
• type DoSomeLoggingCfg
• type FailingTarget
  • func NewFailingTarget(filter logr.Filter, formatter logr.Formatter) *FailingTarget
  • func (ft *FailingTarget) Write(rec *logr.LogRec) error
• type SlowTarget
  • func NewSlowTarget(filter logr.Filter, formatter logr.Formatter, out io.Writer, maxQueue int) *SlowTarget
  • func (st *SlowTarget) Write(rec *logr.LogRec) error
• type TestCounter
  • func (c *TestCounter) Add(val float64)
  • func (c *TestCounter) Inc()
• type TestGauge
  • func (g *TestGauge) Add(val float64)
  • func (g *TestGauge) Set(val float64)
  • func (g *TestGauge) Sub(val float64)
• type TestMetrics
• type TestMetricsCollector
  • func NewTestMetricsCollector() *TestMetricsCollector
  • func (c *TestMetricsCollector) BlockedCounter(target string) (logr.Counter, error)
  • func (c *TestMetricsCollector) DroppedCounter(target string) (logr.Counter, error)
  • func (c *TestMetricsCollector) ErrorCounter(target string) (logr.Counter, error)
  • func (c *TestMetricsCollector) Get(target string) TestMetrics
  • func (c *TestMetricsCollector) LoggedCounter(target string) (logr.Counter, error)
  • func (c *TestMetricsCollector) QueueSizeGauge(target string) (logr.Gauge, error)

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

type FailingTarget struct {
	logr.Basic
}

FailingTarget is a test target that always fails.

func NewFailingTarget

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

NewFailingTarget creates a target that always fails.

func (*FailingTarget) Write

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

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

func (*TestCounter) Add

func (c *TestCounter) Add(val float64)

func (*TestCounter) Inc

func (c *TestCounter) Inc()

type TestGauge

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

func (*TestGauge) Add

func (g *TestGauge) Add(val float64)

func (*TestGauge) Set

func (g *TestGauge) Set(val float64)

func (*TestGauge) Sub

func (g *TestGauge) Sub(val float64)

type TestMetrics

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

type TestMetricsCollector

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

func NewTestMetricsCollector

func NewTestMetricsCollector() *TestMetricsCollector

func (*TestMetricsCollector) BlockedCounter

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

func (*TestMetricsCollector) DroppedCounter

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

func (*TestMetricsCollector) ErrorCounter

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

func (*TestMetricsCollector) Get

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

func (*TestMetricsCollector) LoggedCounter

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

func (*TestMetricsCollector) QueueSizeGauge

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