mocks

Documentation

Index

• type Connection
  • func NewConnection(t mockConstructorTestingTNewConnection) *Connection
  • func (_m *Connection) Drain() error
  • func (_m *Connection) PublishMsg(_a0 *nats.Msg) error
  • func (_m *Connection) QueueSubscribe(_a0 string, _a1 string, _a2 nats.MsgHandler) (*nats.Subscription, error)
• type MarshallerUnmarshaller
  • func NewMarshallerUnmarshaller(t mockConstructorTestingTNewMarshallerUnmarshaller) *MarshallerUnmarshaller
  • func (_m *MarshallerUnmarshaller) Marshal(v types.MessageEnvelope, publishTopic string) (*nats.Msg, error)
  • func (_m *MarshallerUnmarshaller) Unmarshal(msg *nats.Msg, v *types.MessageEnvelope) error

Types

type Connection

type Connection struct {
	mock.Mock
}

Connection is an autogenerated mock type for the Connection type

func NewConnection

func NewConnection(t mockConstructorTestingTNewConnection) *Connection

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

func (*Connection) Drain

func (_m *Connection) Drain() error

Drain provides a mock function with given fields:

func (*Connection) PublishMsg

func (_m *Connection) PublishMsg(_a0 *nats.Msg) error

PublishMsg provides a mock function with given fields: _a0

func (*Connection) QueueSubscribe

func (_m *Connection) QueueSubscribe(_a0 string, _a1 string, _a2 nats.MsgHandler) (*nats.Subscription, error)

QueueSubscribe provides a mock function with given fields: _a0, _a1, _a2

type MarshallerUnmarshaller

type MarshallerUnmarshaller struct {
	mock.Mock
}

MarshallerUnmarshaller is an autogenerated mock type for the MarshallerUnmarshaller type

func NewMarshallerUnmarshaller

func NewMarshallerUnmarshaller(t mockConstructorTestingTNewMarshallerUnmarshaller) *MarshallerUnmarshaller

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

func (*MarshallerUnmarshaller) Marshal

func (_m *MarshallerUnmarshaller) Marshal(v types.MessageEnvelope, publishTopic string) (*nats.Msg, error)

Marshal provides a mock function with given fields: v, publishTopic

func (*MarshallerUnmarshaller) Unmarshal

func (_m *MarshallerUnmarshaller) Unmarshal(msg *nats.Msg, v *types.MessageEnvelope) error

Unmarshal provides a mock function with given fields: msg, v