mocks

Documentation

Index

• type MessageClient
  • func NewMessageClient(t mockConstructorTestingTNewMessageClient) *MessageClient
  • func (_m *MessageClient) Connect() error
  • func (_m *MessageClient) Disconnect() error
  • func (_m *MessageClient) Publish(message types.MessageEnvelope, topic string) error
  • func (_m *MessageClient) Request(message types.MessageEnvelope, requestTopic string, responseTopicPrefix string, ...) (*types.MessageEnvelope, error)
  • func (_m *MessageClient) Subscribe(topics []types.TopicChannel, messageErrors chan error) error
  • func (_m *MessageClient) Unsubscribe(topics ...string) error

Types

type MessageClient

type MessageClient struct {
	mock.Mock
}

MessageClient is an autogenerated mock type for the MessageClient type

func NewMessageClient

func NewMessageClient(t mockConstructorTestingTNewMessageClient) *MessageClient

NewMessageClient creates a new instance of MessageClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MessageClient) Connect

func (_m *MessageClient) Connect() error

Connect provides a mock function with given fields:

func (*MessageClient) Disconnect

func (_m *MessageClient) Disconnect() error

Disconnect provides a mock function with given fields:

func (*MessageClient) Publish

func (_m *MessageClient) Publish(message types.MessageEnvelope, topic string) error

Publish provides a mock function with given fields: message, topic

func (*MessageClient) Request

func (_m *MessageClient) Request(message types.MessageEnvelope, requestTopic string, responseTopicPrefix string, timeout time.Duration) (*types.MessageEnvelope, error)

Request provides a mock function with given fields: message, requestTopic, responseTopicPrefix, timeout

func (*MessageClient) Subscribe

func (_m *MessageClient) Subscribe(topics []types.TopicChannel, messageErrors chan error) error

Subscribe provides a mock function with given fields: topics, messageErrors

func (*MessageClient) Unsubscribe

func (_m *MessageClient) Unsubscribe(topics ...string) error

Unsubscribe provides a mock function with given fields: topics