mocks_jobsdb

package
v1.6.0-rc.6 Latest Latest
Warning

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

Go to latest
Published: Feb 22, 2023 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) GetActiveWorkspaces added in v1.6.0

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

GetActiveWorkspaces 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) GetActiveWorkspaces added in v1.6.0

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

GetActiveWorkspaces indicates an expected call of GetActiveWorkspaces.

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

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

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.

Jump to

Keyboard shortcuts

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