mock

package

v1.2.3 Latest Latest Go to latest Published: Apr 22, 2016 License: Apache-2.0, Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Messenger struct {
	mock.Mock
	// contains filtered or unexported fields
}

Messenger is a messenger that returns error on every operation.

func NewMessenger() *Messenger

NewMessenger returns a mocked messenger used for testing.

func (m *Messenger) Install(handler messenger.MessageHandler, msg proto.Message) error

Install is a mocked implementation.

func (m *Messenger) Recv(from *upid.UPID, msg proto.Message)

Recv receives a upid and a message, it will dispatch the message to its handler with the upid. This is for testing.

func (m *Messenger) Route(ctx context.Context, upid *upid.UPID, msg proto.Message) error

func (m *Messenger) Send(ctx context.Context, upid *upid.UPID, msg proto.Message) error

Send is a mocked implementation.

func (m *Messenger) Start() error

Start is a mocked implementation.

func (m *Messenger) Stop() error

Stop is a mocked implementation.

func (m *Messenger) UPID() upid.UPID

UPID is a mocked implementation.