mocks_jobsdb

package
v1.5.0-preview.1 Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2022 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mocks_jobsdb is a generated GoMock package.

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

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

JournalMarkStart mocks base method.

func (*MockJobsDB) Ping 

func (m *MockJobsDB) Ping() error

Ping mocks base method.

func (*MockJobsDB) Status 

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

Status mocks base method.

func (*MockJobsDB) Store 

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

Store 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) StoreWithRetryEach 

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

StoreWithRetryEach mocks base method.

func (*MockJobsDB) StoreWithRetryEachInTx 

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

StoreWithRetryEachInTx 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) 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) 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) 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) Status 

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

Status indicates an expected call of Status.

func (*MockJobsDBMockRecorder) Store 

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

Store indicates an expected call of Store.

func (*MockJobsDBMockRecorder) StoreInTx 

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

StoreInTx indicates an expected call of StoreInTx.

func (*MockJobsDBMockRecorder) StoreWithRetryEach 

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

StoreWithRetryEach indicates an expected call of StoreWithRetryEach.

func (*MockJobsDBMockRecorder) StoreWithRetryEachInTx 

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

StoreWithRetryEachInTx indicates an expected call of StoreWithRetryEachInTx.

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.

type MockMultiTenantJobsDB 

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

MockMultiTenantJobsDB is a mock of MultiTenantJobsDB interface.

func NewMockMultiTenantJobsDB 

func NewMockMultiTenantJobsDB(ctrl *gomock.Controller) *MockMultiTenantJobsDB

NewMockMultiTenantJobsDB creates a new mock instance.

func (*MockMultiTenantJobsDB) DeleteExecuting 

func (m *MockMultiTenantJobsDB) DeleteExecuting()

DeleteExecuting mocks base method.

func (*MockMultiTenantJobsDB) EXPECT 

func (m *MockMultiTenantJobsDB) EXPECT() *MockMultiTenantJobsDBMockRecorder

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

func (*MockMultiTenantJobsDB) FailExecuting added in v1.5.0 

func (m *MockMultiTenantJobsDB) FailExecuting()

FailExecuting mocks base method.

func (*MockMultiTenantJobsDB) GetAllJobs 

func (m *MockMultiTenantJobsDB) GetAllJobs(arg0 context.Context, arg1 map[string]int, arg2 jobsdb.GetQueryParamsT, arg3 int, arg4 jobsdb.MoreToken) (*jobsdb.GetAllJobsResult, error)

GetAllJobs mocks base method.

func (*MockMultiTenantJobsDB) GetJournalEntries 

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

GetJournalEntries mocks base method.

func (*MockMultiTenantJobsDB) GetPileUpCounts 

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

GetPileUpCounts mocks base method.

func (*MockMultiTenantJobsDB) JournalDeleteEntry 

func (m *MockMultiTenantJobsDB) JournalDeleteEntry(arg0 int64)

JournalDeleteEntry mocks base method.

func (*MockMultiTenantJobsDB) JournalMarkStart 

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

JournalMarkStart mocks base method.

func (*MockMultiTenantJobsDB) UpdateJobStatus 

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

UpdateJobStatus mocks base method.

func (*MockMultiTenantJobsDB) UpdateJobStatusInTx 

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

UpdateJobStatusInTx mocks base method.

func (*MockMultiTenantJobsDB) WithUpdateSafeTx 

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

WithUpdateSafeTx mocks base method.

type MockMultiTenantJobsDBMockRecorder 

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

MockMultiTenantJobsDBMockRecorder is the mock recorder for MockMultiTenantJobsDB.

func (*MockMultiTenantJobsDBMockRecorder) DeleteExecuting 

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

DeleteExecuting indicates an expected call of DeleteExecuting.

func (*MockMultiTenantJobsDBMockRecorder) FailExecuting added in v1.5.0 

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

FailExecuting indicates an expected call of FailExecuting.

func (*MockMultiTenantJobsDBMockRecorder) GetAllJobs 

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

GetAllJobs indicates an expected call of GetAllJobs.

func (*MockMultiTenantJobsDBMockRecorder) GetJournalEntries 

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

GetJournalEntries indicates an expected call of GetJournalEntries.

func (*MockMultiTenantJobsDBMockRecorder) GetPileUpCounts 

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

GetPileUpCounts indicates an expected call of GetPileUpCounts.

func (*MockMultiTenantJobsDBMockRecorder) JournalDeleteEntry 

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

JournalDeleteEntry indicates an expected call of JournalDeleteEntry.

func (*MockMultiTenantJobsDBMockRecorder) JournalMarkStart 

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

JournalMarkStart indicates an expected call of JournalMarkStart.

func (*MockMultiTenantJobsDBMockRecorder) UpdateJobStatus 

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

UpdateJobStatus indicates an expected call of UpdateJobStatus.

func (*MockMultiTenantJobsDBMockRecorder) UpdateJobStatusInTx 

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

UpdateJobStatusInTx indicates an expected call of UpdateJobStatusInTx.

func (*MockMultiTenantJobsDBMockRecorder) WithUpdateSafeTx 

func (mr *MockMultiTenantJobsDBMockRecorder) 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.