Documentation ¶
Index ¶
- type Application
- func (_m *Application) AddJobV2(ctx context.Context, _a1 *job.Job) error
- func (_m *Application) AuthenticationProvider() sessions.AuthenticationProvider
- func (_m *Application) BasicAdminUsersORM() sessions.BasicAdminUsersORM
- func (_m *Application) BridgeORM() bridges.ORM
- func (_m *Application) DeleteJob(ctx context.Context, jobID int32) error
- func (_m *Application) EVMORM() types.Configs
- func (_m *Application) GetAuditLogger() audit.AuditLogger
- func (_m *Application) GetConfig() erinaceus.GeneralConfig
- func (_m *Application) GetExternalInitiatorManager() webhook.ExternalInitiatorManager
- func (_m *Application) GetHealthChecker() services.Checker
- func (_m *Application) GetKeyStore() keystore.Master
- func (_m *Application) GetLogger() logger.SugaredLogger
- func (_m *Application) GetLoopRegistry() *plugins.LoopRegistry
- func (_m *Application) GetRelayers() erinaceus.RelayerChainInteroperators
- func (_m *Application) GetSqlxDB() *sqlx.DB
- func (_m *Application) GetWebAuthnConfiguration() sessions.WebAuthnConfiguration
- func (_m *Application) ID() uuid.UUID
- func (_m *Application) JobORM() job.ORM
- func (_m *Application) JobSpawner() job.Spawner
- func (_m *Application) PipelineORM() pipeline.ORM
- func (_m *Application) ReplayFromBlock(chainID *big.Int, number uint64, forceBroadcast bool) error
- func (_m *Application) ResumeJobV2(ctx context.Context, taskID uuid.UUID, result pipeline.Result) error
- func (_m *Application) RunJobV2(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)
- func (_m *Application) RunWebhookJobV2(ctx context.Context, jobUUID uuid.UUID, requestBody string, ...) (int64, error)
- func (_m *Application) SecretGenerator() erinaceus.SecretGenerator
- func (_m *Application) SetLogLevel(lvl zapcore.Level) error
- func (_m *Application) Start(ctx context.Context) error
- func (_m *Application) Stop() error
- func (_m *Application) TxmStorageService() txmgr.EvmTxStore
- func (_m *Application) WakeSessionReaper()
- type PrometheusBackend
- func (_m *PrometheusBackend) SetMaxUnconfirmedAge(_a0 *big.Int, _a1 float64)
- func (_m *PrometheusBackend) SetMaxUnconfirmedBlocks(_a0 *big.Int, _a1 int64)
- func (_m *PrometheusBackend) SetPipelineRunsQueued(n int)
- func (_m *PrometheusBackend) SetPipelineTaskRunsQueued(n int)
- func (_m *PrometheusBackend) SetUnconfirmedTransactions(_a0 *big.Int, _a1 int64)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Application ¶
Application is an autogenerated mock type for the Application type
func NewApplication ¶
func NewApplication(t interface { mock.TestingT Cleanup(func()) }) *Application
NewApplication creates a new instance of Application. 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 (*Application) AuthenticationProvider ¶
func (_m *Application) AuthenticationProvider() sessions.AuthenticationProvider
AuthenticationProvider provides a mock function with given fields:
func (*Application) BasicAdminUsersORM ¶
func (_m *Application) BasicAdminUsersORM() sessions.BasicAdminUsersORM
BasicAdminUsersORM provides a mock function with given fields:
func (*Application) BridgeORM ¶
func (_m *Application) BridgeORM() bridges.ORM
BridgeORM provides a mock function with given fields:
func (*Application) DeleteJob ¶
func (_m *Application) DeleteJob(ctx context.Context, jobID int32) error
DeleteJob provides a mock function with given fields: ctx, jobID
func (*Application) EVMORM ¶
func (_m *Application) EVMORM() types.Configs
EVMORM provides a mock function with given fields:
func (*Application) GetAuditLogger ¶
func (_m *Application) GetAuditLogger() audit.AuditLogger
GetAuditLogger provides a mock function with given fields:
func (*Application) GetConfig ¶
func (_m *Application) GetConfig() erinaceus.GeneralConfig
GetConfig provides a mock function with given fields:
func (*Application) GetExternalInitiatorManager ¶
func (_m *Application) GetExternalInitiatorManager() webhook.ExternalInitiatorManager
GetExternalInitiatorManager provides a mock function with given fields:
func (*Application) GetHealthChecker ¶
func (_m *Application) GetHealthChecker() services.Checker
GetHealthChecker provides a mock function with given fields:
func (*Application) GetKeyStore ¶
func (_m *Application) GetKeyStore() keystore.Master
GetKeyStore provides a mock function with given fields:
func (*Application) GetLogger ¶
func (_m *Application) GetLogger() logger.SugaredLogger
GetLogger provides a mock function with given fields:
func (*Application) GetLoopRegistry ¶
func (_m *Application) GetLoopRegistry() *plugins.LoopRegistry
GetLoopRegistry provides a mock function with given fields:
func (*Application) GetRelayers ¶
func (_m *Application) GetRelayers() erinaceus.RelayerChainInteroperators
GetRelayers provides a mock function with given fields:
func (*Application) GetSqlxDB ¶
func (_m *Application) GetSqlxDB() *sqlx.DB
GetSqlxDB provides a mock function with given fields:
func (*Application) GetWebAuthnConfiguration ¶
func (_m *Application) GetWebAuthnConfiguration() sessions.WebAuthnConfiguration
GetWebAuthnConfiguration provides a mock function with given fields:
func (*Application) ID ¶
func (_m *Application) ID() uuid.UUID
ID provides a mock function with given fields:
func (*Application) JobORM ¶
func (_m *Application) JobORM() job.ORM
JobORM provides a mock function with given fields:
func (*Application) JobSpawner ¶
func (_m *Application) JobSpawner() job.Spawner
JobSpawner provides a mock function with given fields:
func (*Application) PipelineORM ¶
func (_m *Application) PipelineORM() pipeline.ORM
PipelineORM provides a mock function with given fields:
func (*Application) ReplayFromBlock ¶
ReplayFromBlock provides a mock function with given fields: chainID, number, forceBroadcast
func (*Application) ResumeJobV2 ¶
func (_m *Application) ResumeJobV2(ctx context.Context, taskID uuid.UUID, result pipeline.Result) error
ResumeJobV2 provides a mock function with given fields: ctx, taskID, result
func (*Application) RunJobV2 ¶
func (_m *Application) RunJobV2(ctx context.Context, jobID int32, meta map[string]interface{}) (int64, error)
RunJobV2 provides a mock function with given fields: ctx, jobID, meta
func (*Application) RunWebhookJobV2 ¶
func (_m *Application) RunWebhookJobV2(ctx context.Context, jobUUID uuid.UUID, requestBody string, meta pipeline.JSONSerializable) (int64, error)
RunWebhookJobV2 provides a mock function with given fields: ctx, jobUUID, requestBody, meta
func (*Application) SecretGenerator ¶
func (_m *Application) SecretGenerator() erinaceus.SecretGenerator
SecretGenerator provides a mock function with given fields:
func (*Application) SetLogLevel ¶
func (_m *Application) SetLogLevel(lvl zapcore.Level) error
SetLogLevel provides a mock function with given fields: lvl
func (*Application) Start ¶
func (_m *Application) Start(ctx context.Context) error
Start provides a mock function with given fields: ctx
func (*Application) Stop ¶
func (_m *Application) Stop() error
Stop provides a mock function with given fields:
func (*Application) TxmStorageService ¶
func (_m *Application) TxmStorageService() txmgr.EvmTxStore
TxmStorageService provides a mock function with given fields:
func (*Application) WakeSessionReaper ¶
func (_m *Application) WakeSessionReaper()
WakeSessionReaper provides a mock function with given fields:
type PrometheusBackend ¶
PrometheusBackend is an autogenerated mock type for the PrometheusBackend type
func NewPrometheusBackend ¶
func NewPrometheusBackend(t interface { mock.TestingT Cleanup(func()) }) *PrometheusBackend
NewPrometheusBackend creates a new instance of PrometheusBackend. 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 (*PrometheusBackend) SetMaxUnconfirmedAge ¶
func (_m *PrometheusBackend) SetMaxUnconfirmedAge(_a0 *big.Int, _a1 float64)
SetMaxUnconfirmedAge provides a mock function with given fields: _a0, _a1
func (*PrometheusBackend) SetMaxUnconfirmedBlocks ¶
func (_m *PrometheusBackend) SetMaxUnconfirmedBlocks(_a0 *big.Int, _a1 int64)
SetMaxUnconfirmedBlocks provides a mock function with given fields: _a0, _a1
func (*PrometheusBackend) SetPipelineRunsQueued ¶
func (_m *PrometheusBackend) SetPipelineRunsQueued(n int)
SetPipelineRunsQueued provides a mock function with given fields: n
func (*PrometheusBackend) SetPipelineTaskRunsQueued ¶
func (_m *PrometheusBackend) SetPipelineTaskRunsQueued(n int)
SetPipelineTaskRunsQueued provides a mock function with given fields: n
func (*PrometheusBackend) SetUnconfirmedTransactions ¶
func (_m *PrometheusBackend) SetUnconfirmedTransactions(_a0 *big.Int, _a1 int64)
SetUnconfirmedTransactions provides a mock function with given fields: _a0, _a1