Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockMessageBus
- func (m *MockMessageBus) Close()
- func (m *MockMessageBus) EXPECT() *MockMessageBusMockRecorder
- func (m *MockMessageBus) Publish(topic msgbus.Topic, payload interface{})
- func (m *MockMessageBus) PublishSafe(topic msgbus.Topic, payload interface{})
- func (m *MockMessageBus) PublishSync(topic msgbus.Topic, payload interface{})
- func (m *MockMessageBus) Register(topic msgbus.Topic, sub msgbus.Subscriber)
- func (m *MockMessageBus) UnRegister(topic msgbus.Topic, sub msgbus.Subscriber)
- type MockMessageBusMockRecorder
- func (mr *MockMessageBusMockRecorder) Close() *gomock.Call
- func (mr *MockMessageBusMockRecorder) Publish(topic, payload interface{}) *gomock.Call
- func (mr *MockMessageBusMockRecorder) PublishSafe(topic, payload interface{}) *gomock.Call
- func (mr *MockMessageBusMockRecorder) PublishSync(topic, payload interface{}) *gomock.Call
- func (mr *MockMessageBusMockRecorder) Register(topic, sub interface{}) *gomock.Call
- func (mr *MockMessageBusMockRecorder) UnRegister(topic, sub interface{}) *gomock.Call
- type MockSubscriber
- type MockSubscriberMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockMessageBus ¶
type MockMessageBus struct {
// contains filtered or unexported fields
}
MockMessageBus is a mock of MessageBus interface.
func NewMockMessageBus ¶
func NewMockMessageBus(ctrl *gomock.Controller) *MockMessageBus
NewMockMessageBus creates a new mock instance.
func (*MockMessageBus) EXPECT ¶
func (m *MockMessageBus) EXPECT() *MockMessageBusMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMessageBus) Publish ¶
func (m *MockMessageBus) Publish(topic msgbus.Topic, payload interface{})
Publish mocks base method.
func (*MockMessageBus) PublishSafe ¶
func (m *MockMessageBus) PublishSafe(topic msgbus.Topic, payload interface{})
PublishSafe mocks base method.
func (*MockMessageBus) PublishSync ¶ added in v2.2.0
func (m *MockMessageBus) PublishSync(topic msgbus.Topic, payload interface{})
PublishSync mocks base method.
func (*MockMessageBus) Register ¶
func (m *MockMessageBus) Register(topic msgbus.Topic, sub msgbus.Subscriber)
Register mocks base method.
func (*MockMessageBus) UnRegister ¶ added in v2.1.0
func (m *MockMessageBus) UnRegister(topic msgbus.Topic, sub msgbus.Subscriber)
UnRegister mocks base method.
type MockMessageBusMockRecorder ¶
type MockMessageBusMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageBusMockRecorder is the mock recorder for MockMessageBus.
func (*MockMessageBusMockRecorder) Close ¶
func (mr *MockMessageBusMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockMessageBusMockRecorder) Publish ¶
func (mr *MockMessageBusMockRecorder) Publish(topic, payload interface{}) *gomock.Call
Publish indicates an expected call of Publish.
func (*MockMessageBusMockRecorder) PublishSafe ¶
func (mr *MockMessageBusMockRecorder) PublishSafe(topic, payload interface{}) *gomock.Call
PublishSafe indicates an expected call of PublishSafe.
func (*MockMessageBusMockRecorder) PublishSync ¶ added in v2.2.0
func (mr *MockMessageBusMockRecorder) PublishSync(topic, payload interface{}) *gomock.Call
PublishSync indicates an expected call of PublishSync.
func (*MockMessageBusMockRecorder) Register ¶
func (mr *MockMessageBusMockRecorder) Register(topic, sub interface{}) *gomock.Call
Register indicates an expected call of Register.
func (*MockMessageBusMockRecorder) UnRegister ¶ added in v2.1.0
func (mr *MockMessageBusMockRecorder) UnRegister(topic, sub interface{}) *gomock.Call
UnRegister indicates an expected call of UnRegister.
type MockSubscriber ¶
type MockSubscriber struct {
// contains filtered or unexported fields
}
MockSubscriber is a mock of Subscriber interface.
func NewMockSubscriber ¶
func NewMockSubscriber(ctrl *gomock.Controller) *MockSubscriber
NewMockSubscriber creates a new mock instance.
func (*MockSubscriber) EXPECT ¶
func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSubscriber) OnMessage ¶
func (m *MockSubscriber) OnMessage(arg0 *msgbus.Message)
OnMessage mocks base method.
type MockSubscriberMockRecorder ¶
type MockSubscriberMockRecorder struct {
// contains filtered or unexported fields
}
MockSubscriberMockRecorder is the mock recorder for MockSubscriber.
func (*MockSubscriberMockRecorder) OnMessage ¶
func (mr *MockSubscriberMockRecorder) OnMessage(arg0 interface{}) *gomock.Call
OnMessage indicates an expected call of OnMessage.
func (*MockSubscriberMockRecorder) OnQuit ¶
func (mr *MockSubscriberMockRecorder) OnQuit() *gomock.Call
OnQuit indicates an expected call of OnQuit.