watermillx

Documentation

Overview

Package queue 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 NewLogger() (*Logger, error)
  • 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
  • func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher
  • func (m *MockPublisher) Close() error
  • func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
  • func (m *MockPublisher) Publish(topic string, messages ...*message.Message) error
• type MockPublisherMockRecorder
  • func (mr *MockPublisherMockRecorder) Close() *gomock.Call
  • func (mr *MockPublisherMockRecorder) Publish(topic interface{}, messages ...interface{}) *gomock.Call
• type MockSubscriber
  • func NewMockSubscriber(ctrl *gomock.Controller) *MockSubscriber
  • func (m *MockSubscriber) Close() error
  • func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder
  • func (m *MockSubscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)
• type MockSubscriberMockRecorder
  • func (mr *MockSubscriberMockRecorder) Close() *gomock.Call
  • func (mr *MockSubscriberMockRecorder) Subscribe(ctx, topic interface{}) *gomock.Call
• type Publisher
• type Subscriber

Functions

func NewMessage

func NewMessage(_ context.Context, data interface{}) (*message.Message, error)

func NewRouter

func NewRouter(
	_ context.Context,
	logger watermill.LoggerAdapter,
	handlers []Handler,
) (*message.Router, error)

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 NewLogger

func NewLogger() (*Logger, error)

func (*Logger) Debug

func (l *Logger) Debug(msg string, fields watermill.LogFields)

func (*Logger) ErrMetadata

func (l *Logger) ErrMetadata(err error, fields watermill.LogFields) error

func (*Logger) Error

func (l *Logger) Error(msg string, err error, fields watermill.LogFields)

func (*Logger) Info

func (l *Logger) Info(msg string, fields watermill.LogFields)

func (*Logger) Trace

func (l *Logger) Trace(msg string, fields watermill.LogFields)

func (*Logger) With

func (l *Logger) With(fields watermill.LogFields) watermill.LoggerAdapter

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) Close

func (m *MockPublisher) Close() error

Close mocks base method.

func (*MockPublisher) EXPECT

func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPublisher) Publish

func (m *MockPublisher) Publish(topic string, messages ...*message.Message) error

Publish mocks base method.

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) Close

func (m *MockSubscriber) Close() error

Close mocks base method.

func (*MockSubscriber) EXPECT

func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSubscriber) Subscribe

func (m *MockSubscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)

Subscribe mocks base method.

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 Publisher

type Publisher interface {
	message.Publisher
}

type Subscriber

type Subscriber interface {
	message.Subscriber
}