testmessagebus

Documentation

Index

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

Types

type TapeRecord

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

type TestMessageBus

type TestMessageBus struct {
	PulseAccessor pulse.Accessor
	ReadingTape   []TapeRecord
	WritingTape   []TapeRecord
	// contains filtered or unexported fields
}

func NewTestMessageBus

func NewTestMessageBus(t *testing.T) *TestMessageBus

func (*TestMessageBus) Lock

func (mb *TestMessageBus) Lock(context.Context)

func (*TestMessageBus) MustRegister

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

func (*TestMessageBus) NewPlayer

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

func (*TestMessageBus) NewRecorder

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

func (*TestMessageBus) OnPulse

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

func (*TestMessageBus) ReRegister

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

func (*TestMessageBus) Register

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

func (*TestMessageBus) Send

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

func (*TestMessageBus) Unlock

func (mb *TestMessageBus) Unlock(context.Context)

func (*TestMessageBus) WriteTape

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