mocks_jobsdb

package
v1.13.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2023 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) DeleteExecuting 

func (m *MockJobsDB) DeleteExecuting()

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) FailExecuting added in v1.5.0 

func (m *MockJobsDB) FailExecuting()

FailExecuting mocks base method.

func (*MockJobsDB) GetAborted 

func (m *MockJobsDB) GetAborted(arg0 context.Context, arg1 jobsdb.GetQueryParams) (jobsdb.JobsResult, error)

GetAborted mocks base method.

func (*MockJobsDB) GetActiveWorkspaces added in v1.6.0 

func (m *MockJobsDB) GetActiveWorkspaces(arg0 context.Context, arg1 string) ([]string, error)

GetActiveWorkspaces mocks base method.

func (*MockJobsDB) GetDistinctParameterValues added in v1.8.0 

func (m *MockJobsDB) GetDistinctParameterValues(arg0 context.Context, arg1 string) ([]string, error)

GetDistinctParameterValues mocks base method.

func (*MockJobsDB) GetFailed 

func (m *MockJobsDB) GetFailed(arg0 context.Context, arg1 jobsdb.GetQueryParams) (jobsdb.JobsResult, error)

GetFailed mocks base method.

func (*MockJobsDB) GetImporting 

func (m *MockJobsDB) GetImporting(arg0 context.Context, arg1 jobsdb.GetQueryParams) (jobsdb.JobsResult, error)

GetImporting mocks base method.

func (*MockJobsDB) GetJobs 

func (m *MockJobsDB) GetJobs(arg0 context.Context, arg1 []string, arg2 jobsdb.GetQueryParams) (jobsdb.JobsResult, error)

GetJobs mocks base method.

func (*MockJobsDB) GetJournalEntries 

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

GetJournalEntries mocks base method.

func (*MockJobsDB) GetPileUpCounts 

func (m *MockJobsDB) GetPileUpCounts(arg0 context.Context) (map[string]map[string]int, error)

GetPileUpCounts mocks base method.

func (*MockJobsDB) GetSucceeded 

func (m *MockJobsDB) GetSucceeded(arg0 context.Context, arg1 jobsdb.GetQueryParams) (jobsdb.JobsResult, error)

GetSucceeded mocks base method.

func (*MockJobsDB) GetToProcess added in v1.11.0 

func (m *MockJobsDB) GetToProcess(arg0 context.Context, arg1 jobsdb.GetQueryParams, arg2 jobsdb.MoreToken) (*jobsdb.MoreJobsResult, error)

GetToProcess mocks base method.

func (*MockJobsDB) GetUnprocessed 

func (m *MockJobsDB) GetUnprocessed(arg0 context.Context, arg1 jobsdb.GetQueryParams) (jobsdb.JobsResult, error)

GetUnprocessed mocks base method.

func (*MockJobsDB) GetWaiting 

func (m *MockJobsDB) GetWaiting(arg0 context.Context, arg1 jobsdb.GetQueryParams) (jobsdb.JobsResult, error)

GetWaiting mocks base method.

func (*MockJobsDB) Identifier 

func (m *MockJobsDB) Identifier() string

Identifier mocks base method.

func (*MockJobsDB) IsMasterBackupEnabled 

func (m *MockJobsDB) IsMasterBackupEnabled() bool

IsMasterBackupEnabled mocks base method.

func (*MockJobsDB) JournalDeleteEntry 

func (m *MockJobsDB) JournalDeleteEntry(arg0 int64)

JournalDeleteEntry mocks base method.

func (*MockJobsDB) JournalMarkDone added in v1.10.0 

func (m *MockJobsDB) JournalMarkDone(arg0 int64) error

JournalMarkDone mocks base method.

func (*MockJobsDB) JournalMarkStart 

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

JournalMarkStart mocks base method.

func (*MockJobsDB) Ping 

func (m *MockJobsDB) Ping() error

Ping mocks base method.

func (*MockJobsDB) Store 

func (m *MockJobsDB) Store(arg0 context.Context, arg1 []*jobsdb.JobT) error

Store mocks base method.

func (*MockJobsDB) StoreEachBatchRetry added in v1.10.0 

func (m *MockJobsDB) StoreEachBatchRetry(arg0 context.Context, arg1 [][]*jobsdb.JobT) map[uuid.UUID]string

StoreEachBatchRetry mocks base method.

func (*MockJobsDB) StoreEachBatchRetryInTx added in v1.10.0 

func (m *MockJobsDB) StoreEachBatchRetryInTx(arg0 context.Context, arg1 jobsdb.StoreSafeTx, arg2 [][]*jobsdb.JobT) (map[uuid.UUID]string, error)

StoreEachBatchRetryInTx mocks base method.

func (*MockJobsDB) StoreInTx 

func (m *MockJobsDB) StoreInTx(arg0 context.Context, arg1 jobsdb.StoreSafeTx, arg2 []*jobsdb.JobT) error

StoreInTx mocks base method.

func (*MockJobsDB) UpdateJobStatus 

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

UpdateJobStatus mocks base method.

func (*MockJobsDB) UpdateJobStatusInTx 

func (m *MockJobsDB) UpdateJobStatusInTx(arg0 context.Context, arg1 jobsdb.UpdateSafeTx, arg2 []*jobsdb.JobStatusT, arg3 []string, arg4 []jobsdb.ParameterFilterT) error

UpdateJobStatusInTx mocks base method.

func (*MockJobsDB) WithStoreSafeTx 

func (m *MockJobsDB) WithStoreSafeTx(arg0 context.Context, arg1 func(jobsdb.StoreSafeTx) error) error

WithStoreSafeTx mocks base method.

func (*MockJobsDB) WithTx 

func (m *MockJobsDB) WithTx(arg0 func(*jobsdb.Tx) error) error

WithTx mocks base method.

func (*MockJobsDB) WithUpdateSafeTx 

func (m *MockJobsDB) WithUpdateSafeTx(arg0 context.Context, arg1 func(jobsdb.UpdateSafeTx) error) error

WithUpdateSafeTx mocks base method.

type MockJobsDBMockRecorder 

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

MockJobsDBMockRecorder is the mock recorder for MockJobsDB.

func (*MockJobsDBMockRecorder) DeleteExecuting 

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

DeleteExecuting indicates an expected call of DeleteExecuting.

func (*MockJobsDBMockRecorder) FailExecuting added in v1.5.0 

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

FailExecuting indicates an expected call of FailExecuting.

func (*MockJobsDBMockRecorder) GetAborted 

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

GetAborted indicates an expected call of GetAborted.

func (*MockJobsDBMockRecorder) GetActiveWorkspaces added in v1.6.0 

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

GetActiveWorkspaces indicates an expected call of GetActiveWorkspaces.

func (*MockJobsDBMockRecorder) GetDistinctParameterValues added in v1.8.0 

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

GetDistinctParameterValues indicates an expected call of GetDistinctParameterValues.

func (*MockJobsDBMockRecorder) GetFailed 

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

GetFailed indicates an expected call of GetFailed.

func (*MockJobsDBMockRecorder) GetImporting 

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

GetImporting indicates an expected call of GetImporting.

func (*MockJobsDBMockRecorder) GetJobs 

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

GetJobs indicates an expected call of GetJobs.

func (*MockJobsDBMockRecorder) GetJournalEntries 

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

GetJournalEntries indicates an expected call of GetJournalEntries.

func (*MockJobsDBMockRecorder) GetPileUpCounts 

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

GetPileUpCounts indicates an expected call of GetPileUpCounts.

func (*MockJobsDBMockRecorder) GetSucceeded 

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

GetSucceeded indicates an expected call of GetSucceeded.

func (*MockJobsDBMockRecorder) GetToProcess added in v1.11.0 

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

GetToProcess indicates an expected call of GetToProcess.

func (*MockJobsDBMockRecorder) GetUnprocessed 

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

GetUnprocessed indicates an expected call of GetUnprocessed.

func (*MockJobsDBMockRecorder) GetWaiting 

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

GetWaiting indicates an expected call of GetWaiting.

func (*MockJobsDBMockRecorder) Identifier 

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

Identifier indicates an expected call of Identifier.

func (*MockJobsDBMockRecorder) IsMasterBackupEnabled 

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

IsMasterBackupEnabled indicates an expected call of IsMasterBackupEnabled.

func (*MockJobsDBMockRecorder) JournalDeleteEntry 

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

JournalDeleteEntry indicates an expected call of JournalDeleteEntry.

func (*MockJobsDBMockRecorder) JournalMarkDone added in v1.10.0 

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

JournalMarkDone indicates an expected call of JournalMarkDone.

func (*MockJobsDBMockRecorder) JournalMarkStart 

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

JournalMarkStart indicates an expected call of JournalMarkStart.

func (*MockJobsDBMockRecorder) Ping 

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

Ping indicates an expected call of Ping.

func (*MockJobsDBMockRecorder) Store 

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

Store indicates an expected call of Store.

func (*MockJobsDBMockRecorder) StoreEachBatchRetry added in v1.10.0 

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

StoreEachBatchRetry indicates an expected call of StoreEachBatchRetry.

func (*MockJobsDBMockRecorder) StoreEachBatchRetryInTx added in v1.10.0 

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

StoreEachBatchRetryInTx indicates an expected call of StoreEachBatchRetryInTx.

func (*MockJobsDBMockRecorder) StoreInTx 

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

StoreInTx indicates an expected call of StoreInTx.

func (*MockJobsDBMockRecorder) UpdateJobStatus 

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

UpdateJobStatus indicates an expected call of UpdateJobStatus.

func (*MockJobsDBMockRecorder) UpdateJobStatusInTx 

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

UpdateJobStatusInTx indicates an expected call of UpdateJobStatusInTx.

func (*MockJobsDBMockRecorder) WithStoreSafeTx 

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

WithStoreSafeTx indicates an expected call of WithStoreSafeTx.

func (*MockJobsDBMockRecorder) WithTx 

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

WithTx indicates an expected call of WithTx.

func (*MockJobsDBMockRecorder) WithUpdateSafeTx 

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

WithUpdateSafeTx indicates an expected call of WithUpdateSafeTx.

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.