mocks

Documentation

Index

• type MessageClient
  • func NewMessageClient(t interface{ ... }) *MessageClient
  • func (_m *MessageClient) Connect() error
  • func (_m *MessageClient) Disconnect() error
  • func (_m *MessageClient) Publish(message types.MessageEnvelope, topic string) error
  • func (_m *MessageClient) PublishBinaryData(data []byte, topic string) error
  • func (_m *MessageClient) PublishWithSizeLimit(message types.MessageEnvelope, topic string, limit int64) 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) SubscribeBinaryData(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 interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

func (*MessageClient) Connect

func (_m *MessageClient) Connect() error

Connect provides a mock function with no fields

func (*MessageClient) Disconnect

func (_m *MessageClient) Disconnect() error

Disconnect provides a mock function with no 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) PublishBinaryData

func (_m *MessageClient) PublishBinaryData(data []byte, topic string) error

PublishBinaryData provides a mock function with given fields: data, topic

func (*MessageClient) PublishWithSizeLimit

func (_m *MessageClient) PublishWithSizeLimit(message types.MessageEnvelope, topic string, limit int64) error

PublishWithSizeLimit provides a mock function with given fields: message, topic, limit

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) SubscribeBinaryData

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

SubscribeBinaryData 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