testmessagebus

Documentation

Index

• type TapeRecord
• type TestMessageBus
  • func NewTestMessageBus(t *testing.T) *TestMessageBus
  • func (mb *TestMessageBus) MustRegister(p core.MessageType, handler core.MessageHandler)
  • func (mb *TestMessageBus) NewPlayer(ctx context.Context, reader io.Reader) (core.MessageBus, error)
  • func (mb *TestMessageBus) NewRecorder(ctx context.Context, currentPulse core.Pulse) (core.MessageBus, error)
  • func (mb *TestMessageBus) OnPulse(context.Context, core.Pulse) error
  • func (mb *TestMessageBus) ReRegister(p core.MessageType, handler core.MessageHandler)
  • func (mb *TestMessageBus) Register(p core.MessageType, handler core.MessageHandler) error
  • func (mb *TestMessageBus) Send(ctx context.Context, m core.Message, _ *core.MessageSendOptions) (core.Reply, error)
  • func (mb *TestMessageBus) WriteTape(ctx context.Context, writer io.Writer) error

Types

type TapeRecord

type TapeRecord struct {
	Message core.Message
	Reply   core.Reply
	Error   error
}

type TestMessageBus

type TestMessageBus struct {
	PulseStorage core.PulseStorage
	ReadingTape  []TapeRecord
	WritingTape  []TapeRecord
	// contains filtered or unexported fields
}

func NewTestMessageBus

func NewTestMessageBus(t *testing.T) *TestMessageBus

func (*TestMessageBus) MustRegister

func (mb *TestMessageBus) MustRegister(p core.MessageType, handler core.MessageHandler)

func (*TestMessageBus) NewPlayer

func (mb *TestMessageBus) NewPlayer(ctx context.Context, reader io.Reader) (core.MessageBus, error)

func (*TestMessageBus) NewRecorder

func (mb *TestMessageBus) NewRecorder(ctx context.Context, currentPulse core.Pulse) (core.MessageBus, error)

func (*TestMessageBus) OnPulse

func (mb *TestMessageBus) OnPulse(context.Context, core.Pulse) error

func (*TestMessageBus) ReRegister

func (mb *TestMessageBus) ReRegister(p core.MessageType, handler core.MessageHandler)

func (*TestMessageBus) Register

func (mb *TestMessageBus) Register(p core.MessageType, handler core.MessageHandler) error

func (*TestMessageBus) Send

func (mb *TestMessageBus) Send(ctx context.Context, m core.Message, _ *core.MessageSendOptions) (core.Reply, error)

func (*TestMessageBus) WriteTape

func (mb *TestMessageBus) WriteTape(ctx context.Context, writer io.Writer) error