msgmocks

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2021 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 Command 

type Command struct {
	mock.Mock
}

Command is an autogenerated mock type for the Command type

func (*Command) Command 

func (_m *Command) Command() core.Command

Command provides a mock function with given fields:

func (*Command) Headers 

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

Headers provides a mock function with given fields:

type CommandDispatcherOption 

type CommandDispatcherOption struct {
	mock.Mock
}

CommandDispatcherOption is an autogenerated mock type for the CommandDispatcherOption type

func (*CommandDispatcherOption) Execute 

func (_m *CommandDispatcherOption) Execute(consumer *msg.CommandDispatcher)

Execute provides a mock function with given fields: consumer

type CommandHandlerFunc 

type CommandHandlerFunc struct {
	mock.Mock
}

CommandHandlerFunc is an autogenerated mock type for the CommandHandlerFunc type

func (*CommandHandlerFunc) Execute 

func (_m *CommandHandlerFunc) Execute(_a0 context.Context, _a1 msg.Command) ([]msg.Reply, error)

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

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 DomainCommand 

type DomainCommand struct {
	mock.Mock
}

DomainCommand is an autogenerated mock type for the DomainCommand type

func (*DomainCommand) CommandName 

func (_m *DomainCommand) CommandName() string

CommandName provides a mock function with given fields:

func (*DomainCommand) DestinationChannel 

func (_m *DomainCommand) DestinationChannel() string

DestinationChannel provides a mock function with given fields:

type DomainEvent 

type DomainEvent struct {
	mock.Mock
}

DomainEvent is an autogenerated mock type for the DomainEvent type

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

type EntityEventDispatcherOption struct {
	mock.Mock
}

EntityEventDispatcherOption is an autogenerated mock type for the EntityEventDispatcherOption type

func (*EntityEventDispatcherOption) Execute 

func (_m *EntityEventDispatcherOption) Execute(consumer *msg.EntityEventDispatcher)

Execute provides a mock function with given fields: consumer

type EntityEventHandlerFunc 

type EntityEventHandlerFunc struct {
	mock.Mock
}

EntityEventHandlerFunc is an autogenerated mock type for the EntityEventHandlerFunc type

func (*EntityEventHandlerFunc) Execute 

func (_m *EntityEventHandlerFunc) Execute(_a0 context.Context, _a1 msg.EntityEvent) error

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

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 Event 

type Event struct {
	mock.Mock
}

Event is an autogenerated mock type for the Event type

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 EventDispatcherOption 

type EventDispatcherOption struct {
	mock.Mock
}

EventDispatcherOption is an autogenerated mock type for the EventDispatcherOption type

func (*EventDispatcherOption) Execute 

func (_m *EventDispatcherOption) Execute(consumer *msg.EventDispatcher)

Execute provides a mock function with given fields: consumer

type EventHandlerFunc 

type EventHandlerFunc struct {
	mock.Mock
}

EventHandlerFunc is an autogenerated mock type for the EventHandlerFunc type

func (*EventHandlerFunc) Execute 

func (_m *EventHandlerFunc) Execute(_a0 context.Context, _a1 msg.Event) error

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

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 Message 

type Message struct {
	mock.Mock
}

Message is an autogenerated mock type for the Message type

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

type PublisherOption struct {
	mock.Mock
}

PublisherOption is an autogenerated mock type for the PublisherOption type

func (*PublisherOption) Execute 

func (_m *PublisherOption) Execute(_a0 *msg.Publisher)

Execute provides a mock function with given fields: _a0

type ReceiveMessageFunc 

type ReceiveMessageFunc struct {
	mock.Mock
}

ReceiveMessageFunc is an autogenerated mock type for the ReceiveMessageFunc type

func (*ReceiveMessageFunc) Execute 

func (_m *ReceiveMessageFunc) Execute(_a0 context.Context, _a1 msg.Message) error

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

type Reply 

type Reply struct {
	mock.Mock
}

Reply is an autogenerated mock type for the Reply type

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

type SubscriberOption 

type SubscriberOption struct {
	mock.Mock
}

SubscriberOption is an autogenerated mock type for the SubscriberOption type

func (*SubscriberOption) Execute 

func (_m *SubscriberOption) Execute(_a0 *msg.Subscriber)

Execute provides a mock function with given fields: _a0

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.