Versions in this module Expand all Collapse all v0 v0.1.0 Mar 19, 2022 Changes in this version + type MockStore struct + func NewMockStore(ctrl *gomock.Controller) *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 struct + 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 v0.1.0-beta Jul 14, 2021
Go to main page