Documentation
¶
Overview ¶
Package mock_store is a generated GoMock package.
Index ¶
- type MockStore
- func (m *MockStore) BPopJobFromQueue(queue string, blockTime time.Duration) (job.NameVersion, error)
- func (m *MockStore) CollectInFlightJobNumberBucket(bucket string) (uint64, error)
- func (m *MockStore) CollectInFlightJobNumberQueue(queuePrefix string) (map[string]uint64, error)
- func (m *MockStore) CreateJob(j *job.Job) error
- func (m *MockStore) CreateJobInBucket(bucket string, j *job.Job, isTTR bool) error
- func (m *MockStore) DeleteJob(j *job.Job) (bool, error)
- func (m *MockStore) EXPECT() *MockStoreMockRecorder
- func (m *MockStore) GetLock(name string) lock.Locker
- func (m *MockStore) GetReadyJobsInBucket(bucket string, num uint) ([]job.NameVersion, error)
- func (m *MockStore) LoadJob(j *job.Job) error
- func (m *MockStore) PopJobFromQueue(queue string) (job.NameVersion, error)
- func (m *MockStore) PushJobToQueue(queuePrefix, queueName string, j *job.Job) error
- func (m *MockStore) ReplaceJob(j *job.Job) error
- type MockStoreMockRecorder
- func (mr *MockStoreMockRecorder) BPopJobFromQueue(queue, blockTime interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) CollectInFlightJobNumberBucket(bucket interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) CollectInFlightJobNumberQueue(queuePrefix interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) CreateJob(j interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) CreateJobInBucket(bucket, j, isTTR interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) DeleteJob(j interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) GetLock(name interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) GetReadyJobsInBucket(bucket, num interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) LoadJob(j interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) PopJobFromQueue(queue interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) PushJobToQueue(queuePrefix, queueName, j interface{}) *gomock.Call
- func (mr *MockStoreMockRecorder) ReplaceJob(j interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockStore ¶
type MockStore struct {
// contains filtered or unexported fields
}
MockStore is a mock of Store interface.
func NewMockStore ¶
func NewMockStore(ctrl *gomock.Controller) *MockStore
NewMockStore creates a new mock instance.
func (*MockStore) BPopJobFromQueue ¶
func (m *MockStore) BPopJobFromQueue(queue string, blockTime time.Duration) (job.NameVersion, error)
BPopJobFromQueue mocks base method.
func (*MockStore) CollectInFlightJobNumberBucket ¶
CollectInFlightJobNumberBucket mocks base method.
func (*MockStore) CollectInFlightJobNumberQueue ¶
CollectInFlightJobNumberQueue mocks base method.
func (*MockStore) CreateJobInBucket ¶
CreateJobInBucket mocks base method.
func (*MockStore) EXPECT ¶
func (m *MockStore) EXPECT() *MockStoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStore) GetReadyJobsInBucket ¶
GetReadyJobsInBucket mocks base method.
func (*MockStore) PopJobFromQueue ¶
func (m *MockStore) PopJobFromQueue(queue string) (job.NameVersion, error)
PopJobFromQueue mocks base method.
func (*MockStore) PushJobToQueue ¶
PushJobToQueue mocks base method.
type MockStoreMockRecorder ¶
type MockStoreMockRecorder struct {
// contains filtered or unexported fields
}
MockStoreMockRecorder is the mock recorder for MockStore.
func (*MockStoreMockRecorder) BPopJobFromQueue ¶
func (mr *MockStoreMockRecorder) BPopJobFromQueue(queue, blockTime interface{}) *gomock.Call
BPopJobFromQueue indicates an expected call of BPopJobFromQueue.
func (*MockStoreMockRecorder) CollectInFlightJobNumberBucket ¶
func (mr *MockStoreMockRecorder) CollectInFlightJobNumberBucket(bucket interface{}) *gomock.Call
CollectInFlightJobNumberBucket indicates an expected call of CollectInFlightJobNumberBucket.
func (*MockStoreMockRecorder) CollectInFlightJobNumberQueue ¶
func (mr *MockStoreMockRecorder) CollectInFlightJobNumberQueue(queuePrefix interface{}) *gomock.Call
CollectInFlightJobNumberQueue indicates an expected call of CollectInFlightJobNumberQueue.
func (*MockStoreMockRecorder) CreateJob ¶
func (mr *MockStoreMockRecorder) CreateJob(j interface{}) *gomock.Call
CreateJob indicates an expected call of CreateJob.
func (*MockStoreMockRecorder) CreateJobInBucket ¶
func (mr *MockStoreMockRecorder) CreateJobInBucket(bucket, j, isTTR interface{}) *gomock.Call
CreateJobInBucket indicates an expected call of CreateJobInBucket.
func (*MockStoreMockRecorder) DeleteJob ¶
func (mr *MockStoreMockRecorder) DeleteJob(j interface{}) *gomock.Call
DeleteJob indicates an expected call of DeleteJob.
func (*MockStoreMockRecorder) GetLock ¶
func (mr *MockStoreMockRecorder) GetLock(name interface{}) *gomock.Call
GetLock indicates an expected call of GetLock.
func (*MockStoreMockRecorder) GetReadyJobsInBucket ¶
func (mr *MockStoreMockRecorder) GetReadyJobsInBucket(bucket, num interface{}) *gomock.Call
GetReadyJobsInBucket indicates an expected call of GetReadyJobsInBucket.
func (*MockStoreMockRecorder) LoadJob ¶
func (mr *MockStoreMockRecorder) LoadJob(j interface{}) *gomock.Call
LoadJob indicates an expected call of LoadJob.
func (*MockStoreMockRecorder) PopJobFromQueue ¶
func (mr *MockStoreMockRecorder) PopJobFromQueue(queue interface{}) *gomock.Call
PopJobFromQueue indicates an expected call of PopJobFromQueue.
func (*MockStoreMockRecorder) PushJobToQueue ¶
func (mr *MockStoreMockRecorder) PushJobToQueue(queuePrefix, queueName, j interface{}) *gomock.Call
PushJobToQueue indicates an expected call of PushJobToQueue.
func (*MockStoreMockRecorder) ReplaceJob ¶
func (mr *MockStoreMockRecorder) ReplaceJob(j interface{}) *gomock.Call
ReplaceJob indicates an expected call of ReplaceJob.
Source Files