mock_store

Documentation

Overview

Package mock_store is a generated GoMock package.

Index

• type MockStore
  • 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
  • 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

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

func (m *MockStore) CollectInFlightJobNumberBucket(bucket string) (uint64, error)

CollectInFlightJobNumberBucket mocks base method.

func (*MockStore) CollectInFlightJobNumberQueue

func (m *MockStore) CollectInFlightJobNumberQueue(queuePrefix string) (map[string]uint64, error)

CollectInFlightJobNumberQueue mocks base method.

func (*MockStore) CreateJob

func (m *MockStore) CreateJob(j *job.Job) error

CreateJob mocks base method.

func (*MockStore) CreateJobInBucket

func (m *MockStore) CreateJobInBucket(bucket string, j *job.Job, isTTR bool) error

CreateJobInBucket mocks base method.

func (*MockStore) DeleteJob

func (m *MockStore) DeleteJob(j *job.Job) (bool, error)

DeleteJob 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) GetLock

func (m *MockStore) GetLock(name string) lock.Locker

GetLock mocks base method.

func (*MockStore) GetReadyJobsInBucket

func (m *MockStore) GetReadyJobsInBucket(bucket string, num uint) ([]job.NameVersion, error)

GetReadyJobsInBucket mocks base method.

func (*MockStore) LoadJob

func (m *MockStore) LoadJob(j *job.Job) error

LoadJob mocks base method.

func (*MockStore) PopJobFromQueue

func (m *MockStore) PopJobFromQueue(queue string) (job.NameVersion, error)

PopJobFromQueue mocks base method.

func (*MockStore) PushJobToQueue

func (m *MockStore) PushJobToQueue(queuePrefix, queueName string, j *job.Job) error

PushJobToQueue mocks base method.

func (*MockStore) ReplaceJob

func (m *MockStore) ReplaceJob(j *job.Job) error

ReplaceJob 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.