Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- func NewDummyOracle(ctx context.Context, ot core.RegisterType, opts ...component.Option) (component.Component, error)
- func NewDummyPipe(ctx context.Context, it core.RegisterType, ot core.RegisterType, ...) (component.Component, error)
- type AlertManager
- type AlertManagerMockRecorder
- type EngineManager
- func (m *EngineManager) DeleteHeuristicSession(arg0 core.SUUID) (core.SUUID, error)
- func (m *EngineManager) DeployHeuristicSession(arg0 *heuristic.DeployConfig) (core.SUUID, error)
- func (m *EngineManager) EXPECT() *EngineManagerMockRecorder
- func (m *EngineManager) EventLoop() error
- func (m *EngineManager) GetInputType(arg0 core.HeuristicType) (core.RegisterType, error)
- func (m *EngineManager) Shutdown() error
- func (m *EngineManager) Transit() chan core.HeuristicInput
- type EngineManagerMockRecorder
- func (mr *EngineManagerMockRecorder) DeleteHeuristicSession(arg0 interface{}) *gomock.Call
- func (mr *EngineManagerMockRecorder) DeployHeuristicSession(arg0 interface{}) *gomock.Call
- func (mr *EngineManagerMockRecorder) EventLoop() *gomock.Call
- func (mr *EngineManagerMockRecorder) GetInputType(arg0 interface{}) *gomock.Call
- func (mr *EngineManagerMockRecorder) Shutdown() *gomock.Call
- func (mr *EngineManagerMockRecorder) Transit() *gomock.Call
- type EtlManager
- func (m *EtlManager) ActiveCount() int
- func (m *EtlManager) CreateDataPipeline(arg0 *core.PipelineConfig) (core.PUUID, bool, error)
- func (m *EtlManager) EXPECT() *EtlManagerMockRecorder
- func (m *EtlManager) EventLoop() error
- func (m *EtlManager) GetStateKey(arg0 core.RegisterType) (*core.StateKey, bool, error)
- func (m *EtlManager) InferComponent(arg0 *core.ClientConfig, arg1 core.CUUID, arg2 core.PUUID, ...) (component.Component, error)
- func (m *EtlManager) RunPipeline(arg0 core.PUUID) error
- func (m *EtlManager) Shutdown() error
- type EtlManagerMockRecorder
- func (mr *EtlManagerMockRecorder) ActiveCount() *gomock.Call
- func (mr *EtlManagerMockRecorder) CreateDataPipeline(arg0 interface{}) *gomock.Call
- func (mr *EtlManagerMockRecorder) EventLoop() *gomock.Call
- func (mr *EtlManagerMockRecorder) GetStateKey(arg0 interface{}) *gomock.Call
- func (mr *EtlManagerMockRecorder) InferComponent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *EtlManagerMockRecorder) RunPipeline(arg0 interface{}) *gomock.Call
- func (mr *EtlManagerMockRecorder) Shutdown() *gomock.Call
- type MockAlertClient
- type MockAlertClientMockRecorder
- type MockClientMap
- func (m *MockClientMap) EXPECT() *MockClientMapMockRecorder
- func (m *MockClientMap) GetPagerDutyClients(arg0 core.Severity) []client.PagerDutyClient
- func (m *MockClientMap) GetSlackClients(arg0 core.Severity) []client.SlackClient
- func (m *MockClientMap) InitializeRouting(arg0 *core.AlertRoutingParams)
- func (m *MockClientMap) SetPagerDutyClients(arg0 []client.PagerDutyClient, arg1 core.Severity)
- func (m *MockClientMap) SetSlackClients(arg0 []client.SlackClient, arg1 core.Severity)
- type MockClientMapMockRecorder
- func (mr *MockClientMapMockRecorder) GetPagerDutyClients(arg0 interface{}) *gomock.Call
- func (mr *MockClientMapMockRecorder) GetSlackClients(arg0 interface{}) *gomock.Call
- func (mr *MockClientMapMockRecorder) InitAlertClients(arg0 interface{}) *gomock.Call
- func (mr *MockClientMapMockRecorder) SetPagerDutyClients(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMapMockRecorder) SetSlackClients(arg0, arg1 interface{}) *gomock.Call
- type MockEthClient
- func (m *MockEthClient) BalanceAt(arg0 context.Context, arg1 common.Address, arg2 *big.Int) (*big.Int, error)
- func (m *MockEthClient) BlockByNumber(arg0 context.Context, arg1 *big.Int) (*types.Block, error)
- func (m *MockEthClient) CallContract(arg0 context.Context, arg1 ethereum.CallMsg, arg2 *big.Int) ([]byte, error)
- func (m *MockEthClient) CodeAt(arg0 context.Context, arg1 common.Address, arg2 *big.Int) ([]byte, error)
- func (m *MockEthClient) EXPECT() *MockEthClientMockRecorder
- func (m *MockEthClient) FilterLogs(arg0 context.Context, arg1 ethereum.FilterQuery) ([]types.Log, error)
- func (m *MockEthClient) HeaderByNumber(arg0 context.Context, arg1 *big.Int) (*types.Header, error)
- func (m *MockEthClient) SubscribeFilterLogs(arg0 context.Context, arg1 ethereum.FilterQuery, arg2 chan<- types.Log) (ethereum.Subscription, error)
- type MockEthClientMockRecorder
- func (mr *MockEthClientMockRecorder) BalanceAt(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockEthClientMockRecorder) BlockByNumber(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEthClientMockRecorder) CallContract(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockEthClientMockRecorder) CodeAt(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockEthClientMockRecorder) FilterLogs(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEthClientMockRecorder) HeaderByNumber(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEthClientMockRecorder) SubscribeFilterLogs(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockGethClient
- type MockGethClientMockRecorder
- type MockHeuristic
- func (m *MockHeuristic) Assess(arg0 core.TransitData) (*core.Activation, bool, error)
- func (m *MockHeuristic) EXPECT() *MockHeuristicMockRecorder
- func (m *MockHeuristic) InputType() core.RegisterType
- func (m *MockHeuristic) SUUID() core.SUUID
- func (m *MockHeuristic) SetSUUID(arg0 core.SUUID)
- func (m *MockHeuristic) ValidateInput(arg0 core.TransitData) error
- type MockHeuristicMockRecorder
- func (mr *MockHeuristicMockRecorder) Assess(arg0 interface{}) *gomock.Call
- func (mr *MockHeuristicMockRecorder) InputType() *gomock.Call
- func (mr *MockHeuristicMockRecorder) SUUID() *gomock.Call
- func (mr *MockHeuristicMockRecorder) SetSUUID(arg0 interface{}) *gomock.Call
- func (mr *MockHeuristicMockRecorder) ValidateInput(arg0 interface{}) *gomock.Call
- type MockPagerDutyClient
- type MockPagerDutyClientMockRecorder
- type MockRoutingDirectory
- func (m *MockRoutingDirectory) EXPECT() *MockRoutingDirectoryMockRecorder
- func (m *MockRoutingDirectory) GetPagerDutyClients(arg0 core.Severity) []client.PagerDutyClient
- func (m *MockRoutingDirectory) GetSlackClients(arg0 core.Severity) []client.SlackClient
- func (m *MockRoutingDirectory) InitializeRouting(arg0 *core.AlertRoutingParams)
- func (m *MockRoutingDirectory) SetPagerDutyClients(arg0 []client.PagerDutyClient, arg1 core.Severity)
- func (m *MockRoutingDirectory) SetSlackClients(arg0 []client.SlackClient, arg1 core.Severity)
- type MockRoutingDirectoryMockRecorder
- func (mr *MockRoutingDirectoryMockRecorder) GetPagerDutyClients(arg0 interface{}) *gomock.Call
- func (mr *MockRoutingDirectoryMockRecorder) GetSlackClients(arg0 interface{}) *gomock.Call
- func (mr *MockRoutingDirectoryMockRecorder) InitializeRouting(arg0 interface{}) *gomock.Call
- func (mr *MockRoutingDirectoryMockRecorder) SetPagerDutyClients(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRoutingDirectoryMockRecorder) SetSlackClients(arg0, arg1 interface{}) *gomock.Call
- type MockService
- func (m *MockService) CheckETHRPCHealth(arg0 core.Network) bool
- func (m *MockService) CheckHealth() *models.HealthCheck
- func (m *MockService) EXPECT() *MockServiceMockRecorder
- func (m *MockService) ProcessHeuristicRequest(arg0 *models.SessionRequestBody) (core.SUUID, error)
- func (m *MockService) RunHeuristicSession(arg0 *models.SessionRequestParams) (core.SUUID, error)
- type MockServiceMockRecorder
- func (mr *MockServiceMockRecorder) CheckETHRPCHealth(arg0 interface{}) *gomock.Call
- func (mr *MockServiceMockRecorder) CheckHealth() *gomock.Call
- func (mr *MockServiceMockRecorder) ProcessHeuristicRequest(arg0 interface{}) *gomock.Call
- func (mr *MockServiceMockRecorder) RunHeuristicSession(arg0 interface{}) *gomock.Call
- type MockSlackClient
- type MockSlackClientMockRecorder
- type MockSuite
- type SubManager
- func (m *SubManager) BuildDeployCfg(arg0 *core.PipelineConfig, arg1 *core.SessionConfig) (*heuristic.DeployConfig, error)
- func (m *SubManager) BuildPipelineCfg(arg0 *models.SessionRequestParams) (*core.PipelineConfig, error)
- func (m *SubManager) EXPECT() *SubManagerMockRecorder
- func (m *SubManager) RunSession(arg0 *heuristic.DeployConfig) (core.SUUID, error)
- func (m *SubManager) Shutdown() error
- func (m *SubManager) StartEventRoutines(arg0 context.Context)
- type SubManagerMockRecorder
- func (mr *SubManagerMockRecorder) BuildDeployCfg(arg0, arg1 interface{}) *gomock.Call
- func (mr *SubManagerMockRecorder) BuildPipelineCfg(arg0 interface{}) *gomock.Call
- func (mr *SubManagerMockRecorder) RunSession(arg0 interface{}) *gomock.Call
- func (mr *SubManagerMockRecorder) Shutdown() *gomock.Call
- func (mr *SubManagerMockRecorder) StartEventRoutines(arg0 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDummyOracle ¶
func NewDummyOracle(ctx context.Context, ot core.RegisterType, opts ...component.Option) (component.Component, error)
NewDummyOracle ... Takes in a register type that specifies the mocked output type Useful for testing inter-component connectivity and higher level component management abstractions
func NewDummyPipe ¶
func NewDummyPipe(ctx context.Context, it core.RegisterType, ot core.RegisterType, opts ...component.Option) (component.Component, error)
NewDummyPipe ... Takes in a register type that specifies the mocked output type Useful for testing inter-component connectivity and higher level component management abstractions
Types ¶
type AlertManager ¶
type AlertManager struct {
// contains filtered or unexported fields
}
AlertManager is a mock of Manager interface.
func NewAlertManager ¶
func NewAlertManager(ctrl *gomock.Controller) *AlertManager
NewAlertManager creates a new mock instance.
func (*AlertManager) AddSession ¶
func (m *AlertManager) AddSession(arg0 core.SUUID, arg1 *core.AlertPolicy) error
AddSession mocks base method.
func (*AlertManager) EXPECT ¶
func (m *AlertManager) EXPECT() *AlertManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*AlertManager) EventLoop ¶
func (m *AlertManager) EventLoop() error
EventLoop mocks base method.
func (*AlertManager) Transit ¶
func (m *AlertManager) Transit() chan core.Alert
Transit mocks base method.
type AlertManagerMockRecorder ¶
type AlertManagerMockRecorder struct {
// contains filtered or unexported fields
}
AlertManagerMockRecorder is the mock recorder for AlertManager.
func (*AlertManagerMockRecorder) AddSession ¶
func (mr *AlertManagerMockRecorder) AddSession(arg0, arg1 interface{}) *gomock.Call
AddSession indicates an expected call of AddSession.
func (*AlertManagerMockRecorder) EventLoop ¶
func (mr *AlertManagerMockRecorder) EventLoop() *gomock.Call
EventLoop indicates an expected call of EventLoop.
func (*AlertManagerMockRecorder) Shutdown ¶
func (mr *AlertManagerMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*AlertManagerMockRecorder) Transit ¶
func (mr *AlertManagerMockRecorder) Transit() *gomock.Call
Transit indicates an expected call of Transit.
type EngineManager ¶
type EngineManager struct {
// contains filtered or unexported fields
}
EngineManager is a mock of Manager interface.
func NewEngineManager ¶
func NewEngineManager(ctrl *gomock.Controller) *EngineManager
NewEngineManager creates a new mock instance.
func (*EngineManager) DeleteHeuristicSession ¶ added in v1.0.0
DeleteHeuristicSession mocks base method.
func (*EngineManager) DeployHeuristicSession ¶ added in v1.0.0
func (m *EngineManager) DeployHeuristicSession(arg0 *heuristic.DeployConfig) (core.SUUID, error)
DeployHeuristicSession mocks base method.
func (*EngineManager) EXPECT ¶
func (m *EngineManager) EXPECT() *EngineManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*EngineManager) EventLoop ¶
func (m *EngineManager) EventLoop() error
EventLoop mocks base method.
func (*EngineManager) GetInputType ¶
func (m *EngineManager) GetInputType(arg0 core.HeuristicType) (core.RegisterType, error)
GetInputType mocks base method.
func (*EngineManager) Shutdown ¶
func (m *EngineManager) Shutdown() error
Shutdown mocks base method.
func (*EngineManager) Transit ¶
func (m *EngineManager) Transit() chan core.HeuristicInput
Transit mocks base method.
type EngineManagerMockRecorder ¶
type EngineManagerMockRecorder struct {
// contains filtered or unexported fields
}
EngineManagerMockRecorder is the mock recorder for EngineManager.
func (*EngineManagerMockRecorder) DeleteHeuristicSession ¶ added in v1.0.0
func (mr *EngineManagerMockRecorder) DeleteHeuristicSession(arg0 interface{}) *gomock.Call
DeleteHeuristicSession indicates an expected call of DeleteHeuristicSession.
func (*EngineManagerMockRecorder) DeployHeuristicSession ¶ added in v1.0.0
func (mr *EngineManagerMockRecorder) DeployHeuristicSession(arg0 interface{}) *gomock.Call
DeployHeuristicSession indicates an expected call of DeployHeuristicSession.
func (*EngineManagerMockRecorder) EventLoop ¶
func (mr *EngineManagerMockRecorder) EventLoop() *gomock.Call
EventLoop indicates an expected call of EventLoop.
func (*EngineManagerMockRecorder) GetInputType ¶
func (mr *EngineManagerMockRecorder) GetInputType(arg0 interface{}) *gomock.Call
GetInputType indicates an expected call of GetInputType.
func (*EngineManagerMockRecorder) Shutdown ¶
func (mr *EngineManagerMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*EngineManagerMockRecorder) Transit ¶
func (mr *EngineManagerMockRecorder) Transit() *gomock.Call
Transit indicates an expected call of Transit.
type EtlManager ¶
type EtlManager struct {
// contains filtered or unexported fields
}
EtlManager is a mock of Manager interface.
func NewEtlManager ¶
func NewEtlManager(ctrl *gomock.Controller) *EtlManager
NewEtlManager creates a new mock instance.
func (*EtlManager) ActiveCount ¶
func (m *EtlManager) ActiveCount() int
ActiveCount mocks base method.
func (*EtlManager) CreateDataPipeline ¶
func (m *EtlManager) CreateDataPipeline(arg0 *core.PipelineConfig) (core.PUUID, bool, error)
CreateDataPipeline mocks base method.
func (*EtlManager) EXPECT ¶
func (m *EtlManager) EXPECT() *EtlManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*EtlManager) GetStateKey ¶
func (m *EtlManager) GetStateKey(arg0 core.RegisterType) (*core.StateKey, bool, error)
GetStateKey mocks base method.
func (*EtlManager) InferComponent ¶
func (m *EtlManager) InferComponent(arg0 *core.ClientConfig, arg1 core.CUUID, arg2 core.PUUID, arg3 *core.DataRegister) (component.Component, error)
InferComponent mocks base method.
func (*EtlManager) RunPipeline ¶
func (m *EtlManager) RunPipeline(arg0 core.PUUID) error
RunPipeline mocks base method.
type EtlManagerMockRecorder ¶
type EtlManagerMockRecorder struct {
// contains filtered or unexported fields
}
EtlManagerMockRecorder is the mock recorder for EtlManager.
func (*EtlManagerMockRecorder) ActiveCount ¶
func (mr *EtlManagerMockRecorder) ActiveCount() *gomock.Call
ActiveCount indicates an expected call of ActiveCount.
func (*EtlManagerMockRecorder) CreateDataPipeline ¶
func (mr *EtlManagerMockRecorder) CreateDataPipeline(arg0 interface{}) *gomock.Call
CreateDataPipeline indicates an expected call of CreateDataPipeline.
func (*EtlManagerMockRecorder) EventLoop ¶
func (mr *EtlManagerMockRecorder) EventLoop() *gomock.Call
EventLoop indicates an expected call of EventLoop.
func (*EtlManagerMockRecorder) GetStateKey ¶
func (mr *EtlManagerMockRecorder) GetStateKey(arg0 interface{}) *gomock.Call
GetStateKey indicates an expected call of GetStateKey.
func (*EtlManagerMockRecorder) InferComponent ¶
func (mr *EtlManagerMockRecorder) InferComponent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
InferComponent indicates an expected call of InferComponent.
func (*EtlManagerMockRecorder) RunPipeline ¶
func (mr *EtlManagerMockRecorder) RunPipeline(arg0 interface{}) *gomock.Call
RunPipeline indicates an expected call of RunPipeline.
func (*EtlManagerMockRecorder) Shutdown ¶
func (mr *EtlManagerMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
type MockAlertClient ¶ added in v1.0.0
type MockAlertClient struct {
// contains filtered or unexported fields
}
MockAlertClient is a mock of AlertClient interface.
func NewMockAlertClient ¶ added in v1.0.0
func NewMockAlertClient(ctrl *gomock.Controller) *MockAlertClient
NewMockAlertClient creates a new mock instance.
func (*MockAlertClient) EXPECT ¶ added in v1.0.0
func (m *MockAlertClient) EXPECT() *MockAlertClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAlertClient) PostEvent ¶ added in v1.0.0
func (m *MockAlertClient) PostEvent(arg0 context.Context, arg1 *alert_client.AlertEventTrigger) (*alert_client.AlertAPIResponse, error)
PostEvent mocks base method.
type MockAlertClientMockRecorder ¶ added in v1.0.0
type MockAlertClientMockRecorder struct {
// contains filtered or unexported fields
}
MockAlertClientMockRecorder is the mock recorder for MockAlertClient.
func (*MockAlertClientMockRecorder) PostEvent ¶ added in v1.0.0
func (mr *MockAlertClientMockRecorder) PostEvent(arg0, arg1 interface{}) *gomock.Call
PostEvent indicates an expected call of PostEvent.
type MockClientMap ¶ added in v1.0.0
type MockClientMap struct {
// contains filtered or unexported fields
}
MockClientMap is a mock of ClientMap interface.
func NewMockClientMap ¶ added in v1.0.0
func NewMockClientMap(ctrl *gomock.Controller) *MockClientMap
NewMockClientMap creates a new mock instance.
func (*MockClientMap) EXPECT ¶ added in v1.0.0
func (m *MockClientMap) EXPECT() *MockClientMapMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClientMap) GetPagerDutyClients ¶ added in v1.0.0
func (m *MockClientMap) GetPagerDutyClients(arg0 core.Severity) []client.PagerDutyClient
GetPagerDutyClients mocks base method.
func (*MockClientMap) GetSlackClients ¶ added in v1.0.0
func (m *MockClientMap) GetSlackClients(arg0 core.Severity) []client.SlackClient
GetSlackClients mocks base method.
func (*MockClientMap) InitializeRouting ¶ added in v1.0.0
func (m *MockClientMap) InitializeRouting(arg0 *core.AlertRoutingParams)
InitAlertClients mocks base method.
func (*MockClientMap) SetPagerDutyClients ¶ added in v1.0.0
func (m *MockClientMap) SetPagerDutyClients(arg0 []client.PagerDutyClient, arg1 core.Severity)
SetPagerDutyClients mocks base method.
func (*MockClientMap) SetSlackClients ¶ added in v1.0.0
func (m *MockClientMap) SetSlackClients(arg0 []client.SlackClient, arg1 core.Severity)
SetSlackClients mocks base method.
type MockClientMapMockRecorder ¶ added in v1.0.0
type MockClientMapMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMapMockRecorder is the mock recorder for MockClientMap.
func (*MockClientMapMockRecorder) GetPagerDutyClients ¶ added in v1.0.0
func (mr *MockClientMapMockRecorder) GetPagerDutyClients(arg0 interface{}) *gomock.Call
GetPagerDutyClients indicates an expected call of GetPagerDutyClients.
func (*MockClientMapMockRecorder) GetSlackClients ¶ added in v1.0.0
func (mr *MockClientMapMockRecorder) GetSlackClients(arg0 interface{}) *gomock.Call
GetSlackClients indicates an expected call of GetSlackClients.
func (*MockClientMapMockRecorder) InitAlertClients ¶ added in v1.0.0
func (mr *MockClientMapMockRecorder) InitAlertClients(arg0 interface{}) *gomock.Call
InitAlertClients indicates an expected call of InitAlertClients.
func (*MockClientMapMockRecorder) SetPagerDutyClients ¶ added in v1.0.0
func (mr *MockClientMapMockRecorder) SetPagerDutyClients(arg0, arg1 interface{}) *gomock.Call
SetPagerDutyClients indicates an expected call of SetPagerDutyClients.
func (*MockClientMapMockRecorder) SetSlackClients ¶ added in v1.0.0
func (mr *MockClientMapMockRecorder) SetSlackClients(arg0, arg1 interface{}) *gomock.Call
SetSlackClients indicates an expected call of SetSlackClients.
type MockEthClient ¶
type MockEthClient struct {
// contains filtered or unexported fields
}
MockEthClient is a mock of EthClient interface.
func NewMockEthClient ¶
func NewMockEthClient(ctrl *gomock.Controller) *MockEthClient
NewMockEthClient creates a new mock instance.
func (*MockEthClient) BalanceAt ¶
func (m *MockEthClient) BalanceAt(arg0 context.Context, arg1 common.Address, arg2 *big.Int) (*big.Int, error)
BalanceAt mocks base method.
func (*MockEthClient) BlockByNumber ¶
BlockByNumber mocks base method.
func (*MockEthClient) CallContract ¶
func (m *MockEthClient) CallContract(arg0 context.Context, arg1 ethereum.CallMsg, arg2 *big.Int) ([]byte, error)
CallContract mocks base method.
func (*MockEthClient) CodeAt ¶
func (m *MockEthClient) CodeAt(arg0 context.Context, arg1 common.Address, arg2 *big.Int) ([]byte, error)
CodeAt mocks base method.
func (*MockEthClient) EXPECT ¶
func (m *MockEthClient) EXPECT() *MockEthClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEthClient) FilterLogs ¶
func (m *MockEthClient) FilterLogs(arg0 context.Context, arg1 ethereum.FilterQuery) ([]types.Log, error)
FilterLogs mocks base method.
func (*MockEthClient) HeaderByNumber ¶
HeaderByNumber mocks base method.
func (*MockEthClient) SubscribeFilterLogs ¶
func (m *MockEthClient) SubscribeFilterLogs(arg0 context.Context, arg1 ethereum.FilterQuery, arg2 chan<- types.Log) (ethereum.Subscription, error)
SubscribeFilterLogs mocks base method.
type MockEthClientMockRecorder ¶
type MockEthClientMockRecorder struct {
// contains filtered or unexported fields
}
MockEthClientMockRecorder is the mock recorder for MockEthClient.
func (*MockEthClientMockRecorder) BalanceAt ¶
func (mr *MockEthClientMockRecorder) BalanceAt(arg0, arg1, arg2 interface{}) *gomock.Call
BalanceAt indicates an expected call of BalanceAt.
func (*MockEthClientMockRecorder) BlockByNumber ¶
func (mr *MockEthClientMockRecorder) BlockByNumber(arg0, arg1 interface{}) *gomock.Call
BlockByNumber indicates an expected call of BlockByNumber.
func (*MockEthClientMockRecorder) CallContract ¶
func (mr *MockEthClientMockRecorder) CallContract(arg0, arg1, arg2 interface{}) *gomock.Call
CallContract indicates an expected call of CallContract.
func (*MockEthClientMockRecorder) CodeAt ¶
func (mr *MockEthClientMockRecorder) CodeAt(arg0, arg1, arg2 interface{}) *gomock.Call
CodeAt indicates an expected call of CodeAt.
func (*MockEthClientMockRecorder) FilterLogs ¶
func (mr *MockEthClientMockRecorder) FilterLogs(arg0, arg1 interface{}) *gomock.Call
FilterLogs indicates an expected call of FilterLogs.
func (*MockEthClientMockRecorder) HeaderByNumber ¶
func (mr *MockEthClientMockRecorder) HeaderByNumber(arg0, arg1 interface{}) *gomock.Call
HeaderByNumber indicates an expected call of HeaderByNumber.
func (*MockEthClientMockRecorder) SubscribeFilterLogs ¶
func (mr *MockEthClientMockRecorder) SubscribeFilterLogs(arg0, arg1, arg2 interface{}) *gomock.Call
SubscribeFilterLogs indicates an expected call of SubscribeFilterLogs.
type MockGethClient ¶
type MockGethClient struct {
// contains filtered or unexported fields
}
MockGethClient is a mock of GethClient interface.
func NewMockGethClient ¶
func NewMockGethClient(ctrl *gomock.Controller) *MockGethClient
NewMockGethClient creates a new mock instance.
func (*MockGethClient) EXPECT ¶
func (m *MockGethClient) EXPECT() *MockGethClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockGethClient) GetProof ¶
func (m *MockGethClient) GetProof(arg0 context.Context, arg1 common.Address, arg2 []string, arg3 *big.Int) (*gethclient.AccountResult, error)
GetProof mocks base method.
type MockGethClientMockRecorder ¶
type MockGethClientMockRecorder struct {
// contains filtered or unexported fields
}
MockGethClientMockRecorder is the mock recorder for MockGethClient.
func (*MockGethClientMockRecorder) GetProof ¶
func (mr *MockGethClientMockRecorder) GetProof(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
GetProof indicates an expected call of GetProof.
type MockHeuristic ¶ added in v1.0.0
type MockHeuristic struct {
// contains filtered or unexported fields
}
MockHeuristic is a mock of Heuristic interface.
func NewMockHeuristic ¶ added in v1.0.0
func NewMockHeuristic(ctrl *gomock.Controller) *MockHeuristic
NewMockHeuristic creates a new mock instance.
func (*MockHeuristic) Assess ¶ added in v1.0.0
func (m *MockHeuristic) Assess(arg0 core.TransitData) (*core.Activation, bool, error)
Assess mocks base method.
func (*MockHeuristic) EXPECT ¶ added in v1.0.0
func (m *MockHeuristic) EXPECT() *MockHeuristicMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockHeuristic) InputType ¶ added in v1.0.0
func (m *MockHeuristic) InputType() core.RegisterType
InputType mocks base method.
func (*MockHeuristic) SUUID ¶ added in v1.0.0
func (m *MockHeuristic) SUUID() core.SUUID
SUUID mocks base method.
func (*MockHeuristic) SetSUUID ¶ added in v1.0.0
func (m *MockHeuristic) SetSUUID(arg0 core.SUUID)
SetSUUID mocks base method.
func (*MockHeuristic) ValidateInput ¶ added in v1.0.0
func (m *MockHeuristic) ValidateInput(arg0 core.TransitData) error
ValidateInput mocks base method.
type MockHeuristicMockRecorder ¶ added in v1.0.0
type MockHeuristicMockRecorder struct {
// contains filtered or unexported fields
}
MockHeuristicMockRecorder is the mock recorder for MockHeuristic.
func (*MockHeuristicMockRecorder) Assess ¶ added in v1.0.0
func (mr *MockHeuristicMockRecorder) Assess(arg0 interface{}) *gomock.Call
Assess indicates an expected call of Assess.
func (*MockHeuristicMockRecorder) InputType ¶ added in v1.0.0
func (mr *MockHeuristicMockRecorder) InputType() *gomock.Call
InputType indicates an expected call of InputType.
func (*MockHeuristicMockRecorder) SUUID ¶ added in v1.0.0
func (mr *MockHeuristicMockRecorder) SUUID() *gomock.Call
SUUID indicates an expected call of SUUID.
func (*MockHeuristicMockRecorder) SetSUUID ¶ added in v1.0.0
func (mr *MockHeuristicMockRecorder) SetSUUID(arg0 interface{}) *gomock.Call
SetSUUID indicates an expected call of SetSUUID.
func (*MockHeuristicMockRecorder) ValidateInput ¶ added in v1.0.0
func (mr *MockHeuristicMockRecorder) ValidateInput(arg0 interface{}) *gomock.Call
ValidateInput indicates an expected call of ValidateInput.
type MockPagerDutyClient ¶ added in v1.0.0
type MockPagerDutyClient struct {
// contains filtered or unexported fields
}
MockPagerDutyClient is a mock of PagerDutyClient interface.
func NewMockPagerDutyClient ¶ added in v1.0.0
func NewMockPagerDutyClient(ctrl *gomock.Controller) *MockPagerDutyClient
NewMockPagerDutyClient creates a new mock instance.
func (*MockPagerDutyClient) EXPECT ¶ added in v1.0.0
func (m *MockPagerDutyClient) EXPECT() *MockPagerDutyClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPagerDutyClient) GetName ¶ added in v1.0.0
func (m *MockPagerDutyClient) GetName() string
GetName mocks base method.
func (*MockPagerDutyClient) PostEvent ¶ added in v1.0.0
func (m *MockPagerDutyClient) PostEvent(arg0 context.Context, arg1 *client.AlertEventTrigger) (*client.AlertAPIResponse, error)
PostEvent mocks base method.
type MockPagerDutyClientMockRecorder ¶ added in v1.0.0
type MockPagerDutyClientMockRecorder struct {
// contains filtered or unexported fields
}
MockPagerDutyClientMockRecorder is the mock recorder for MockPagerDutyClient.
func (*MockPagerDutyClientMockRecorder) GetName ¶ added in v1.0.0
func (mr *MockPagerDutyClientMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockPagerDutyClientMockRecorder) PostEvent ¶ added in v1.0.0
func (mr *MockPagerDutyClientMockRecorder) PostEvent(arg0, arg1 interface{}) *gomock.Call
PostEvent indicates an expected call of PostEvent.
type MockRoutingDirectory ¶ added in v1.0.0
type MockRoutingDirectory struct {
// contains filtered or unexported fields
}
MockRoutingDirectory is a mock of RoutingDirectory interface.
func NewMockRoutingDirectory ¶ added in v1.0.0
func NewMockRoutingDirectory(ctrl *gomock.Controller) *MockRoutingDirectory
NewMockRoutingDirectory creates a new mock instance.
func (*MockRoutingDirectory) EXPECT ¶ added in v1.0.0
func (m *MockRoutingDirectory) EXPECT() *MockRoutingDirectoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRoutingDirectory) GetPagerDutyClients ¶ added in v1.0.0
func (m *MockRoutingDirectory) GetPagerDutyClients(arg0 core.Severity) []client.PagerDutyClient
GetPagerDutyClients mocks base method.
func (*MockRoutingDirectory) GetSlackClients ¶ added in v1.0.0
func (m *MockRoutingDirectory) GetSlackClients(arg0 core.Severity) []client.SlackClient
GetSlackClients mocks base method.
func (*MockRoutingDirectory) InitializeRouting ¶ added in v1.0.0
func (m *MockRoutingDirectory) InitializeRouting(arg0 *core.AlertRoutingParams)
InitializeRouting mocks base method.
func (*MockRoutingDirectory) SetPagerDutyClients ¶ added in v1.0.0
func (m *MockRoutingDirectory) SetPagerDutyClients(arg0 []client.PagerDutyClient, arg1 core.Severity)
SetPagerDutyClients mocks base method.
func (*MockRoutingDirectory) SetSlackClients ¶ added in v1.0.0
func (m *MockRoutingDirectory) SetSlackClients(arg0 []client.SlackClient, arg1 core.Severity)
SetSlackClients mocks base method.
type MockRoutingDirectoryMockRecorder ¶ added in v1.0.0
type MockRoutingDirectoryMockRecorder struct {
// contains filtered or unexported fields
}
MockRoutingDirectoryMockRecorder is the mock recorder for MockRoutingDirectory.
func (*MockRoutingDirectoryMockRecorder) GetPagerDutyClients ¶ added in v1.0.0
func (mr *MockRoutingDirectoryMockRecorder) GetPagerDutyClients(arg0 interface{}) *gomock.Call
GetPagerDutyClients indicates an expected call of GetPagerDutyClients.
func (*MockRoutingDirectoryMockRecorder) GetSlackClients ¶ added in v1.0.0
func (mr *MockRoutingDirectoryMockRecorder) GetSlackClients(arg0 interface{}) *gomock.Call
GetSlackClients indicates an expected call of GetSlackClients.
func (*MockRoutingDirectoryMockRecorder) InitializeRouting ¶ added in v1.0.0
func (mr *MockRoutingDirectoryMockRecorder) InitializeRouting(arg0 interface{}) *gomock.Call
InitializeRouting indicates an expected call of InitializeRouting.
func (*MockRoutingDirectoryMockRecorder) SetPagerDutyClients ¶ added in v1.0.0
func (mr *MockRoutingDirectoryMockRecorder) SetPagerDutyClients(arg0, arg1 interface{}) *gomock.Call
SetPagerDutyClients indicates an expected call of SetPagerDutyClients.
func (*MockRoutingDirectoryMockRecorder) SetSlackClients ¶ added in v1.0.0
func (mr *MockRoutingDirectoryMockRecorder) SetSlackClients(arg0, arg1 interface{}) *gomock.Call
SetSlackClients indicates an expected call of SetSlackClients.
type MockService ¶
type MockService struct {
// contains filtered or unexported fields
}
MockService is a mock of Service interface.
func NewMockService ¶
func NewMockService(ctrl *gomock.Controller) *MockService
NewMockService creates a new mock instance.
func (*MockService) CheckETHRPCHealth ¶
func (m *MockService) CheckETHRPCHealth(arg0 core.Network) bool
CheckETHRPCHealth mocks base method.
func (*MockService) CheckHealth ¶
func (m *MockService) CheckHealth() *models.HealthCheck
CheckHealth mocks base method.
func (*MockService) EXPECT ¶
func (m *MockService) EXPECT() *MockServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockService) ProcessHeuristicRequest ¶ added in v1.0.0
func (m *MockService) ProcessHeuristicRequest(arg0 *models.SessionRequestBody) (core.SUUID, error)
ProcessHeuristicRequest mocks base method.
func (*MockService) RunHeuristicSession ¶ added in v1.0.0
func (m *MockService) RunHeuristicSession(arg0 *models.SessionRequestParams) (core.SUUID, error)
RunHeuristicSession mocks base method.
type MockServiceMockRecorder ¶
type MockServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockServiceMockRecorder is the mock recorder for MockService.
func (*MockServiceMockRecorder) CheckETHRPCHealth ¶
func (mr *MockServiceMockRecorder) CheckETHRPCHealth(arg0 interface{}) *gomock.Call
CheckETHRPCHealth indicates an expected call of CheckETHRPCHealth.
func (*MockServiceMockRecorder) CheckHealth ¶
func (mr *MockServiceMockRecorder) CheckHealth() *gomock.Call
CheckHealth indicates an expected call of CheckHealth.
func (*MockServiceMockRecorder) ProcessHeuristicRequest ¶ added in v1.0.0
func (mr *MockServiceMockRecorder) ProcessHeuristicRequest(arg0 interface{}) *gomock.Call
ProcessHeuristicRequest indicates an expected call of ProcessHeuristicRequest.
func (*MockServiceMockRecorder) RunHeuristicSession ¶ added in v1.0.0
func (mr *MockServiceMockRecorder) RunHeuristicSession(arg0 interface{}) *gomock.Call
RunHeuristicSession indicates an expected call of RunHeuristicSession.
type MockSlackClient ¶
type MockSlackClient struct {
// contains filtered or unexported fields
}
MockSlackClient is a mock of SlackClient interface.
func NewMockSlackClient ¶
func NewMockSlackClient(ctrl *gomock.Controller) *MockSlackClient
NewMockSlackClient creates a new mock instance.
func (*MockSlackClient) EXPECT ¶
func (m *MockSlackClient) EXPECT() *MockSlackClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSlackClient) GetName ¶ added in v1.0.0
func (m *MockSlackClient) GetName() string
GetName mocks base method.
func (*MockSlackClient) PostEvent ¶ added in v1.0.0
func (m *MockSlackClient) PostEvent(arg0 context.Context, arg1 *client.AlertEventTrigger) (*client.AlertAPIResponse, error)
PostEvent mocks base method.
type MockSlackClientMockRecorder ¶
type MockSlackClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSlackClientMockRecorder is the mock recorder for MockSlackClient.
func (*MockSlackClientMockRecorder) GetName ¶ added in v1.0.0
func (mr *MockSlackClientMockRecorder) GetName() *gomock.Call
GetName indicates an expected call of GetName.
func (*MockSlackClientMockRecorder) PostEvent ¶ added in v1.0.0
func (mr *MockSlackClientMockRecorder) PostEvent(arg0, arg1 interface{}) *gomock.Call
PostEvent indicates an expected call of PostEvent.
type MockSuite ¶ added in v1.0.0
type MockSuite struct { Ctrl *gomock.Controller MockL1 *MockEthClient MockL2 *MockEthClient SS state.Store }
type SubManager ¶
type SubManager struct {
// contains filtered or unexported fields
}
SubManager is a mock of Manager interface.
func NewSubManager ¶
func NewSubManager(ctrl *gomock.Controller) *SubManager
NewSubManager creates a new mock instance.
func (*SubManager) BuildDeployCfg ¶
func (m *SubManager) BuildDeployCfg(arg0 *core.PipelineConfig, arg1 *core.SessionConfig) (*heuristic.DeployConfig, error)
BuildDeployCfg mocks base method.
func (*SubManager) BuildPipelineCfg ¶
func (m *SubManager) BuildPipelineCfg(arg0 *models.SessionRequestParams) (*core.PipelineConfig, error)
BuildPipelineCfg mocks base method.
func (*SubManager) EXPECT ¶
func (m *SubManager) EXPECT() *SubManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*SubManager) RunSession ¶ added in v1.0.0
func (m *SubManager) RunSession(arg0 *heuristic.DeployConfig) (core.SUUID, error)
RunSession mocks base method.
func (*SubManager) StartEventRoutines ¶
func (m *SubManager) StartEventRoutines(arg0 context.Context)
StartEventRoutines mocks base method.
type SubManagerMockRecorder ¶
type SubManagerMockRecorder struct {
// contains filtered or unexported fields
}
SubManagerMockRecorder is the mock recorder for SubManager.
func (*SubManagerMockRecorder) BuildDeployCfg ¶
func (mr *SubManagerMockRecorder) BuildDeployCfg(arg0, arg1 interface{}) *gomock.Call
BuildDeployCfg indicates an expected call of BuildDeployCfg.
func (*SubManagerMockRecorder) BuildPipelineCfg ¶
func (mr *SubManagerMockRecorder) BuildPipelineCfg(arg0 interface{}) *gomock.Call
BuildPipelineCfg indicates an expected call of BuildPipelineCfg.
func (*SubManagerMockRecorder) RunSession ¶ added in v1.0.0
func (mr *SubManagerMockRecorder) RunSession(arg0 interface{}) *gomock.Call
RunSession indicates an expected call of RunSession.
func (*SubManagerMockRecorder) Shutdown ¶
func (mr *SubManagerMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*SubManagerMockRecorder) StartEventRoutines ¶
func (mr *SubManagerMockRecorder) StartEventRoutines(arg0 interface{}) *gomock.Call
StartEventRoutines indicates an expected call of StartEventRoutines.