Documentation ¶
Overview ¶
Package broker is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broker ¶
type MockBroker ¶
type MockBroker struct {
// contains filtered or unexported fields
}
MockBroker is a mock of Broker interface.
func NewMockBroker ¶
func NewMockBroker(ctrl *gomock.Controller) *MockBroker
NewMockBroker creates a new mock instance.
func (*MockBroker) EXPECT ¶
func (m *MockBroker) EXPECT() *MockBrokerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockBroker) Publish ¶
func (m *MockBroker) Publish(topic string, value *store.Value) error
Publish mocks base method.
func (*MockBroker) Subscribe ¶
func (m *MockBroker) Subscribe(topic string) *consumer.Consumer
Subscribe mocks base method.
func (*MockBroker) Unsubscribe ¶
func (m *MockBroker) Unsubscribe(topic, id string) error
Unsubscribe mocks base method.
type MockBrokerMockRecorder ¶
type MockBrokerMockRecorder struct {
// contains filtered or unexported fields
}
MockBrokerMockRecorder is the mock recorder for MockBroker.
func (*MockBrokerMockRecorder) Publish ¶
func (mr *MockBrokerMockRecorder) Publish(topic, value interface{}) *gomock.Call
Publish indicates an expected call of Publish.
func (*MockBrokerMockRecorder) Subscribe ¶
func (mr *MockBrokerMockRecorder) Subscribe(topic interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
func (*MockBrokerMockRecorder) Unsubscribe ¶
func (mr *MockBrokerMockRecorder) Unsubscribe(topic, id interface{}) *gomock.Call
Unsubscribe indicates an expected call of Unsubscribe.
Click to show internal directories.
Click to hide internal directories.