mocks_jobsdb

package

v0.0.0-...-0ade494 Latest Latest Go to latest Published: Aug 26, 2022 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/serviceexchange/server

Documentation ¶

Overview ¶

Package mocks_jobsdb is a generated GoMock package.

Index ¶

type MockJobsDB
- func NewMockJobsDB(ctrl *gomock.Controller) *MockJobsDB
type MockJobsDBMockRecorder
type MockMultiTenantJobsDB
- func NewMockMultiTenantJobsDB(ctrl *gomock.Controller) *MockMultiTenantJobsDB
type MockMultiTenantJobsDBMockRecorder

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

func (m *MockJobsDB) GetExecuting(arg0 jobsdb.GetQueryParamsT) jobsdb.JobsResult

GetExecuting mocks base method.

func (*MockJobsDB) GetImporting ¶

func (m *MockJobsDB) GetImporting(arg0 jobsdb.GetQueryParamsT) jobsdb.JobsResult

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 map[string]map[string]int)

GetPileUpCounts mocks base method.

func (*MockJobsDB) GetProcessed ¶

func (m *MockJobsDB) GetProcessed(arg0 jobsdb.GetQueryParamsT) jobsdb.JobsResult

GetProcessed mocks base method.

func (*MockJobsDB) GetToRetry ¶

func (m *MockJobsDB) GetToRetry(arg0 jobsdb.GetQueryParamsT) jobsdb.JobsResult

GetToRetry mocks base method.

func (*MockJobsDB) GetUnprocessed ¶

func (m *MockJobsDB) GetUnprocessed(arg0 jobsdb.GetQueryParamsT) jobsdb.JobsResult

GetUnprocessed mocks base method.

func (*MockJobsDB) GetWaiting ¶

func (m *MockJobsDB) GetWaiting(arg0 jobsdb.GetQueryParamsT) jobsdb.JobsResult

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

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 func(jobsdb.StoreSafeTx) error) error

WithStoreSafeTx mocks base method.

func (*MockJobsDB) WithTx ¶

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

WithTx mocks base method.

func (*MockJobsDB) WithUpdateSafeTx ¶

func (m *MockJobsDB) WithUpdateSafeTx(arg0 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) GetExecuting ¶

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

GetExecuting indicates an expected call of GetExecuting.

func (*MockJobsDBMockRecorder) GetImporting ¶

func (mr *MockJobsDBMockRecorder) GetImporting(arg0 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 interface{}) *gomock.Call

GetProcessed indicates an expected call of GetProcessed.

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) 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 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 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) GetAllJobs ¶

func (m *MockMultiTenantJobsDB) GetAllJobs(arg0 map[string]int, arg1 jobsdb.GetQueryParamsT, arg2 int) []*jobsdb.JobT

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 map[string]map[string]int)

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 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) GetAllJobs ¶

func (mr *MockMultiTenantJobsDBMockRecorder) GetAllJobs(arg0, arg1, arg2 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 interface{}) *gomock.Call

WithUpdateSafeTx indicates an expected call of WithUpdateSafeTx.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL