Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
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 ¶
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
Source Files