Documentation ¶
Overview ¶
Package mmock is a generated GoMock package.
Package mmock is a generated GoMock package.
Package mmock is a generated GoMock package.
Package mmock is a generated GoMock package.
Package mmock is a generated GoMock package.
Index ¶
- type MockBatchConsumer
- type MockBatchConsumerMockRecorder
- type MockConnection
- type MockConnectionMockRecorder
- type MockConsumer
- type MockConsumerMockRecorder
- type MockQueue
- func (m *MockQueue) AddBatchConsumer(arg0 string, arg1 int, arg2 rmq.BatchConsumer) string
- func (m *MockQueue) AddBatchConsumerWithTimeout(arg0 string, arg1 int, arg2 time.Duration, arg3 rmq.BatchConsumer) string
- func (m *MockQueue) AddConsumer(arg0 string, arg1 rmq.Consumer) string
- func (m *MockQueue) AddConsumerFunc(arg0 string, arg1 rmq.ConsumerFunc) string
- func (m *MockQueue) Close() bool
- func (m *MockQueue) EXPECT() *MockQueueMockRecorder
- func (m *MockQueue) Publish(arg0 ...string) bool
- func (m *MockQueue) PublishBytes(arg0 ...[]byte) bool
- func (m *MockQueue) PurgeReady() int
- func (m *MockQueue) PurgeRejected() int
- func (m *MockQueue) ReturnAllRejected() int
- func (m *MockQueue) ReturnRejected(arg0 int) int
- func (m *MockQueue) SetPushQueue(arg0 rmq.Queue)
- func (m *MockQueue) StartConsuming(arg0 int, arg1 time.Duration) bool
- func (m *MockQueue) StopConsuming() <-chan struct{}
- type MockQueueMockRecorder
- func (mr *MockQueueMockRecorder) AddBatchConsumer(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) AddBatchConsumerWithTimeout(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) AddConsumer(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) AddConsumerFunc(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) Close() *gomock.Call
- func (mr *MockQueueMockRecorder) Publish(arg0 ...interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) PublishBytes(arg0 ...interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) PurgeReady() *gomock.Call
- func (mr *MockQueueMockRecorder) PurgeRejected() *gomock.Call
- func (mr *MockQueueMockRecorder) ReturnAllRejected() *gomock.Call
- func (mr *MockQueueMockRecorder) ReturnRejected(arg0 interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) SetPushQueue(arg0 interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) StartConsuming(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueMockRecorder) StopConsuming() *gomock.Call
- type MockRedisClient
- func (m *MockRedisClient) Del(arg0 string) (int, bool)
- func (m *MockRedisClient) EXPECT() *MockRedisClientMockRecorder
- func (m *MockRedisClient) FlushDb()
- func (m *MockRedisClient) LLen(arg0 string) (int, bool)
- func (m *MockRedisClient) LPush(arg0 string, arg1 ...string) bool
- func (m *MockRedisClient) LRem(arg0 string, arg1 int, arg2 string) (int, bool)
- func (m *MockRedisClient) LTrim(arg0 string, arg1, arg2 int)
- func (m *MockRedisClient) RPopLPush(arg0, arg1 string) (string, bool)
- func (m *MockRedisClient) SAdd(arg0, arg1 string) bool
- func (m *MockRedisClient) SMembers(arg0 string) []string
- func (m *MockRedisClient) SRem(arg0, arg1 string) (int, bool)
- func (m *MockRedisClient) Set(arg0, arg1 string, arg2 time.Duration) bool
- func (m *MockRedisClient) TTL(arg0 string) (time.Duration, bool)
- type MockRedisClientMockRecorder
- func (mr *MockRedisClientMockRecorder) Del(arg0 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) FlushDb() *gomock.Call
- func (mr *MockRedisClientMockRecorder) LLen(arg0 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) LPush(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) LRem(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) LTrim(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) RPopLPush(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) SAdd(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) SMembers(arg0 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) SRem(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) Set(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRedisClientMockRecorder) TTL(arg0 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBatchConsumer ¶
type MockBatchConsumer struct {
// contains filtered or unexported fields
}
MockBatchConsumer is a mock of BatchConsumer interface
func NewMockBatchConsumer ¶
func NewMockBatchConsumer(ctrl *gomock.Controller) *MockBatchConsumer
NewMockBatchConsumer creates a new mock instance
func (*MockBatchConsumer) Consume ¶
func (m *MockBatchConsumer) Consume(arg0 rmq.Deliveries)
Consume mocks base method
func (*MockBatchConsumer) EXPECT ¶
func (m *MockBatchConsumer) EXPECT() *MockBatchConsumerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockBatchConsumerMockRecorder ¶
type MockBatchConsumerMockRecorder struct {
// contains filtered or unexported fields
}
MockBatchConsumerMockRecorder is the mock recorder for MockBatchConsumer
func (*MockBatchConsumerMockRecorder) Consume ¶
func (mr *MockBatchConsumerMockRecorder) Consume(arg0 interface{}) *gomock.Call
Consume indicates an expected call of Consume
type MockConnection ¶
type MockConnection struct {
// contains filtered or unexported fields
}
MockConnection is a mock of Connection interface
func NewMockConnection ¶
func NewMockConnection(ctrl *gomock.Controller) *MockConnection
NewMockConnection creates a new mock instance
func (*MockConnection) CollectStats ¶
func (m *MockConnection) CollectStats(arg0 []string) rmq.Stats
CollectStats mocks base method
func (*MockConnection) EXPECT ¶
func (m *MockConnection) EXPECT() *MockConnectionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockConnection) GetOpenQueues ¶
func (m *MockConnection) GetOpenQueues() []string
GetOpenQueues mocks base method
type MockConnectionMockRecorder ¶
type MockConnectionMockRecorder struct {
// contains filtered or unexported fields
}
MockConnectionMockRecorder is the mock recorder for MockConnection
func (*MockConnectionMockRecorder) CollectStats ¶
func (mr *MockConnectionMockRecorder) CollectStats(arg0 interface{}) *gomock.Call
CollectStats indicates an expected call of CollectStats
func (*MockConnectionMockRecorder) GetOpenQueues ¶
func (mr *MockConnectionMockRecorder) GetOpenQueues() *gomock.Call
GetOpenQueues indicates an expected call of GetOpenQueues
func (*MockConnectionMockRecorder) OpenQueue ¶
func (mr *MockConnectionMockRecorder) OpenQueue(arg0 interface{}) *gomock.Call
OpenQueue indicates an expected call of OpenQueue
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(arg0 rmq.Delivery)
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) Consume ¶
func (mr *MockConsumerMockRecorder) Consume(arg0 interface{}) *gomock.Call
Consume indicates an expected call of Consume
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) AddBatchConsumer ¶
AddBatchConsumer mocks base method
func (*MockQueue) AddBatchConsumerWithTimeout ¶
func (m *MockQueue) AddBatchConsumerWithTimeout(arg0 string, arg1 int, arg2 time.Duration, arg3 rmq.BatchConsumer) string
AddBatchConsumerWithTimeout mocks base method
func (*MockQueue) AddConsumer ¶
AddConsumer mocks base method
func (*MockQueue) AddConsumerFunc ¶
func (m *MockQueue) AddConsumerFunc(arg0 string, arg1 rmq.ConsumerFunc) string
AddConsumerFunc mocks base method
func (*MockQueue) EXPECT ¶
func (m *MockQueue) EXPECT() *MockQueueMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockQueue) PublishBytes ¶
PublishBytes mocks base method
func (*MockQueue) PurgeRejected ¶
PurgeRejected mocks base method
func (*MockQueue) ReturnAllRejected ¶
ReturnAllRejected mocks base method
func (*MockQueue) ReturnRejected ¶
ReturnRejected mocks base method
func (*MockQueue) SetPushQueue ¶
SetPushQueue mocks base method
func (*MockQueue) StartConsuming ¶
StartConsuming mocks base method
func (*MockQueue) StopConsuming ¶
func (m *MockQueue) StopConsuming() <-chan struct{}
StopConsuming mocks base method
type MockQueueMockRecorder ¶
type MockQueueMockRecorder struct {
// contains filtered or unexported fields
}
MockQueueMockRecorder is the mock recorder for MockQueue
func (*MockQueueMockRecorder) AddBatchConsumer ¶
func (mr *MockQueueMockRecorder) AddBatchConsumer(arg0, arg1, arg2 interface{}) *gomock.Call
AddBatchConsumer indicates an expected call of AddBatchConsumer
func (*MockQueueMockRecorder) AddBatchConsumerWithTimeout ¶
func (mr *MockQueueMockRecorder) AddBatchConsumerWithTimeout(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
AddBatchConsumerWithTimeout indicates an expected call of AddBatchConsumerWithTimeout
func (*MockQueueMockRecorder) AddConsumer ¶
func (mr *MockQueueMockRecorder) AddConsumer(arg0, arg1 interface{}) *gomock.Call
AddConsumer indicates an expected call of AddConsumer
func (*MockQueueMockRecorder) AddConsumerFunc ¶
func (mr *MockQueueMockRecorder) AddConsumerFunc(arg0, arg1 interface{}) *gomock.Call
AddConsumerFunc indicates an expected call of AddConsumerFunc
func (*MockQueueMockRecorder) Close ¶
func (mr *MockQueueMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockQueueMockRecorder) Publish ¶
func (mr *MockQueueMockRecorder) Publish(arg0 ...interface{}) *gomock.Call
Publish indicates an expected call of Publish
func (*MockQueueMockRecorder) PublishBytes ¶
func (mr *MockQueueMockRecorder) PublishBytes(arg0 ...interface{}) *gomock.Call
PublishBytes indicates an expected call of PublishBytes
func (*MockQueueMockRecorder) PurgeReady ¶
func (mr *MockQueueMockRecorder) PurgeReady() *gomock.Call
PurgeReady indicates an expected call of PurgeReady
func (*MockQueueMockRecorder) PurgeRejected ¶
func (mr *MockQueueMockRecorder) PurgeRejected() *gomock.Call
PurgeRejected indicates an expected call of PurgeRejected
func (*MockQueueMockRecorder) ReturnAllRejected ¶
func (mr *MockQueueMockRecorder) ReturnAllRejected() *gomock.Call
ReturnAllRejected indicates an expected call of ReturnAllRejected
func (*MockQueueMockRecorder) ReturnRejected ¶
func (mr *MockQueueMockRecorder) ReturnRejected(arg0 interface{}) *gomock.Call
ReturnRejected indicates an expected call of ReturnRejected
func (*MockQueueMockRecorder) SetPushQueue ¶
func (mr *MockQueueMockRecorder) SetPushQueue(arg0 interface{}) *gomock.Call
SetPushQueue indicates an expected call of SetPushQueue
func (*MockQueueMockRecorder) StartConsuming ¶
func (mr *MockQueueMockRecorder) StartConsuming(arg0, arg1 interface{}) *gomock.Call
StartConsuming indicates an expected call of StartConsuming
func (*MockQueueMockRecorder) StopConsuming ¶
func (mr *MockQueueMockRecorder) StopConsuming() *gomock.Call
StopConsuming indicates an expected call of StopConsuming
type MockRedisClient ¶
type MockRedisClient struct {
// contains filtered or unexported fields
}
MockRedisClient is a mock of RedisClient interface
func NewMockRedisClient ¶
func NewMockRedisClient(ctrl *gomock.Controller) *MockRedisClient
NewMockRedisClient creates a new mock instance
func (*MockRedisClient) Del ¶
func (m *MockRedisClient) Del(arg0 string) (int, bool)
Del mocks base method
func (*MockRedisClient) EXPECT ¶
func (m *MockRedisClient) EXPECT() *MockRedisClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockRedisClient) LLen ¶
func (m *MockRedisClient) LLen(arg0 string) (int, bool)
LLen mocks base method
func (*MockRedisClient) LPush ¶
func (m *MockRedisClient) LPush(arg0 string, arg1 ...string) bool
LPush mocks base method
func (*MockRedisClient) LTrim ¶
func (m *MockRedisClient) LTrim(arg0 string, arg1, arg2 int)
LTrim mocks base method
func (*MockRedisClient) RPopLPush ¶
func (m *MockRedisClient) RPopLPush(arg0, arg1 string) (string, bool)
RPopLPush mocks base method
func (*MockRedisClient) SAdd ¶
func (m *MockRedisClient) SAdd(arg0, arg1 string) bool
SAdd mocks base method
func (*MockRedisClient) SMembers ¶
func (m *MockRedisClient) SMembers(arg0 string) []string
SMembers mocks base method
func (*MockRedisClient) SRem ¶
func (m *MockRedisClient) SRem(arg0, arg1 string) (int, bool)
SRem mocks base method
type MockRedisClientMockRecorder ¶
type MockRedisClientMockRecorder struct {
// contains filtered or unexported fields
}
MockRedisClientMockRecorder is the mock recorder for MockRedisClient
func (*MockRedisClientMockRecorder) Del ¶
func (mr *MockRedisClientMockRecorder) Del(arg0 interface{}) *gomock.Call
Del indicates an expected call of Del
func (*MockRedisClientMockRecorder) FlushDb ¶
func (mr *MockRedisClientMockRecorder) FlushDb() *gomock.Call
FlushDb indicates an expected call of FlushDb
func (*MockRedisClientMockRecorder) LLen ¶
func (mr *MockRedisClientMockRecorder) LLen(arg0 interface{}) *gomock.Call
LLen indicates an expected call of LLen
func (*MockRedisClientMockRecorder) LPush ¶
func (mr *MockRedisClientMockRecorder) LPush(arg0 interface{}, arg1 ...interface{}) *gomock.Call
LPush indicates an expected call of LPush
func (*MockRedisClientMockRecorder) LRem ¶
func (mr *MockRedisClientMockRecorder) LRem(arg0, arg1, arg2 interface{}) *gomock.Call
LRem indicates an expected call of LRem
func (*MockRedisClientMockRecorder) LTrim ¶
func (mr *MockRedisClientMockRecorder) LTrim(arg0, arg1, arg2 interface{}) *gomock.Call
LTrim indicates an expected call of LTrim
func (*MockRedisClientMockRecorder) RPopLPush ¶
func (mr *MockRedisClientMockRecorder) RPopLPush(arg0, arg1 interface{}) *gomock.Call
RPopLPush indicates an expected call of RPopLPush
func (*MockRedisClientMockRecorder) SAdd ¶
func (mr *MockRedisClientMockRecorder) SAdd(arg0, arg1 interface{}) *gomock.Call
SAdd indicates an expected call of SAdd
func (*MockRedisClientMockRecorder) SMembers ¶
func (mr *MockRedisClientMockRecorder) SMembers(arg0 interface{}) *gomock.Call
SMembers indicates an expected call of SMembers
func (*MockRedisClientMockRecorder) SRem ¶
func (mr *MockRedisClientMockRecorder) SRem(arg0, arg1 interface{}) *gomock.Call
SRem indicates an expected call of SRem
func (*MockRedisClientMockRecorder) Set ¶
func (mr *MockRedisClientMockRecorder) Set(arg0, arg1, arg2 interface{}) *gomock.Call
Set indicates an expected call of Set
func (*MockRedisClientMockRecorder) TTL ¶
func (mr *MockRedisClientMockRecorder) TTL(arg0 interface{}) *gomock.Call
TTL indicates an expected call of TTL