msgmocks

package
v1.2.19 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 24, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CommandMessagePublisher

type CommandMessagePublisher struct {
	mock.Mock
}

CommandMessagePublisher is an autogenerated mock type for the CommandMessagePublisher type

func NewCommandMessagePublisher

func NewCommandMessagePublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *CommandMessagePublisher

NewCommandMessagePublisher creates a new instance of CommandMessagePublisher. 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 (*CommandMessagePublisher) PublishCommand added in v1.2.17

func (_m *CommandMessagePublisher) PublishCommand(ctx context.Context, replyChannel string, command core.Command, options ...msg.MessageOption) error

PublishCommand provides a mock function with given fields: ctx, replyChannel, command, options

type Consumer

type Consumer struct {
	mock.Mock
}

Consumer is an autogenerated mock type for the Consumer type

func NewConsumer

func NewConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *Consumer

NewConsumer creates a new instance of Consumer. 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 (*Consumer) Close

func (_m *Consumer) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*Consumer) Listen

func (_m *Consumer) Listen(ctx context.Context, channel string, consumer msg.ReceiveMessageFunc) error

Listen provides a mock function with given fields: ctx, channel, consumer

type DomainEvent

type DomainEvent struct {
	mock.Mock
}

DomainEvent is an autogenerated mock type for the DomainEvent type

func NewDomainEvent

func NewDomainEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *DomainEvent

NewDomainEvent creates a new instance of DomainEvent. 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 (*DomainEvent) DestinationChannel

func (_m *DomainEvent) DestinationChannel() string

DestinationChannel provides a mock function with given fields:

func (*DomainEvent) EventName

func (_m *DomainEvent) EventName() string

EventName provides a mock function with given fields:

type EntityEvent

type EntityEvent struct {
	mock.Mock
}

EntityEvent is an autogenerated mock type for the EntityEvent type

func NewEntityEvent

func NewEntityEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *EntityEvent

NewEntityEvent creates a new instance of EntityEvent. 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 (*EntityEvent) EntityID

func (_m *EntityEvent) EntityID() string

EntityID provides a mock function with given fields:

func (*EntityEvent) EntityName

func (_m *EntityEvent) EntityName() string

EntityName provides a mock function with given fields:

func (*EntityEvent) Event

func (_m *EntityEvent) Event() core.Event

Event provides a mock function with given fields:

func (*EntityEvent) Headers

func (_m *EntityEvent) Headers() msg.Headers

Headers provides a mock function with given fields:

type EntityEventMessagePublisher

type EntityEventMessagePublisher struct {
	mock.Mock
}

EntityEventMessagePublisher is an autogenerated mock type for the EntityEventMessagePublisher type

func NewEntityEventMessagePublisher

func NewEntityEventMessagePublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *EntityEventMessagePublisher

NewEntityEventMessagePublisher creates a new instance of EntityEventMessagePublisher. 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 (*EntityEventMessagePublisher) PublishEntityEvents

func (_m *EntityEventMessagePublisher) PublishEntityEvents(ctx context.Context, entity core.Entity, options ...msg.MessageOption) error

PublishEntityEvents provides a mock function with given fields: ctx, entity, options

type Event

type Event struct {
	mock.Mock
}

Event is an autogenerated mock type for the Event type

func NewEvent

func NewEvent(t interface {
	mock.TestingT
	Cleanup(func())
}) *Event

NewEvent creates a new instance of Event. 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 (*Event) Event

func (_m *Event) Event() core.Event

Event provides a mock function with given fields:

func (*Event) Headers

func (_m *Event) Headers() msg.Headers

Headers provides a mock function with given fields:

type EventMessagePublisher

type EventMessagePublisher struct {
	mock.Mock
}

EventMessagePublisher is an autogenerated mock type for the EventMessagePublisher type

func NewEventMessagePublisher

func NewEventMessagePublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *EventMessagePublisher

NewEventMessagePublisher creates a new instance of EventMessagePublisher. 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 (*EventMessagePublisher) PublishEvent

func (_m *EventMessagePublisher) PublishEvent(ctx context.Context, event core.Event, options ...msg.MessageOption) error

PublishEvent provides a mock function with given fields: ctx, event, options

type Message

type Message struct {
	mock.Mock
}

Message is an autogenerated mock type for the Message type

func NewMessage

func NewMessage(t interface {
	mock.TestingT
	Cleanup(func())
}) *Message

NewMessage creates a new instance of Message. 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 (*Message) Headers

func (_m *Message) Headers() msg.Headers

Headers provides a mock function with given fields:

func (*Message) ID

func (_m *Message) ID() string

ID provides a mock function with given fields:

func (*Message) Payload

func (_m *Message) Payload() []byte

Payload provides a mock function with given fields:

type MessagePublisher

type MessagePublisher struct {
	mock.Mock
}

MessagePublisher is an autogenerated mock type for the MessagePublisher type

func NewMessagePublisher

func NewMessagePublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessagePublisher

NewMessagePublisher creates a new instance of MessagePublisher. 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 (*MessagePublisher) Publish

func (_m *MessagePublisher) Publish(ctx context.Context, message msg.Message) error

Publish provides a mock function with given fields: ctx, message

type MessageReceiver added in v1.2.19

type MessageReceiver struct {
	mock.Mock
}

MessageReceiver is an autogenerated mock type for the MessageReceiver type

func NewMessageReceiver added in v1.2.19

func NewMessageReceiver(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageReceiver

NewMessageReceiver creates a new instance of MessageReceiver. 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 (*MessageReceiver) ReceiveMessage added in v1.2.19

func (_m *MessageReceiver) ReceiveMessage(_a0 context.Context, _a1 msg.Message) error

ReceiveMessage provides a mock function with given fields: _a0, _a1

type MessageSubscriber

type MessageSubscriber struct {
	mock.Mock
}

MessageSubscriber is an autogenerated mock type for the MessageSubscriber type

func NewMessageSubscriber

func NewMessageSubscriber(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageSubscriber

NewMessageSubscriber creates a new instance of MessageSubscriber. 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 (*MessageSubscriber) Subscribe

func (_m *MessageSubscriber) Subscribe(channel string, receiver msg.MessageReceiver)

Subscribe provides a mock function with given fields: channel, receiver

type Producer

type Producer struct {
	mock.Mock
}

Producer is an autogenerated mock type for the Producer type

func NewProducer

func NewProducer(t interface {
	mock.TestingT
	Cleanup(func())
}) *Producer

NewProducer creates a new instance of Producer. 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 (*Producer) Close

func (_m *Producer) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*Producer) Send

func (_m *Producer) Send(ctx context.Context, channel string, message msg.Message) error

Send provides a mock function with given fields: ctx, channel, message

type Reply

type Reply struct {
	mock.Mock
}

Reply is an autogenerated mock type for the Reply type

func NewReply

func NewReply(t interface {
	mock.TestingT
	Cleanup(func())
}) *Reply

NewReply creates a new instance of Reply. 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 (*Reply) Headers

func (_m *Reply) Headers() msg.Headers

Headers provides a mock function with given fields:

func (*Reply) Reply

func (_m *Reply) Reply() core.Reply

Reply provides a mock function with given fields:

type ReplyMessagePublisher

type ReplyMessagePublisher struct {
	mock.Mock
}

ReplyMessagePublisher is an autogenerated mock type for the ReplyMessagePublisher type

func NewReplyMessagePublisher

func NewReplyMessagePublisher(t interface {
	mock.TestingT
	Cleanup(func())
}) *ReplyMessagePublisher

NewReplyMessagePublisher creates a new instance of ReplyMessagePublisher. 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 (*ReplyMessagePublisher) PublishReply

func (_m *ReplyMessagePublisher) PublishReply(ctx context.Context, reply core.Reply, options ...msg.MessageOption) error

PublishReply provides a mock function with given fields: ctx, reply, options

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL