mocks_jobsdb

package
v1.12.0-rc.2 Latest Latest
Warning

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

 Go to latest Published: Aug 11, 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) 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) GetExecuting 

func (m *MockJobsDB) GetExecuting(arg0 context.Context, arg1 jobsdb.GetQueryParamsT) (jobsdb.JobsResult, error)

GetExecuting mocks base method.

func (*MockJobsDB) GetImporting 

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

GetImporting 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) GetProcessed 

func (m *MockJobsDB) GetProcessed(arg0 context.Context, arg1 jobsdb.GetQueryParamsT) (jobsdb.JobsResult, error)

GetProcessed mocks base method.

func (*MockJobsDB) GetToProcess added in v1.11.0 

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

GetToProcess mocks base method.

func (*MockJobsDB) GetToRetry 

func (m *MockJobsDB) GetToRetry(arg0 context.Context, arg1 jobsdb.GetQueryParamsT) (jobsdb.JobsResult, error)

GetToRetry mocks base method.

func (*MockJobsDB) GetUnprocessed 

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

GetUnprocessed mocks base method.

func (*MockJobsDB) GetWaiting 

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

GetWaiting mocks base method.

func (*MockJobsDB) Identifier 

func (m *MockJobsDB) Identifier() string

Identifier 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) 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) GetExecuting 

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

GetExecuting indicates an expected call of GetExecuting.

func (*MockJobsDBMockRecorder) GetImporting 

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

GetImporting indicates an expected call of GetImporting.

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) GetProcessed 

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

GetProcessed indicates an expected call of GetProcessed.

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) GetToRetry 

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

GetToRetry indicates an expected call of GetToRetry.

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