log

Documentation

Index

• type LogListener
  • func NewLogListener() *LogListener
  • func (l *LogListener) AssertLastLogLine(t *testing.T, key string, value interface{})
  • func (l *LogListener) Close() error
  • func (l *LogListener) Listen(key string, value interface{}, timeout time.Duration) error
  • func (l *LogListener) Write(p []byte) (n int, err error)

Types

type LogListener

type LogListener struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewLogListener

func NewLogListener() *LogListener

func (*LogListener) AssertLastLogLine

func (l *LogListener) AssertLastLogLine(t *testing.T, key string, value interface{})

Assert if the last logline has the key value pair

func (*LogListener) Close

func (l *LogListener) Close() error

func (*LogListener) Listen

func (l *LogListener) Listen(key string, value interface{}, timeout time.Duration) error

listen to a JSON stream until a key/value pair is found this function is not thread safe and is only intended for one listener at a time.

func (*LogListener) Write

func (l *LogListener) Write(p []byte) (n int, err error)