Documentation ¶
Index ¶
- type AttackNetwork
- type AttackOrchestrator
- type AttackerClient
- type AttackerServer
- type Attacker_ObserveClient
- func (_m *Attacker_ObserveClient) CloseAndRecv() (*emptypb.Empty, error)
- func (_m *Attacker_ObserveClient) CloseSend() error
- func (_m *Attacker_ObserveClient) Context() context.Context
- func (_m *Attacker_ObserveClient) Header() (metadata.MD, error)
- func (_m *Attacker_ObserveClient) RecvMsg(m interface{}) error
- func (_m *Attacker_ObserveClient) Send(_a0 *insecure.Message) error
- func (_m *Attacker_ObserveClient) SendMsg(m interface{}) error
- func (_m *Attacker_ObserveClient) Trailer() metadata.MD
- type Attacker_ObserveServer
- func (_m *Attacker_ObserveServer) Context() context.Context
- func (_m *Attacker_ObserveServer) Recv() (*insecure.Message, error)
- func (_m *Attacker_ObserveServer) RecvMsg(m interface{}) error
- func (_m *Attacker_ObserveServer) SendAndClose(_a0 *emptypb.Empty) error
- func (_m *Attacker_ObserveServer) SendHeader(_a0 metadata.MD) error
- func (_m *Attacker_ObserveServer) SendMsg(m interface{}) error
- func (_m *Attacker_ObserveServer) SetHeader(_a0 metadata.MD) error
- func (_m *Attacker_ObserveServer) SetTrailer(_a0 metadata.MD)
- type ConduitController
- type ConduitMaster
- type CorruptedNodeConnection
- type CorruptedNodeConnector
- type CorruptibleConduitFactoryClient
- func (_m *CorruptibleConduitFactoryClient) ProcessAttackerMessage(ctx context.Context, opts ...grpc.CallOption) (insecure.CorruptibleConduitFactory_ProcessAttackerMessageClient, error)
- func (_m *CorruptibleConduitFactoryClient) RegisterAttacker(ctx context.Context, in *insecure.AttackerRegisterMessage, ...) (*emptypb.Empty, error)
- type CorruptibleConduitFactoryServer
- type CorruptibleConduitFactory_ProcessAttackerMessageClient
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) CloseAndRecv() (*emptypb.Empty, error)
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) CloseSend() error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) Context() context.Context
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) Header() (metadata.MD, error)
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) RecvMsg(m interface{}) error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) Send(_a0 *insecure.Message) error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) SendMsg(m interface{}) error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) Trailer() metadata.MD
- type CorruptibleConduitFactory_ProcessAttackerMessageServer
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) Context() context.Context
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) Recv() (*insecure.Message, error)
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) RecvMsg(m interface{}) error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SendAndClose(_a0 *emptypb.Empty) error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SendHeader(_a0 metadata.MD) error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SendMsg(m interface{}) error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SetHeader(_a0 metadata.MD) error
- func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SetTrailer(_a0 metadata.MD)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AttackNetwork ¶
AttackNetwork is an autogenerated mock type for the AttackNetwork type
func NewAttackNetwork ¶ added in v0.26.1
func NewAttackNetwork(t testing.TB) *AttackNetwork
NewAttackNetwork creates a new instance of AttackNetwork. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*AttackNetwork) Done ¶
func (_m *AttackNetwork) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*AttackNetwork) Ready ¶
func (_m *AttackNetwork) Ready() <-chan struct{}
Ready provides a mock function with given fields:
func (*AttackNetwork) Send ¶ added in v0.25.2
func (_m *AttackNetwork) Send(_a0 *insecure.Event) error
Send provides a mock function with given fields: _a0
func (*AttackNetwork) Start ¶
func (_m *AttackNetwork) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
type AttackOrchestrator ¶
AttackOrchestrator is an autogenerated mock type for the AttackOrchestrator type
func NewAttackOrchestrator ¶ added in v0.26.1
func NewAttackOrchestrator(t testing.TB) *AttackOrchestrator
NewAttackOrchestrator creates a new instance of AttackOrchestrator. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*AttackOrchestrator) HandleEventFromCorruptedNode ¶
func (_m *AttackOrchestrator) HandleEventFromCorruptedNode(_a0 *insecure.Event) error
HandleEventFromCorruptedNode provides a mock function with given fields: _a0
func (*AttackOrchestrator) WithAttackNetwork ¶ added in v0.25.2
func (_m *AttackOrchestrator) WithAttackNetwork(_a0 insecure.AttackNetwork)
WithAttackNetwork provides a mock function with given fields: _a0
type AttackerClient ¶
AttackerClient is an autogenerated mock type for the AttackerClient type
func NewAttackerClient ¶ added in v0.26.1
func NewAttackerClient(t testing.TB) *AttackerClient
NewAttackerClient creates a new instance of AttackerClient. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*AttackerClient) Observe ¶
func (_m *AttackerClient) Observe(ctx context.Context, opts ...grpc.CallOption) (insecure.Attacker_ObserveClient, error)
Observe provides a mock function with given fields: ctx, opts
type AttackerServer ¶
AttackerServer is an autogenerated mock type for the AttackerServer type
func NewAttackerServer ¶ added in v0.26.1
func NewAttackerServer(t testing.TB) *AttackerServer
NewAttackerServer creates a new instance of AttackerServer. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*AttackerServer) Observe ¶
func (_m *AttackerServer) Observe(_a0 insecure.Attacker_ObserveServer) error
Observe provides a mock function with given fields: _a0
type Attacker_ObserveClient ¶
Attacker_ObserveClient is an autogenerated mock type for the Attacker_ObserveClient type
func NewAttacker_ObserveClient ¶ added in v0.26.1
func NewAttacker_ObserveClient(t testing.TB) *Attacker_ObserveClient
NewAttacker_ObserveClient creates a new instance of Attacker_ObserveClient. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*Attacker_ObserveClient) CloseAndRecv ¶
func (_m *Attacker_ObserveClient) CloseAndRecv() (*emptypb.Empty, error)
CloseAndRecv provides a mock function with given fields:
func (*Attacker_ObserveClient) CloseSend ¶
func (_m *Attacker_ObserveClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*Attacker_ObserveClient) Context ¶
func (_m *Attacker_ObserveClient) Context() context.Context
Context provides a mock function with given fields:
func (*Attacker_ObserveClient) Header ¶
func (_m *Attacker_ObserveClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*Attacker_ObserveClient) RecvMsg ¶
func (_m *Attacker_ObserveClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*Attacker_ObserveClient) Send ¶
func (_m *Attacker_ObserveClient) Send(_a0 *insecure.Message) error
Send provides a mock function with given fields: _a0
func (*Attacker_ObserveClient) SendMsg ¶
func (_m *Attacker_ObserveClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*Attacker_ObserveClient) Trailer ¶
func (_m *Attacker_ObserveClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type Attacker_ObserveServer ¶
Attacker_ObserveServer is an autogenerated mock type for the Attacker_ObserveServer type
func NewAttacker_ObserveServer ¶ added in v0.26.1
func NewAttacker_ObserveServer(t testing.TB) *Attacker_ObserveServer
NewAttacker_ObserveServer creates a new instance of Attacker_ObserveServer. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*Attacker_ObserveServer) Context ¶
func (_m *Attacker_ObserveServer) Context() context.Context
Context provides a mock function with given fields:
func (*Attacker_ObserveServer) Recv ¶
func (_m *Attacker_ObserveServer) Recv() (*insecure.Message, error)
Recv provides a mock function with given fields:
func (*Attacker_ObserveServer) RecvMsg ¶
func (_m *Attacker_ObserveServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*Attacker_ObserveServer) SendAndClose ¶
func (_m *Attacker_ObserveServer) SendAndClose(_a0 *emptypb.Empty) error
SendAndClose provides a mock function with given fields: _a0
func (*Attacker_ObserveServer) SendHeader ¶
func (_m *Attacker_ObserveServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*Attacker_ObserveServer) SendMsg ¶
func (_m *Attacker_ObserveServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*Attacker_ObserveServer) SetHeader ¶
func (_m *Attacker_ObserveServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*Attacker_ObserveServer) SetTrailer ¶
func (_m *Attacker_ObserveServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type ConduitController ¶ added in v0.25.2
ConduitController is an autogenerated mock type for the ConduitController type
func NewConduitController ¶ added in v0.26.1
func NewConduitController(t testing.TB) *ConduitController
NewConduitController creates a new instance of ConduitController. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*ConduitController) EngineClosingChannel ¶ added in v0.25.2
func (_m *ConduitController) EngineClosingChannel(_a0 network.Channel) error
EngineClosingChannel provides a mock function with given fields: _a0
func (*ConduitController) HandleIncomingEvent ¶ added in v0.25.2
func (_m *ConduitController) HandleIncomingEvent(_a0 interface{}, _a1 network.Channel, _a2 insecure.Protocol, _a3 uint32, _a4 ...flow.Identifier) error
HandleIncomingEvent provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
type ConduitMaster ¶
ConduitMaster is an autogenerated mock type for the ConduitMaster type
func (*ConduitMaster) EngineClosingChannel ¶
func (_m *ConduitMaster) EngineClosingChannel(_a0 network.Channel) error
EngineClosingChannel provides a mock function with given fields: _a0
func (*ConduitMaster) HandleIncomingEvent ¶
func (_m *ConduitMaster) HandleIncomingEvent(_a0 interface{}, _a1 network.Channel, _a2 insecure.Protocol, _a3 uint32, _a4 ...flow.Identifier) error
HandleIncomingEvent provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
type CorruptedNodeConnection ¶ added in v0.25.2
CorruptedNodeConnection is an autogenerated mock type for the CorruptedNodeConnection type
func NewCorruptedNodeConnection ¶ added in v0.26.1
func NewCorruptedNodeConnection(t testing.TB) *CorruptedNodeConnection
NewCorruptedNodeConnection creates a new instance of CorruptedNodeConnection. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptedNodeConnection) CloseConnection ¶ added in v0.25.2
func (_m *CorruptedNodeConnection) CloseConnection() error
CloseConnection provides a mock function with given fields:
func (*CorruptedNodeConnection) SendMessage ¶ added in v0.25.2
func (_m *CorruptedNodeConnection) SendMessage(_a0 *insecure.Message) error
SendMessage provides a mock function with given fields: _a0
type CorruptedNodeConnector ¶ added in v0.25.2
CorruptedNodeConnector is an autogenerated mock type for the CorruptedNodeConnector type
func NewCorruptedNodeConnector ¶ added in v0.26.1
func NewCorruptedNodeConnector(t testing.TB) *CorruptedNodeConnector
NewCorruptedNodeConnector creates a new instance of CorruptedNodeConnector. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptedNodeConnector) Connect ¶ added in v0.25.2
func (_m *CorruptedNodeConnector) Connect(_a0 context.Context, _a1 flow.Identifier) (insecure.CorruptedNodeConnection, error)
Connect provides a mock function with given fields: _a0, _a1
func (*CorruptedNodeConnector) WithAttackerAddress ¶ added in v0.26.0
func (_m *CorruptedNodeConnector) WithAttackerAddress(_a0 string)
WithAttackerAddress provides a mock function with given fields: _a0
type CorruptibleConduitFactoryClient ¶
CorruptibleConduitFactoryClient is an autogenerated mock type for the CorruptibleConduitFactoryClient type
func NewCorruptibleConduitFactoryClient ¶ added in v0.26.1
func NewCorruptibleConduitFactoryClient(t testing.TB) *CorruptibleConduitFactoryClient
NewCorruptibleConduitFactoryClient creates a new instance of CorruptibleConduitFactoryClient. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptibleConduitFactoryClient) ProcessAttackerMessage ¶
func (_m *CorruptibleConduitFactoryClient) ProcessAttackerMessage(ctx context.Context, opts ...grpc.CallOption) (insecure.CorruptibleConduitFactory_ProcessAttackerMessageClient, error)
ProcessAttackerMessage provides a mock function with given fields: ctx, opts
func (*CorruptibleConduitFactoryClient) RegisterAttacker ¶
func (_m *CorruptibleConduitFactoryClient) RegisterAttacker(ctx context.Context, in *insecure.AttackerRegisterMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
RegisterAttacker provides a mock function with given fields: ctx, in, opts
type CorruptibleConduitFactoryServer ¶
CorruptibleConduitFactoryServer is an autogenerated mock type for the CorruptibleConduitFactoryServer type
func NewCorruptibleConduitFactoryServer ¶ added in v0.26.1
func NewCorruptibleConduitFactoryServer(t testing.TB) *CorruptibleConduitFactoryServer
NewCorruptibleConduitFactoryServer creates a new instance of CorruptibleConduitFactoryServer. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptibleConduitFactoryServer) ProcessAttackerMessage ¶
func (_m *CorruptibleConduitFactoryServer) ProcessAttackerMessage(_a0 insecure.CorruptibleConduitFactory_ProcessAttackerMessageServer) error
ProcessAttackerMessage provides a mock function with given fields: _a0
func (*CorruptibleConduitFactoryServer) RegisterAttacker ¶
func (_m *CorruptibleConduitFactoryServer) RegisterAttacker(_a0 context.Context, _a1 *insecure.AttackerRegisterMessage) (*emptypb.Empty, error)
RegisterAttacker provides a mock function with given fields: _a0, _a1
type CorruptibleConduitFactory_ProcessAttackerMessageClient ¶
CorruptibleConduitFactory_ProcessAttackerMessageClient is an autogenerated mock type for the CorruptibleConduitFactory_ProcessAttackerMessageClient type
func NewCorruptibleConduitFactory_ProcessAttackerMessageClient ¶ added in v0.26.1
func NewCorruptibleConduitFactory_ProcessAttackerMessageClient(t testing.TB) *CorruptibleConduitFactory_ProcessAttackerMessageClient
NewCorruptibleConduitFactory_ProcessAttackerMessageClient creates a new instance of CorruptibleConduitFactory_ProcessAttackerMessageClient. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptibleConduitFactory_ProcessAttackerMessageClient) CloseAndRecv ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) CloseAndRecv() (*emptypb.Empty, error)
CloseAndRecv provides a mock function with given fields:
func (*CorruptibleConduitFactory_ProcessAttackerMessageClient) CloseSend ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*CorruptibleConduitFactory_ProcessAttackerMessageClient) Context ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) Context() context.Context
Context provides a mock function with given fields:
func (*CorruptibleConduitFactory_ProcessAttackerMessageClient) Header ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*CorruptibleConduitFactory_ProcessAttackerMessageClient) RecvMsg ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*CorruptibleConduitFactory_ProcessAttackerMessageClient) Send ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) Send(_a0 *insecure.Message) error
Send provides a mock function with given fields: _a0
func (*CorruptibleConduitFactory_ProcessAttackerMessageClient) SendMsg ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*CorruptibleConduitFactory_ProcessAttackerMessageClient) Trailer ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type CorruptibleConduitFactory_ProcessAttackerMessageServer ¶
CorruptibleConduitFactory_ProcessAttackerMessageServer is an autogenerated mock type for the CorruptibleConduitFactory_ProcessAttackerMessageServer type
func NewCorruptibleConduitFactory_ProcessAttackerMessageServer ¶ added in v0.26.1
func NewCorruptibleConduitFactory_ProcessAttackerMessageServer(t testing.TB) *CorruptibleConduitFactory_ProcessAttackerMessageServer
NewCorruptibleConduitFactory_ProcessAttackerMessageServer creates a new instance of CorruptibleConduitFactory_ProcessAttackerMessageServer. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptibleConduitFactory_ProcessAttackerMessageServer) Context ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) Context() context.Context
Context provides a mock function with given fields:
func (*CorruptibleConduitFactory_ProcessAttackerMessageServer) Recv ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) Recv() (*insecure.Message, error)
Recv provides a mock function with given fields:
func (*CorruptibleConduitFactory_ProcessAttackerMessageServer) RecvMsg ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*CorruptibleConduitFactory_ProcessAttackerMessageServer) SendAndClose ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SendAndClose(_a0 *emptypb.Empty) error
SendAndClose provides a mock function with given fields: _a0
func (*CorruptibleConduitFactory_ProcessAttackerMessageServer) SendHeader ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*CorruptibleConduitFactory_ProcessAttackerMessageServer) SendMsg ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*CorruptibleConduitFactory_ProcessAttackerMessageServer) SetHeader ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*CorruptibleConduitFactory_ProcessAttackerMessageServer) SetTrailer ¶
func (_m *CorruptibleConduitFactory_ProcessAttackerMessageServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
Source Files ¶
- attack_network.go
- attack_orchestrator.go
- attacker__observe_client.go
- attacker__observe_server.go
- attacker_client.go
- attacker_server.go
- conduit_controller.go
- conduit_master.go
- corrupted_node_connection.go
- corrupted_node_connector.go
- corruptible_conduit_factory__process_attacker_message_client.go
- corruptible_conduit_factory__process_attacker_message_server.go
- corruptible_conduit_factory_client.go
- corruptible_conduit_factory_server.go