msgmocks

Documentation

Index

• type CommandMessagePublisher
  • func (_m *CommandMessagePublisher) PublishCommand(ctx context.Context, replyChannel string, command core.Command, ...) error
• type Consumer
  • func (_m *Consumer) Close(ctx context.Context) error
  • func (_m *Consumer) Listen(ctx context.Context, channel string, consumer msg.ReceiveMessageFunc) error
• type EntityEventMessagePublisher
  • func (_m *EntityEventMessagePublisher) PublishEntityEvents(ctx context.Context, entity core.Entity, options ...msg.MessageOption) error
• type EventMessagePublisher
  • func (_m *EventMessagePublisher) PublishEvent(ctx context.Context, event core.Event, options ...msg.MessageOption) error
• type MessagePublisher
  • func (_m *MessagePublisher) Publish(ctx context.Context, message msg.Message) error
• type MessageReceiver
  • func (_m *MessageReceiver) ReceiveMessage(_a0 context.Context, _a1 msg.Message) error
• type MessageSubscriber
  • func (_m *MessageSubscriber) Subscribe(channel string, receiver msg.MessageReceiver)
• type Producer
  • func (_m *Producer) Close(ctx context.Context) error
  • func (_m *Producer) Send(ctx context.Context, channel string, message msg.Message) error
• type ReplyMessagePublisher
  • func (_m *ReplyMessagePublisher) PublishReply(ctx context.Context, reply core.Reply, options ...msg.MessageOption) error

Types

type CommandMessagePublisher

type CommandMessagePublisher struct {
	mock.Mock
}

CommandMessagePublisher is an autogenerated mock type for the CommandMessagePublisher type

func (*CommandMessagePublisher) PublishCommand

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 (*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 EntityEventMessagePublisher

type EntityEventMessagePublisher struct {
	mock.Mock
}

EntityEventMessagePublisher is an autogenerated mock type for the EntityEventMessagePublisher type

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 EventMessagePublisher

type EventMessagePublisher struct {
	mock.Mock
}

EventMessagePublisher is an autogenerated mock type for the EventMessagePublisher type

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 MessagePublisher

type MessagePublisher struct {
	mock.Mock
}

MessagePublisher is an autogenerated mock type for the MessagePublisher type

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

type MessageReceiver struct {
	mock.Mock
}

MessageReceiver is an autogenerated mock type for the MessageReceiver type

func (*MessageReceiver) ReceiveMessage

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 (*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 (*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 ReplyMessagePublisher

type ReplyMessagePublisher struct {
	mock.Mock
}

ReplyMessagePublisher is an autogenerated mock type for the ReplyMessagePublisher type

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