mocks

Documentation

Overview

Code generated by mockery v2.13.1. DO NOT EDIT. note that nats.go will need to be added to the end of the nats import

Code generated by mockery v2.13.1. DO NOT EDIT. note that nats.go will need to be added to the end of the nats import

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