Documentation
¶
Overview ¶
Package queues is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumeHandler ¶
type Consumer ¶
type Consumer interface {
Consume(ctx context.Context, handler ConsumeHandler) error
Close()
}
type MockConsumer ¶
type MockConsumer struct {
// contains filtered or unexported fields
}
MockConsumer is a mock of Consumer interface.
func NewMockConsumer ¶
func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
NewMockConsumer creates a new mock instance.
func (*MockConsumer) Consume ¶
func (m *MockConsumer) Consume(ctx context.Context, handler ConsumeHandler) error
Consume mocks base method.
func (*MockConsumer) EXPECT ¶
func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockConsumerMockRecorder ¶
type MockConsumerMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerMockRecorder is the mock recorder for MockConsumer.
func (*MockConsumerMockRecorder) Close ¶
func (mr *MockConsumerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
type MockProvider ¶
type MockProvider struct {
// contains filtered or unexported fields
}
MockProvider is a mock of Provider interface.
func NewMockProvider ¶
func NewMockProvider(ctrl *gomock.Controller) *MockProvider
NewMockProvider creates a new mock instance.
func (*MockProvider) EXPECT ¶
func (m *MockProvider) EXPECT() *MockProviderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProvider) NewConsumer ¶
func (m *MockProvider) NewConsumer(queueName string) (Consumer, error)
NewConsumer mocks base method.
func (*MockProvider) NewPublisher ¶
func (m *MockProvider) NewPublisher(queueName string) (Publisher, error)
NewPublisher mocks base method.
type MockProviderMockRecorder ¶
type MockProviderMockRecorder struct {
// contains filtered or unexported fields
}
MockProviderMockRecorder is the mock recorder for MockProvider.
func (*MockProviderMockRecorder) NewConsumer ¶
func (mr *MockProviderMockRecorder) NewConsumer(queueName any) *gomock.Call
NewConsumer indicates an expected call of NewConsumer.
func (*MockProviderMockRecorder) NewPublisher ¶
func (mr *MockProviderMockRecorder) NewPublisher(queueName any) *gomock.Call
NewPublisher indicates an expected call of NewPublisher.
func (*MockProviderMockRecorder) Stop ¶
func (mr *MockProviderMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
func (*MockProviderMockRecorder) Wait ¶
func (mr *MockProviderMockRecorder) Wait() *gomock.Call
Wait indicates an expected call of Wait.
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.
type Provider ¶
type Provider interface {
NewConsumer(queueName string) (Consumer, error)
NewPublisher(queueName string) (Publisher, error)
Stop()
Wait()
}
func NewRedisProvider ¶ added in v0.4.0
func NewRedisProvider(ctx context.Context, log logrus.FieldLogger, hostname string, port uint, password config.SecureString) (Provider, error)
Source Files