emittest

Documentation

Index

• func Nop(_ context.Context, _ []byte, _ map[string]any) error
• type Call
• type Sink
  • func NewSink(opts ...SinkOpt) *Sink
  • func (s *Sink) ExpectCall(t *testing.T, expected []byte, attrs map[string]any)
  • func (s *Sink) ExpectCalls(t *testing.T, expected ...*Call)
  • func (s *Sink) ExpectNoCalls(t *testing.T)
  • func (s *Sink) ExpectNoCallsUntil(t *testing.T, d time.Duration)
  • func (s *Sink) ExpectToken(t *testing.T, expected []byte)
  • func (s *Sink) ExpectTokens(t *testing.T, expected ...[]byte)
  • func (s *Sink) NextCall(t *testing.T) ([]byte, map[string]any)
  • func (s *Sink) NextToken(t *testing.T) []byte
  • func (s *Sink) NextTokens(t *testing.T, n int) [][]byte
• type SinkOpt
  • func WithCallBuffer(n int) SinkOpt
  • func WithTimeout(d time.Duration) SinkOpt

Functions

func Nop

func Nop(_ context.Context, _ []byte, _ map[string]any) error

Types

type Call

type Call struct {
	Token []byte
	Attrs map[string]any
}

type Sink

type Sink struct {
	emit.Callback
	// contains filtered or unexported fields
}

func NewSink

func NewSink(opts ...SinkOpt) *Sink

func (*Sink) ExpectCall

func (s *Sink) ExpectCall(t *testing.T, expected []byte, attrs map[string]any)

func (*Sink) ExpectCalls

func (s *Sink) ExpectCalls(t *testing.T, expected ...*Call)

func (*Sink) ExpectNoCalls

func (s *Sink) ExpectNoCalls(t *testing.T)

func (*Sink) ExpectNoCallsUntil

func (s *Sink) ExpectNoCallsUntil(t *testing.T, d time.Duration)

func (*Sink) ExpectToken

func (s *Sink) ExpectToken(t *testing.T, expected []byte)

func (*Sink) ExpectTokens

func (s *Sink) ExpectTokens(t *testing.T, expected ...[]byte)

func (*Sink) NextCall

func (s *Sink) NextCall(t *testing.T) ([]byte, map[string]any)

func (*Sink) NextToken

func (s *Sink) NextToken(t *testing.T) []byte

func (*Sink) NextTokens

func (s *Sink) NextTokens(t *testing.T, n int) [][]byte

type SinkOpt

type SinkOpt func(*sinkCfg)

func WithCallBuffer

func WithCallBuffer(n int) SinkOpt

func WithTimeout

func WithTimeout(d time.Duration) SinkOpt