mocks

package

Go to main page

Versions in this module

v1

v1.0.0

Aug 30, 2023

Changes in this version

type EngineManager

+ func (m *EngineManager) DeleteHeuristicSession(arg0 core.SUUID) (core.SUUID, error)

+ func (m *EngineManager) DeployHeuristicSession(arg0 *heuristic.DeployConfig) (core.SUUID, error)

type EngineManagerMockRecorder

+ func (mr *EngineManagerMockRecorder) DeleteHeuristicSession(arg0 interface{}) *gomock.Call

+ func (mr *EngineManagerMockRecorder) DeployHeuristicSession(arg0 interface{}) *gomock.Call

+ type MockAlertClient struct

+ func NewMockAlertClient(ctrl *gomock.Controller) *MockAlertClient

+ func (m *MockAlertClient) EXPECT() *MockAlertClientMockRecorder

+ func (m *MockAlertClient) PostEvent(arg0 context.Context, arg1 *alert_client.AlertEventTrigger) (*alert_client.AlertAPIResponse, error)

+ type MockAlertClientMockRecorder struct

+ func (mr *MockAlertClientMockRecorder) PostEvent(arg0, arg1 interface{}) *gomock.Call

+ type MockClientMap struct

+ func NewMockClientMap(ctrl *gomock.Controller) *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 struct

+ 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 MockHeuristic struct

+ func NewMockHeuristic(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockPagerDutyClient(ctrl *gomock.Controller) *MockPagerDutyClient

+ func (m *MockPagerDutyClient) EXPECT() *MockPagerDutyClientMockRecorder

+ func (m *MockPagerDutyClient) GetName() string

+ func (m *MockPagerDutyClient) PostEvent(arg0 context.Context, arg1 *client.AlertEventTrigger) (*client.AlertAPIResponse, error)

+ type MockPagerDutyClientMockRecorder struct

+ func (mr *MockPagerDutyClientMockRecorder) GetName() *gomock.Call

+ func (mr *MockPagerDutyClientMockRecorder) PostEvent(arg0, arg1 interface{}) *gomock.Call

+ type MockRoutingDirectory struct

+ func NewMockRoutingDirectory(ctrl *gomock.Controller) *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 struct

+ 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) ProcessHeuristicRequest(arg0 *models.SessionRequestBody) (core.SUUID, error)

+ func (m *MockService) RunHeuristicSession(arg0 *models.SessionRequestParams) (core.SUUID, error)

type MockServiceMockRecorder

+ func (mr *MockServiceMockRecorder) ProcessHeuristicRequest(arg0 interface{}) *gomock.Call

+ func (mr *MockServiceMockRecorder) RunHeuristicSession(arg0 interface{}) *gomock.Call

type MockSlackClient

+ func (m *MockSlackClient) GetName() string

+ func (m *MockSlackClient) PostEvent(arg0 context.Context, arg1 *client.AlertEventTrigger) (*client.AlertAPIResponse, error)

type MockSlackClientMockRecorder

+ func (mr *MockSlackClientMockRecorder) GetName() *gomock.Call

+ func (mr *MockSlackClientMockRecorder) PostEvent(arg0, arg1 interface{}) *gomock.Call

+ type MockSuite struct

+ Ctrl *gomock.Controller

+ MockL1 *MockEthClient

+ MockL2 *MockEthClient

+ SS state.Store

type SubManager

+ func (m *SubManager) RunSession(arg0 *heuristic.DeployConfig) (core.SUUID, error)

type SubManagerMockRecorder

+ func (mr *SubManagerMockRecorder) RunSession(arg0 interface{}) *gomock.Call

v0

v0.0.1

Jul 25, 2023

Changes in this version

+ func Context(ctx context.Context, ctrl *gomock.Controller) context.Context

+ 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 struct

+ func NewAlertManager(ctrl *gomock.Controller) *AlertManager

+ func (m *AlertManager) AddSession(arg0 core.SUUID, arg1 core.AlertDestination) error

+ func (m *AlertManager) EXPECT() *AlertManagerMockRecorder

+ func (m *AlertManager) EventLoop() error

+ func (m *AlertManager) Shutdown() error

+ func (m *AlertManager) Transit() chan core.Alert

+ type AlertManagerMockRecorder struct

+ func (mr *AlertManagerMockRecorder) AddSession(arg0, arg1 interface{}) *gomock.Call

+ func (mr *AlertManagerMockRecorder) EventLoop() *gomock.Call

+ func (mr *AlertManagerMockRecorder) Shutdown() *gomock.Call

+ func (mr *AlertManagerMockRecorder) Transit() *gomock.Call

+ type EngineManager struct

+ func NewEngineManager(ctrl *gomock.Controller) *EngineManager

+ func (m *EngineManager) DeleteInvariantSession(arg0 core.SUUID) (core.SUUID, error)

+ func (m *EngineManager) DeployInvariantSession(arg0 *invariant.DeployConfig) (core.SUUID, error)

+ func (m *EngineManager) EXPECT() *EngineManagerMockRecorder

+ func (m *EngineManager) EventLoop() error

+ func (m *EngineManager) GetInputType(arg0 core.InvariantType) (core.RegisterType, error)

+ func (m *EngineManager) Shutdown() error

+ func (m *EngineManager) Transit() chan core.InvariantInput

+ type EngineManagerMockRecorder struct

+ func (mr *EngineManagerMockRecorder) DeleteInvariantSession(arg0 interface{}) *gomock.Call

+ func (mr *EngineManagerMockRecorder) DeployInvariantSession(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 struct

+ func NewEtlManager(ctrl *gomock.Controller) *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 struct

+ 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 MockEthClient struct

+ func NewMockEthClient(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockGethClient(ctrl *gomock.Controller) *MockGethClient

+ func (m *MockGethClient) EXPECT() *MockGethClientMockRecorder

+ func (m *MockGethClient) GetProof(arg0 context.Context, arg1 common.Address, arg2 []string, arg3 *big.Int) (*gethclient.AccountResult, error)

+ type MockGethClientMockRecorder struct

+ func (mr *MockGethClientMockRecorder) GetProof(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ type MockInvariant struct

+ func NewMockInvariant(ctrl *gomock.Controller) *MockInvariant

+ func (m *MockInvariant) EXPECT() *MockInvariantMockRecorder

+ func (m *MockInvariant) InputType() core.RegisterType

+ func (m *MockInvariant) Invalidate(arg0 core.TransitData) (*core.Invalidation, bool, error)

+ func (m *MockInvariant) SUUID() core.SUUID

+ func (m *MockInvariant) SetSUUID(arg0 core.SUUID)

+ func (m *MockInvariant) ValidateInput(arg0 core.TransitData) error

+ type MockInvariantMockRecorder struct

+ func (mr *MockInvariantMockRecorder) InputType() *gomock.Call

+ func (mr *MockInvariantMockRecorder) Invalidate(arg0 interface{}) *gomock.Call

+ func (mr *MockInvariantMockRecorder) SUUID() *gomock.Call

+ func (mr *MockInvariantMockRecorder) SetSUUID(arg0 interface{}) *gomock.Call

+ func (mr *MockInvariantMockRecorder) ValidateInput(arg0 interface{}) *gomock.Call

+ type MockService struct

+ func NewMockService(ctrl *gomock.Controller) *MockService

+ func (m *MockService) CheckETHRPCHealth(arg0 core.Network) bool

+ func (m *MockService) CheckHealth() *models.HealthCheck

+ func (m *MockService) EXPECT() *MockServiceMockRecorder

+ func (m *MockService) ProcessInvariantRequest(arg0 *models.InvRequestBody) (core.SUUID, error)

+ func (m *MockService) RunInvariantSession(arg0 *models.InvRequestParams) (core.SUUID, error)

+ type MockServiceMockRecorder struct

+ func (mr *MockServiceMockRecorder) CheckETHRPCHealth(arg0 interface{}) *gomock.Call

+ func (mr *MockServiceMockRecorder) CheckHealth() *gomock.Call

+ func (mr *MockServiceMockRecorder) ProcessInvariantRequest(arg0 interface{}) *gomock.Call

+ func (mr *MockServiceMockRecorder) RunInvariantSession(arg0 interface{}) *gomock.Call

+ type MockSlackClient struct

+ func NewMockSlackClient(ctrl *gomock.Controller) *MockSlackClient

+ func (m *MockSlackClient) EXPECT() *MockSlackClientMockRecorder

+ func (m *MockSlackClient) PostData(arg0 context.Context, arg1 string) (*client.SlackAPIResponse, error)

+ type MockSlackClientMockRecorder struct

+ func (mr *MockSlackClientMockRecorder) PostData(arg0, arg1 interface{}) *gomock.Call

+ type SubManager struct

+ func NewSubManager(ctrl *gomock.Controller) *SubManager

+ func (m *SubManager) BuildDeployCfg(arg0 *core.PipelineConfig, arg1 *core.SessionConfig) (*invariant.DeployConfig, error)

+ func (m *SubManager) BuildPipelineCfg(arg0 *models.InvRequestParams) (*core.PipelineConfig, error)

+ func (m *SubManager) EXPECT() *SubManagerMockRecorder

+ func (m *SubManager) RunInvSession(arg0 *invariant.DeployConfig) (core.SUUID, error)

+ func (m *SubManager) Shutdown() error

+ func (m *SubManager) StartEventRoutines(arg0 context.Context)

+ type SubManagerMockRecorder struct

+ func (mr *SubManagerMockRecorder) BuildDeployCfg(arg0, arg1 interface{}) *gomock.Call

+ func (mr *SubManagerMockRecorder) BuildPipelineCfg(arg0 interface{}) *gomock.Call

+ func (mr *SubManagerMockRecorder) RunInvSession(arg0 interface{}) *gomock.Call

+ func (mr *SubManagerMockRecorder) Shutdown() *gomock.Call

+ func (mr *SubManagerMockRecorder) StartEventRoutines(arg0 interface{}) *gomock.Call

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