mocks_jobsdb

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 14, 2021 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mocks_jobsdb is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockJobsDB 

type MockJobsDB struct {
	// contains filtered or unexported fields
}

MockJobsDB is a mock of JobsDB interface

func NewMockJobsDB 

func NewMockJobsDB(ctrl *gomock.Controller) *MockJobsDB

NewMockJobsDB creates a new mock instance

func (*MockJobsDB) AcquireStoreLock added in v1.0.0 

func (m *MockJobsDB) AcquireStoreLock()

AcquireStoreLock mocks base method

func (*MockJobsDB) AcquireUpdateJobStatusLocks added in v1.0.0 

func (m *MockJobsDB) AcquireUpdateJobStatusLocks()

AcquireUpdateJobStatusLocks mocks base method

func (*MockJobsDB) BeginGlobalTransaction added in v1.0.0 

func (m *MockJobsDB) BeginGlobalTransaction() *sql.Tx

BeginGlobalTransaction mocks base method

func (*MockJobsDB) CheckPGHealth added in v1.0.0 

func (m *MockJobsDB) CheckPGHealth() bool

CheckPGHealth mocks base method

func (*MockJobsDB) CommitTransaction added in v1.0.0 

func (m *MockJobsDB) CommitTransaction(arg0 *sql.Tx)

CommitTransaction mocks base method

func (*MockJobsDB) DeleteExecuting 

func (m *MockJobsDB) DeleteExecuting(arg0 jobsdb.GetQueryParamsT)

DeleteExecuting mocks base method

func (*MockJobsDB) EXPECT 

func (m *MockJobsDB) EXPECT() *MockJobsDBMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockJobsDB) GetExecuting 

func (m *MockJobsDB) GetExecuting(arg0 jobsdb.GetQueryParamsT) []*jobsdb.JobT

GetExecuting mocks base method

func (*MockJobsDB) GetIdentifier added in v1.0.0 

func (m *MockJobsDB) GetIdentifier() string

GetIdentifier mocks base method

func (*MockJobsDB) GetImportingList added in v1.0.0 

func (m *MockJobsDB) GetImportingList(arg0 jobsdb.GetQueryParamsT) []*jobsdb.JobT

GetImportingList mocks base method

func (*MockJobsDB) GetJournalEntries 

func (m *MockJobsDB) GetJournalEntries(arg0 string) []jobsdb.JournalEntryT

GetJournalEntries mocks base method

func (*MockJobsDB) GetProcessed 

func (m *MockJobsDB) GetProcessed(arg0 jobsdb.GetQueryParamsT) []*jobsdb.JobT

GetProcessed mocks base method

func (*MockJobsDB) GetThrottled added in v1.0.0 

func (m *MockJobsDB) GetThrottled(arg0 jobsdb.GetQueryParamsT) []*jobsdb.JobT

GetThrottled mocks base method

func (*MockJobsDB) GetToRetry 

func (m *MockJobsDB) GetToRetry(arg0 jobsdb.GetQueryParamsT) []*jobsdb.JobT

GetToRetry mocks base method

func (*MockJobsDB) GetUnprocessed 

func (m *MockJobsDB) GetUnprocessed(arg0 jobsdb.GetQueryParamsT) []*jobsdb.JobT

GetUnprocessed mocks base method

func (*MockJobsDB) GetWaiting 

func (m *MockJobsDB) GetWaiting(arg0 jobsdb.GetQueryParamsT) []*jobsdb.JobT

GetWaiting mocks base method

func (*MockJobsDB) JournalDeleteEntry 

func (m *MockJobsDB) JournalDeleteEntry(arg0 int64)

JournalDeleteEntry mocks base method

func (*MockJobsDB) JournalMarkStart 

func (m *MockJobsDB) JournalMarkStart(arg0 string, arg1 json.RawMessage) int64

JournalMarkStart mocks base method

func (*MockJobsDB) ReleaseStoreLock added in v1.0.0 

func (m *MockJobsDB) ReleaseStoreLock()

ReleaseStoreLock mocks base method

func (*MockJobsDB) ReleaseUpdateJobStatusLocks added in v1.0.0 

func (m *MockJobsDB) ReleaseUpdateJobStatusLocks()

ReleaseUpdateJobStatusLocks mocks base method

func (*MockJobsDB) Status 

func (m *MockJobsDB) Status() interface{}

Status mocks base method

func (*MockJobsDB) Store 

func (m *MockJobsDB) Store(arg0 []*jobsdb.JobT) error

Store mocks base method

func (*MockJobsDB) StoreWithRetryEach 

func (m *MockJobsDB) StoreWithRetryEach(arg0 []*jobsdb.JobT) map[uuid.UUID]string

StoreWithRetryEach mocks base method

func (*MockJobsDB) UpdateJobStatus 

func (m *MockJobsDB) UpdateJobStatus(arg0 []*jobsdb.JobStatusT, arg1 []string, arg2 []jobsdb.ParameterFilterT) error

UpdateJobStatus mocks base method

func (*MockJobsDB) UpdateJobStatusInTxn added in v1.0.0 

func (m *MockJobsDB) UpdateJobStatusInTxn(arg0 *sql.Tx, arg1 []*jobsdb.JobStatusT, arg2 []string, arg3 []jobsdb.ParameterFilterT) error

UpdateJobStatusInTxn mocks base method

type MockJobsDBMockRecorder 

type MockJobsDBMockRecorder struct {
	// contains filtered or unexported fields
}

MockJobsDBMockRecorder is the mock recorder for MockJobsDB

func (*MockJobsDBMockRecorder) AcquireStoreLock added in v1.0.0 

func (mr *MockJobsDBMockRecorder) AcquireStoreLock() *gomock.Call

AcquireStoreLock indicates an expected call of AcquireStoreLock

func (*MockJobsDBMockRecorder) AcquireUpdateJobStatusLocks added in v1.0.0 

func (mr *MockJobsDBMockRecorder) AcquireUpdateJobStatusLocks() *gomock.Call

AcquireUpdateJobStatusLocks indicates an expected call of AcquireUpdateJobStatusLocks

func (*MockJobsDBMockRecorder) BeginGlobalTransaction added in v1.0.0 

func (mr *MockJobsDBMockRecorder) BeginGlobalTransaction() *gomock.Call

BeginGlobalTransaction indicates an expected call of BeginGlobalTransaction

func (*MockJobsDBMockRecorder) CheckPGHealth added in v1.0.0 

func (mr *MockJobsDBMockRecorder) CheckPGHealth() *gomock.Call

CheckPGHealth indicates an expected call of CheckPGHealth

func (*MockJobsDBMockRecorder) CommitTransaction added in v1.0.0 

func (mr *MockJobsDBMockRecorder) CommitTransaction(arg0 interface{}) *gomock.Call

CommitTransaction indicates an expected call of CommitTransaction

func (*MockJobsDBMockRecorder) DeleteExecuting 

func (mr *MockJobsDBMockRecorder) DeleteExecuting(arg0 interface{}) *gomock.Call

DeleteExecuting indicates an expected call of DeleteExecuting

func (*MockJobsDBMockRecorder) GetExecuting 

func (mr *MockJobsDBMockRecorder) GetExecuting(arg0 interface{}) *gomock.Call

GetExecuting indicates an expected call of GetExecuting

func (*MockJobsDBMockRecorder) GetIdentifier added in v1.0.0 

func (mr *MockJobsDBMockRecorder) GetIdentifier() *gomock.Call

GetIdentifier indicates an expected call of GetIdentifier

func (*MockJobsDBMockRecorder) GetImportingList added in v1.0.0 

func (mr *MockJobsDBMockRecorder) GetImportingList(arg0 interface{}) *gomock.Call

GetImportingList indicates an expected call of GetImportingList

func (*MockJobsDBMockRecorder) GetJournalEntries 

func (mr *MockJobsDBMockRecorder) GetJournalEntries(arg0 interface{}) *gomock.Call

GetJournalEntries indicates an expected call of GetJournalEntries

func (*MockJobsDBMockRecorder) GetProcessed 

func (mr *MockJobsDBMockRecorder) GetProcessed(arg0 interface{}) *gomock.Call

GetProcessed indicates an expected call of GetProcessed

func (*MockJobsDBMockRecorder) GetThrottled added in v1.0.0 

func (mr *MockJobsDBMockRecorder) GetThrottled(arg0 interface{}) *gomock.Call

GetThrottled indicates an expected call of GetThrottled

func (*MockJobsDBMockRecorder) GetToRetry 

func (mr *MockJobsDBMockRecorder) GetToRetry(arg0 interface{}) *gomock.Call

GetToRetry indicates an expected call of GetToRetry

func (*MockJobsDBMockRecorder) GetUnprocessed 

func (mr *MockJobsDBMockRecorder) GetUnprocessed(arg0 interface{}) *gomock.Call

GetUnprocessed indicates an expected call of GetUnprocessed

func (*MockJobsDBMockRecorder) GetWaiting 

func (mr *MockJobsDBMockRecorder) GetWaiting(arg0 interface{}) *gomock.Call

GetWaiting indicates an expected call of GetWaiting

func (*MockJobsDBMockRecorder) JournalDeleteEntry 

func (mr *MockJobsDBMockRecorder) JournalDeleteEntry(arg0 interface{}) *gomock.Call

JournalDeleteEntry indicates an expected call of JournalDeleteEntry

func (*MockJobsDBMockRecorder) JournalMarkStart 

func (mr *MockJobsDBMockRecorder) JournalMarkStart(arg0, arg1 interface{}) *gomock.Call

JournalMarkStart indicates an expected call of JournalMarkStart

func (*MockJobsDBMockRecorder) ReleaseStoreLock added in v1.0.0 

func (mr *MockJobsDBMockRecorder) ReleaseStoreLock() *gomock.Call

ReleaseStoreLock indicates an expected call of ReleaseStoreLock

func (*MockJobsDBMockRecorder) ReleaseUpdateJobStatusLocks added in v1.0.0 

func (mr *MockJobsDBMockRecorder) ReleaseUpdateJobStatusLocks() *gomock.Call

ReleaseUpdateJobStatusLocks indicates an expected call of ReleaseUpdateJobStatusLocks

func (*MockJobsDBMockRecorder) Status 

func (mr *MockJobsDBMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status

func (*MockJobsDBMockRecorder) Store 

func (mr *MockJobsDBMockRecorder) Store(arg0 interface{}) *gomock.Call

Store indicates an expected call of Store

func (*MockJobsDBMockRecorder) StoreWithRetryEach 

func (mr *MockJobsDBMockRecorder) StoreWithRetryEach(arg0 interface{}) *gomock.Call

StoreWithRetryEach indicates an expected call of StoreWithRetryEach

func (*MockJobsDBMockRecorder) UpdateJobStatus 

func (mr *MockJobsDBMockRecorder) UpdateJobStatus(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateJobStatus indicates an expected call of UpdateJobStatus

func (*MockJobsDBMockRecorder) UpdateJobStatusInTxn added in v1.0.0 

func (mr *MockJobsDBMockRecorder) UpdateJobStatusInTxn(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

UpdateJobStatusInTxn indicates an expected call of UpdateJobStatusInTxn

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.