Documentation
¶
Overview ¶
Package watermillx is a generated GoMock package.
Index ¶
- func NewMessage(_ context.Context, data interface{}) (*message.Message, error)
- func NewRouter(_ context.Context, logger watermill.LoggerAdapter, handlers []Handler) (*message.Router, error)
- type Handler
- type Logger
- func (l *Logger) Debug(msg string, fields watermill.LogFields)
- func (l *Logger) ErrMetadata(err error, fields watermill.LogFields) error
- func (l *Logger) Error(msg string, err error, fields watermill.LogFields)
- func (l *Logger) Info(msg string, fields watermill.LogFields)
- func (l *Logger) Trace(msg string, fields watermill.LogFields)
- func (l *Logger) With(fields watermill.LogFields) watermill.LoggerAdapter
- type MockPublisher
- type MockPublisherMockRecorder
- type MockSubscriber
- type MockSubscriberMockRecorder
- type Publisher
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Handler ¶
type Handler struct {
Topic string
Channel string
Subscriber message.Subscriber
Exec message.NoPublishHandlerFunc
}
type Logger ¶
type Logger struct {
// contains filtered or unexported fields
}
func (*Logger) ErrMetadata ¶
type MockPublisher ¶
type MockPublisher struct {
// contains filtered or unexported fields
}
MockPublisher is a mock of Publisher interface.
func NewMockPublisher ¶
func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher
NewMockPublisher creates a new mock instance.
func (*MockPublisher) EXPECT ¶
func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockPublisherMockRecorder ¶
type MockPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherMockRecorder is the mock recorder for MockPublisher.
func (*MockPublisherMockRecorder) Close ¶
func (mr *MockPublisherMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockPublisherMockRecorder) Publish ¶
func (mr *MockPublisherMockRecorder) Publish(topic interface{}, messages ...interface{}) *gomock.Call
Publish indicates an expected call of Publish.
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.
type MockSubscriberMockRecorder ¶
type MockSubscriberMockRecorder struct {
// contains filtered or unexported fields
}
MockSubscriberMockRecorder is the mock recorder for MockSubscriber.
func (*MockSubscriberMockRecorder) Close ¶
func (mr *MockSubscriberMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockSubscriberMockRecorder) Subscribe ¶
func (mr *MockSubscriberMockRecorder) Subscribe(ctx, topic interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
type Subscriber ¶
type Subscriber interface {
message.Subscriber
}
Source Files
Directories