Documentation
¶
Overview ¶
Package provider is a generated GoMock package.
Index ¶
- func RegisterDecoder(queueType string, decoderConstructor DecoderConstructor) error
- func RegisterQueueProvider(queueType string, queueConstructor QueueConstructor) error
- type Decoder
- type DecoderConstructor
- type MockDecoder
- type MockDecoderMockRecorder
- type MockQueue
- type MockQueueMockRecorder
- type Params
- type Queue
- type QueueConstructor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDecoder ¶
func RegisterDecoder(queueType string, decoderConstructor DecoderConstructor) error
RegisterDecoder registers a decoder constructor for a given queue type
func RegisterQueueProvider ¶
func RegisterQueueProvider(queueType string, queueConstructor QueueConstructor) error
RegisterQueueProvider registers a queue constructor for a given queue type
Types ¶
type DecoderConstructor ¶
func GetDecoder ¶
func GetDecoder(queueType string) (DecoderConstructor, bool)
GetDecoder returns a decoder constructor for a given queue type
type MockDecoder ¶
type MockDecoder struct {
// contains filtered or unexported fields
}
MockDecoder is a mock of Decoder interface.
func NewMockDecoder ¶
func NewMockDecoder(ctrl *gomock.Controller) *MockDecoder
NewMockDecoder creates a new mock instance.
func (*MockDecoder) EXPECT ¶
func (m *MockDecoder) EXPECT() *MockDecoderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockDecoderMockRecorder ¶
type MockDecoderMockRecorder struct {
// contains filtered or unexported fields
}
MockDecoderMockRecorder is the mock recorder for MockDecoder.
func (*MockDecoderMockRecorder) Decode ¶
func (mr *MockDecoderMockRecorder) Decode(arg0 interface{}) *gomock.Call
Decode indicates an expected call of Decode.
type MockQueue ¶
type MockQueue struct {
// contains filtered or unexported fields
}
MockQueue is a mock of Queue interface.
func NewMockQueue ¶
func NewMockQueue(ctrl *gomock.Controller) *MockQueue
NewMockQueue creates a new mock instance.
func (*MockQueue) CreateConsumer ¶
CreateConsumer mocks base method.
func (*MockQueue) CreateProducer ¶
CreateProducer mocks base method.
func (*MockQueue) EXPECT ¶
func (m *MockQueue) EXPECT() *MockQueueMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockQueueMockRecorder ¶
type MockQueueMockRecorder struct {
// contains filtered or unexported fields
}
MockQueueMockRecorder is the mock recorder for MockQueue.
func (*MockQueueMockRecorder) CreateConsumer ¶
func (mr *MockQueueMockRecorder) CreateConsumer(arg0 interface{}) *gomock.Call
CreateConsumer indicates an expected call of CreateConsumer.
func (*MockQueueMockRecorder) CreateProducer ¶
func (mr *MockQueueMockRecorder) CreateProducer(arg0 interface{}) *gomock.Call
CreateProducer indicates an expected call of CreateProducer.
func (*MockQueueMockRecorder) ID ¶
func (mr *MockQueueMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID.
type Queue ¶
type Queue interface {
ID() string
CreateConsumer(*Params) (messaging.Consumer, error)
CreateProducer(*Params) (messaging.Producer, error)
}
Queue is an interface for async queue
type QueueConstructor ¶
func GetQueueProvider ¶
func GetQueueProvider(queueType string) (QueueConstructor, bool)
GetQueueProvider returns a queue constructor for a given queue type
Source Files