mocks

package
v2.12.1-starknet-20240802 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KVStore added in v2.10.0 

type KVStore struct {
	mock.Mock
}

KVStore is an autogenerated mock type for the KVStore type

func NewKVStore added in v2.10.0 

func NewKVStore(t interface {
	mock.TestingT
	Cleanup(func())
}) *KVStore

NewKVStore creates a new instance of KVStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*KVStore) Get added in v2.10.0 

func (_m *KVStore) Get(ctx context.Context, key string) ([]byte, error)

Get provides a mock function with given fields: ctx, key

func (*KVStore) Store added in v2.10.0 

func (_m *KVStore) Store(ctx context.Context, key string, val []byte) error

Store provides a mock function with given fields: ctx, key, val

type ORM 

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func NewORM 

func NewORM(t interface {
	mock.TestingT
	Cleanup(func())
}) *ORM

NewORM creates a new instance of ORM. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ORM) AssertBridgesExist 

func (_m *ORM) AssertBridgesExist(ctx context.Context, p pipeline.Pipeline) error

AssertBridgesExist provides a mock function with given fields: ctx, p

func (*ORM) Close 

func (_m *ORM) Close() error

Close provides a mock function with given fields:

func (*ORM) CountPipelineRunsByJobID 

func (_m *ORM) CountPipelineRunsByJobID(ctx context.Context, jobID int32) (int32, error)

CountPipelineRunsByJobID provides a mock function with given fields: ctx, jobID

func (*ORM) CreateJob 

func (_m *ORM) CreateJob(ctx context.Context, jb *job.Job) error

CreateJob provides a mock function with given fields: ctx, jb

func (*ORM) DataSource added in v2.12.0 

func (_m *ORM) DataSource() sqlutil.DataSource

DataSource provides a mock function with given fields:

func (*ORM) DeleteJob 

func (_m *ORM) DeleteJob(ctx context.Context, id int32) error

DeleteJob provides a mock function with given fields: ctx, id

func (*ORM) DismissError 

func (_m *ORM) DismissError(ctx context.Context, errorID int64) error

DismissError provides a mock function with given fields: ctx, errorID

func (*ORM) FindJob 

func (_m *ORM) FindJob(ctx context.Context, id int32) (job.Job, error)

FindJob provides a mock function with given fields: ctx, id

func (*ORM) FindJobByExternalJobID 

func (_m *ORM) FindJobByExternalJobID(ctx context.Context, _a1 uuid.UUID) (job.Job, error)

FindJobByExternalJobID provides a mock function with given fields: ctx, _a1

func (*ORM) FindJobIDByAddress 

func (_m *ORM) FindJobIDByAddress(ctx context.Context, address types.EIP55Address, evmChainID *big.Big) (int32, error)

FindJobIDByAddress provides a mock function with given fields: ctx, address, evmChainID

func (*ORM) FindJobIDsWithBridge 

func (_m *ORM) FindJobIDsWithBridge(ctx context.Context, name string) ([]int32, error)

FindJobIDsWithBridge provides a mock function with given fields: ctx, name

func (*ORM) FindJobTx 

func (_m *ORM) FindJobTx(ctx context.Context, id int32) (job.Job, error)

FindJobTx provides a mock function with given fields: ctx, id

func (*ORM) FindJobWithoutSpecErrors 

func (_m *ORM) FindJobWithoutSpecErrors(ctx context.Context, id int32) (job.Job, error)

FindJobWithoutSpecErrors provides a mock function with given fields: ctx, id

func (*ORM) FindJobs 

func (_m *ORM) FindJobs(ctx context.Context, offset int, limit int) ([]job.Job, int, error)

FindJobs provides a mock function with given fields: ctx, offset, limit

func (*ORM) FindJobsByPipelineSpecIDs 

func (_m *ORM) FindJobsByPipelineSpecIDs(ctx context.Context, ids []int32) ([]job.Job, error)

FindJobsByPipelineSpecIDs provides a mock function with given fields: ctx, ids

func (*ORM) FindOCR2JobIDByAddress added in v2.3.0 

func (_m *ORM) FindOCR2JobIDByAddress(ctx context.Context, contractID string, feedID *common.Hash) (int32, error)

FindOCR2JobIDByAddress provides a mock function with given fields: ctx, contractID, feedID

func (*ORM) FindPipelineRunByID 

func (_m *ORM) FindPipelineRunByID(ctx context.Context, id int64) (pipeline.Run, error)

FindPipelineRunByID provides a mock function with given fields: ctx, id

func (*ORM) FindPipelineRunIDsByJobID 

func (_m *ORM) FindPipelineRunIDsByJobID(ctx context.Context, jobID int32, offset int, limit int) ([]int64, error)

FindPipelineRunIDsByJobID provides a mock function with given fields: ctx, jobID, offset, limit

func (*ORM) FindPipelineRunsByIDs 

func (_m *ORM) FindPipelineRunsByIDs(ctx context.Context, ids []int64) ([]pipeline.Run, error)

FindPipelineRunsByIDs provides a mock function with given fields: ctx, ids

func (*ORM) FindSpecError 

func (_m *ORM) FindSpecError(ctx context.Context, id int64) (job.SpecError, error)

FindSpecError provides a mock function with given fields: ctx, id

func (*ORM) FindSpecErrorsByJobIDs 

func (_m *ORM) FindSpecErrorsByJobIDs(ctx context.Context, ids []int32) ([]job.SpecError, error)

FindSpecErrorsByJobIDs provides a mock function with given fields: ctx, ids

func (*ORM) FindTaskResultByRunIDAndTaskName 

func (_m *ORM) FindTaskResultByRunIDAndTaskName(ctx context.Context, runID int64, taskName string) ([]byte, error)

FindTaskResultByRunIDAndTaskName provides a mock function with given fields: ctx, runID, taskName

func (*ORM) InsertJob 

func (_m *ORM) InsertJob(ctx context.Context, _a1 *job.Job) error

InsertJob provides a mock function with given fields: ctx, _a1

func (*ORM) InsertWebhookSpec 

func (_m *ORM) InsertWebhookSpec(ctx context.Context, webhookSpec *job.WebhookSpec) error

InsertWebhookSpec provides a mock function with given fields: ctx, webhookSpec

func (*ORM) PipelineRuns 

func (_m *ORM) PipelineRuns(ctx context.Context, jobID *int32, offset int, size int) ([]pipeline.Run, int, error)

PipelineRuns provides a mock function with given fields: ctx, jobID, offset, size

func (*ORM) RecordError 

func (_m *ORM) RecordError(ctx context.Context, jobID int32, description string) error

RecordError provides a mock function with given fields: ctx, jobID, description

func (*ORM) TryRecordError 

func (_m *ORM) TryRecordError(ctx context.Context, jobID int32, description string)

TryRecordError provides a mock function with given fields: ctx, jobID, description

func (*ORM) WithDataSource added in v2.12.0 

func (_m *ORM) WithDataSource(source sqlutil.DataSource) job.ORM

WithDataSource provides a mock function with given fields: source

type ServiceCtx 

type ServiceCtx struct {
	mock.Mock
}

ServiceCtx is an autogenerated mock type for the ServiceCtx type

func NewServiceCtx 

func NewServiceCtx(t interface {
	mock.TestingT
	Cleanup(func())
}) *ServiceCtx

NewServiceCtx creates a new instance of ServiceCtx. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ServiceCtx) Close 

func (_m *ServiceCtx) Close() error

Close provides a mock function with given fields:

func (*ServiceCtx) Start 

func (_m *ServiceCtx) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

type Spawner 

type Spawner struct {
	mock.Mock
}

Spawner is an autogenerated mock type for the Spawner type

func NewSpawner 

func NewSpawner(t interface {
	mock.TestingT
	Cleanup(func())
}) *Spawner

NewSpawner creates a new instance of Spawner. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Spawner) ActiveJobs 

func (_m *Spawner) ActiveJobs() map[int32]job.Job

ActiveJobs provides a mock function with given fields:

func (*Spawner) Close 

func (_m *Spawner) Close() error

Close provides a mock function with given fields:

func (*Spawner) CreateJob 

func (_m *Spawner) CreateJob(ctx context.Context, ds sqlutil.DataSource, jb *job.Job) error

CreateJob provides a mock function with given fields: ctx, ds, jb

func (*Spawner) DeleteJob 

func (_m *Spawner) DeleteJob(ctx context.Context, ds sqlutil.DataSource, jobID int32) error

DeleteJob provides a mock function with given fields: ctx, ds, jobID

func (*Spawner) HealthReport 

func (_m *Spawner) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*Spawner) Name 

func (_m *Spawner) Name() string

Name provides a mock function with given fields:

func (*Spawner) Ready 

func (_m *Spawner) Ready() error

Ready provides a mock function with given fields:

func (*Spawner) Start 

func (_m *Spawner) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

func (*Spawner) StartService 

func (_m *Spawner) StartService(ctx context.Context, spec job.Job) error

StartService provides a mock function with given fields: ctx, spec

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.