stubs

Documentation

Overview

Package stubs contains stubs for the eventer package

Index

• type StubEventer
  • func (*StubEventer) Close() error
  • func (*StubEventer) ConsumeEvents(...interfaces.Consumer)
  • func (s *StubEventer) Publish(topic string, messages ...*message.Message) error
  • func (*StubEventer) Register(string, message.NoPublishHandlerFunc, ...message.HandlerMiddleware)
  • func (*StubEventer) Run(context.Context) error
  • func (*StubEventer) Running() chan struct{}

Types

type StubEventer

type StubEventer struct {
	Topics []string
	Sent   []*message.Message
}

StubEventer is an eventer that's useful for testing.

func (*StubEventer) Close

func (*StubEventer) Close() error

Close implements events.Interface.

func (*StubEventer) ConsumeEvents

func (*StubEventer) ConsumeEvents(...interfaces.Consumer)

ConsumeEvents implements events.Interface.

func (*StubEventer) Publish

func (s *StubEventer) Publish(topic string, messages ...*message.Message) error

Publish implements events.Interface.

func (*StubEventer) Register

func (*StubEventer) Register(string, message.NoPublishHandlerFunc, ...message.HandlerMiddleware)

Register implements events.Interface.

func (*StubEventer) Run

func (*StubEventer) Run(context.Context) error

Run implements events.Interface.

func (*StubEventer) Running

func (*StubEventer) Running() chan struct{}

Running implements events.Interface.