mocks

Documentation

Index

• type EventConnection
  • func NewEventConnection(t mockConstructorTestingTNewEventConnection) *EventConnection
  • func (_m *EventConnection) Listen(_a0 context.Context, _a1 map[common.EventType]messaging2.EventHandlerFunc, ...) error
  • func (_m *EventConnection) ListenWithConcurrentWorkers(ctx context.Context, m map[common.EventType]messaging2.EventHandlerFunc, ...) error
  • func (_m *EventConnection) Publish(ce event.Event) error
  • func (_m *EventConnection) Request(requestCe event.Event, responseEventTypes []common.EventType) (messaging2.EventResponsePromise, error)
  • func (_m *EventConnection) WaitForResponse(transactionID common.TransactionID, responseEventTypes []common.EventType) (messaging2.EventResponsePromise, error)
• type ReplyWriter
  • func NewReplyWriter(t mockConstructorTestingTNewReplyWriter) *ReplyWriter
  • func (_m *ReplyWriter) Write(_a0 event.Event) error

Types

type EventConnection

type EventConnection struct {
	mock.Mock
}

EventConnection is an autogenerated mock type for the EventConnection type

func NewEventConnection

func NewEventConnection(t mockConstructorTestingTNewEventConnection) *EventConnection

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

func (*EventConnection) Listen

func (_m *EventConnection) Listen(_a0 context.Context, _a1 map[common.EventType]messaging2.EventHandlerFunc, _a2 *sync.WaitGroup) error

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

func (*EventConnection) ListenWithConcurrentWorkers

func (_m *EventConnection) ListenWithConcurrentWorkers(ctx context.Context, m map[common.EventType]messaging2.EventHandlerFunc, wg *sync.WaitGroup, channelBufferLen uint, workerCount uint) error

ListenWithConcurrentWorkers provides a mock function with given fields: ctx, m, wg, channelBufferLen, workerCount

func (*EventConnection) Publish

func (_m *EventConnection) Publish(ce event.Event) error

Publish provides a mock function with given fields: ce

func (*EventConnection) Request

func (_m *EventConnection) Request(requestCe event.Event, responseEventTypes []common.EventType) (messaging2.EventResponsePromise, error)

Request provides a mock function with given fields: requestCe, responseEventTypes

func (*EventConnection) WaitForResponse

func (_m *EventConnection) WaitForResponse(transactionID common.TransactionID, responseEventTypes []common.EventType) (messaging2.EventResponsePromise, error)

WaitForResponse provides a mock function with given fields: transactionID, responseEventTypes

type ReplyWriter

type ReplyWriter struct {
	mock.Mock
}

ReplyWriter is an autogenerated mock type for the ReplyWriter type

func NewReplyWriter

func NewReplyWriter(t mockConstructorTestingTNewReplyWriter) *ReplyWriter

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

func (*ReplyWriter) Write

func (_m *ReplyWriter) Write(_a0 event.Event) error

Write provides a mock function with given fields: _a0