func (m *MockStore) CreateJobInBucket(bucket string, j *job.Job, isTTR bool) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CreateJobInBucket", bucket, j, isTTR)
	ret0, _ := ret[0].(error)
	return ret0
}
CreateJobInBucket mocks base method.
package mock_store
import (
	reflect "reflect"
	time "time"
	job "github.com/changsongl/delay-queue/job"
	lock "github.com/changsongl/delay-queue/pkg/lock"
	gomock "github.com/golang/mock/gomock"
)
type MockStore struct {
	ctrl     *gomock.Controller
	recorder *MockStoreMockRecorder
}
type MockStoreMockRecorder struct {
	mock *MockStore
}
func NewMockStore(ctrl *gomock.Controller) *MockStore {
	mock := &MockStore{ctrl: ctrl}
	mock.recorder = &MockStoreMockRecorder{mock}
	return mock
}
func (m *MockStore) EXPECT() *MockStoreMockRecorder {
	return m.recorder
}
func (m *MockStore) BPopJobFromQueue(queue string, blockTime time.Duration) (job.NameVersion, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "BPopJobFromQueue", queue, blockTime)
	ret0, _ := ret[0].(job.NameVersion)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
func (mr *MockStoreMockRecorder) BPopJobFromQueue(queue, blockTime interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "BPopJobFromQueue", reflect.TypeOf((*MockStore)(nil).BPopJobFromQueue), queue, blockTime)
}
func (m *MockStore) CollectInFlightJobNumberBucket(bucket string) (uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CollectInFlightJobNumberBucket", bucket)
	ret0, _ := ret[0].(uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
func (mr *MockStoreMockRecorder) CollectInFlightJobNumberBucket(bucket interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CollectInFlightJobNumberBucket", reflect.TypeOf((*MockStore)(nil).CollectInFlightJobNumberBucket), bucket)
}
func (m *MockStore) CollectInFlightJobNumberQueue(queuePrefix string) (map[string]uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CollectInFlightJobNumberQueue", queuePrefix)
	ret0, _ := ret[0].(map[string]uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
func (mr *MockStoreMockRecorder) CollectInFlightJobNumberQueue(queuePrefix interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CollectInFlightJobNumberQueue", reflect.TypeOf((*MockStore)(nil).CollectInFlightJobNumberQueue), queuePrefix)
}
func (m *MockStore) CreateJob(j *job.Job) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CreateJob", j)
	ret0, _ := ret[0].(error)
	return ret0
}
func (mr *MockStoreMockRecorder) CreateJob(j interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreateJob", reflect.TypeOf((*MockStore)(nil).CreateJob), j)
}