Documentation ¶
Index ¶
- type AttackOrchestrator
- type CorruptConduitFactory
- func (_m *CorruptConduitFactory) NewConduit(_a0 context.Context, _a1 channels.Channel) (network.Conduit, error)
- func (_m *CorruptConduitFactory) RegisterAdapter(_a0 network.Adapter) error
- func (_m *CorruptConduitFactory) RegisterEgressController(_a0 insecure.EgressController) error
- func (_m *CorruptConduitFactory) SendOnFlowNetwork(_a0 interface{}, _a1 channels.Channel, _a2 insecure.Protocol, _a3 uint, ...) error
- func (_m *CorruptConduitFactory) UnregisterChannel(_a0 channels.Channel) error
- type CorruptNetworkClient
- func (_m *CorruptNetworkClient) ConnectAttacker(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (insecure.CorruptNetwork_ConnectAttackerClient, error)
- func (_m *CorruptNetworkClient) ProcessAttackerMessage(ctx context.Context, opts ...grpc.CallOption) (insecure.CorruptNetwork_ProcessAttackerMessageClient, error)
- type CorruptNetworkServer
- type CorruptNetwork_ConnectAttackerClient
- func (_m *CorruptNetwork_ConnectAttackerClient) CloseSend() error
- func (_m *CorruptNetwork_ConnectAttackerClient) Context() context.Context
- func (_m *CorruptNetwork_ConnectAttackerClient) Header() (metadata.MD, error)
- func (_m *CorruptNetwork_ConnectAttackerClient) Recv() (*insecure.Message, error)
- func (_m *CorruptNetwork_ConnectAttackerClient) RecvMsg(m interface{}) error
- func (_m *CorruptNetwork_ConnectAttackerClient) SendMsg(m interface{}) error
- func (_m *CorruptNetwork_ConnectAttackerClient) Trailer() metadata.MD
- type CorruptNetwork_ConnectAttackerServer
- func (_m *CorruptNetwork_ConnectAttackerServer) Context() context.Context
- func (_m *CorruptNetwork_ConnectAttackerServer) RecvMsg(m interface{}) error
- func (_m *CorruptNetwork_ConnectAttackerServer) Send(_a0 *insecure.Message) error
- func (_m *CorruptNetwork_ConnectAttackerServer) SendHeader(_a0 metadata.MD) error
- func (_m *CorruptNetwork_ConnectAttackerServer) SendMsg(m interface{}) error
- func (_m *CorruptNetwork_ConnectAttackerServer) SetHeader(_a0 metadata.MD) error
- func (_m *CorruptNetwork_ConnectAttackerServer) SetTrailer(_a0 metadata.MD)
- type CorruptNetwork_ProcessAttackerMessageClient
- func (_m *CorruptNetwork_ProcessAttackerMessageClient) CloseAndRecv() (*emptypb.Empty, error)
- func (_m *CorruptNetwork_ProcessAttackerMessageClient) CloseSend() error
- func (_m *CorruptNetwork_ProcessAttackerMessageClient) Context() context.Context
- func (_m *CorruptNetwork_ProcessAttackerMessageClient) Header() (metadata.MD, error)
- func (_m *CorruptNetwork_ProcessAttackerMessageClient) RecvMsg(m interface{}) error
- func (_m *CorruptNetwork_ProcessAttackerMessageClient) Send(_a0 *insecure.Message) error
- func (_m *CorruptNetwork_ProcessAttackerMessageClient) SendMsg(m interface{}) error
- func (_m *CorruptNetwork_ProcessAttackerMessageClient) Trailer() metadata.MD
- type CorruptNetwork_ProcessAttackerMessageServer
- func (_m *CorruptNetwork_ProcessAttackerMessageServer) Context() context.Context
- func (_m *CorruptNetwork_ProcessAttackerMessageServer) Recv() (*insecure.Message, error)
- func (_m *CorruptNetwork_ProcessAttackerMessageServer) RecvMsg(m interface{}) error
- func (_m *CorruptNetwork_ProcessAttackerMessageServer) SendAndClose(_a0 *emptypb.Empty) error
- func (_m *CorruptNetwork_ProcessAttackerMessageServer) SendHeader(_a0 metadata.MD) error
- func (_m *CorruptNetwork_ProcessAttackerMessageServer) SendMsg(m interface{}) error
- func (_m *CorruptNetwork_ProcessAttackerMessageServer) SetHeader(_a0 metadata.MD) error
- func (_m *CorruptNetwork_ProcessAttackerMessageServer) SetTrailer(_a0 metadata.MD)
- type CorruptedNodeConnection
- type CorruptedNodeConnector
- type EgressController
- type IngressController
- type OrchestratorNetwork
- func (_m *OrchestratorNetwork) Done() <-chan struct{}
- func (_m *OrchestratorNetwork) Observe(_a0 *insecure.Message)
- func (_m *OrchestratorNetwork) Ready() <-chan struct{}
- func (_m *OrchestratorNetwork) SendEgress(_a0 *insecure.EgressEvent) error
- func (_m *OrchestratorNetwork) SendIngress(_a0 *insecure.IngressEvent) error
- func (_m *OrchestratorNetwork) Start(_a0 irrecoverable.SignalerContext)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AttackOrchestrator ¶
AttackOrchestrator is an autogenerated mock type for the AttackOrchestrator type
func NewAttackOrchestrator ¶ added in v0.26.1
func NewAttackOrchestrator(t mockConstructorTestingTNewAttackOrchestrator) *AttackOrchestrator
NewAttackOrchestrator creates a new instance of AttackOrchestrator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*AttackOrchestrator) HandleEgressEvent ¶ added in v0.28.0
func (_m *AttackOrchestrator) HandleEgressEvent(_a0 *insecure.EgressEvent) error
HandleEgressEvent provides a mock function with given fields: _a0
func (*AttackOrchestrator) HandleIngressEvent ¶ added in v0.28.0
func (_m *AttackOrchestrator) HandleIngressEvent(_a0 *insecure.IngressEvent) error
HandleIngressEvent provides a mock function with given fields: _a0
func (*AttackOrchestrator) Register ¶ added in v0.28.0
func (_m *AttackOrchestrator) Register(_a0 insecure.OrchestratorNetwork)
Register provides a mock function with given fields: _a0
type CorruptConduitFactory ¶ added in v0.28.0
CorruptConduitFactory is an autogenerated mock type for the CorruptConduitFactory type
func NewCorruptConduitFactory ¶ added in v0.28.0
func NewCorruptConduitFactory(t mockConstructorTestingTNewCorruptConduitFactory) *CorruptConduitFactory
NewCorruptConduitFactory creates a new instance of CorruptConduitFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptConduitFactory) NewConduit ¶ added in v0.28.0
func (_m *CorruptConduitFactory) NewConduit(_a0 context.Context, _a1 channels.Channel) (network.Conduit, error)
NewConduit provides a mock function with given fields: _a0, _a1
func (*CorruptConduitFactory) RegisterAdapter ¶ added in v0.28.0
func (_m *CorruptConduitFactory) RegisterAdapter(_a0 network.Adapter) error
RegisterAdapter provides a mock function with given fields: _a0
func (*CorruptConduitFactory) RegisterEgressController ¶ added in v0.28.0
func (_m *CorruptConduitFactory) RegisterEgressController(_a0 insecure.EgressController) error
RegisterEgressController provides a mock function with given fields: _a0
func (*CorruptConduitFactory) SendOnFlowNetwork ¶ added in v0.28.0
func (_m *CorruptConduitFactory) SendOnFlowNetwork(_a0 interface{}, _a1 channels.Channel, _a2 insecure.Protocol, _a3 uint, _a4 ...flow.Identifier) error
SendOnFlowNetwork provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
func (*CorruptConduitFactory) UnregisterChannel ¶ added in v0.28.0
func (_m *CorruptConduitFactory) UnregisterChannel(_a0 channels.Channel) error
UnregisterChannel provides a mock function with given fields: _a0
type CorruptNetworkClient ¶ added in v0.28.0
CorruptNetworkClient is an autogenerated mock type for the CorruptNetworkClient type
func NewCorruptNetworkClient ¶ added in v0.28.0
func NewCorruptNetworkClient(t mockConstructorTestingTNewCorruptNetworkClient) *CorruptNetworkClient
NewCorruptNetworkClient creates a new instance of CorruptNetworkClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptNetworkClient) ConnectAttacker ¶ added in v0.28.0
func (_m *CorruptNetworkClient) ConnectAttacker(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (insecure.CorruptNetwork_ConnectAttackerClient, error)
ConnectAttacker provides a mock function with given fields: ctx, in, opts
func (*CorruptNetworkClient) ProcessAttackerMessage ¶ added in v0.28.0
func (_m *CorruptNetworkClient) ProcessAttackerMessage(ctx context.Context, opts ...grpc.CallOption) (insecure.CorruptNetwork_ProcessAttackerMessageClient, error)
ProcessAttackerMessage provides a mock function with given fields: ctx, opts
type CorruptNetworkServer ¶ added in v0.28.0
CorruptNetworkServer is an autogenerated mock type for the CorruptNetworkServer type
func NewCorruptNetworkServer ¶ added in v0.28.0
func NewCorruptNetworkServer(t mockConstructorTestingTNewCorruptNetworkServer) *CorruptNetworkServer
NewCorruptNetworkServer creates a new instance of CorruptNetworkServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptNetworkServer) ConnectAttacker ¶ added in v0.28.0
func (_m *CorruptNetworkServer) ConnectAttacker(_a0 *emptypb.Empty, _a1 insecure.CorruptNetwork_ConnectAttackerServer) error
ConnectAttacker provides a mock function with given fields: _a0, _a1
func (*CorruptNetworkServer) ProcessAttackerMessage ¶ added in v0.28.0
func (_m *CorruptNetworkServer) ProcessAttackerMessage(_a0 insecure.CorruptNetwork_ProcessAttackerMessageServer) error
ProcessAttackerMessage provides a mock function with given fields: _a0
type CorruptNetwork_ConnectAttackerClient ¶ added in v0.28.0
CorruptNetwork_ConnectAttackerClient is an autogenerated mock type for the CorruptNetwork_ConnectAttackerClient type
func NewCorruptNetwork_ConnectAttackerClient ¶ added in v0.28.0
func NewCorruptNetwork_ConnectAttackerClient(t mockConstructorTestingTNewCorruptNetwork_ConnectAttackerClient) *CorruptNetwork_ConnectAttackerClient
NewCorruptNetwork_ConnectAttackerClient creates a new instance of CorruptNetwork_ConnectAttackerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptNetwork_ConnectAttackerClient) CloseSend ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*CorruptNetwork_ConnectAttackerClient) Context ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerClient) Context() context.Context
Context provides a mock function with given fields:
func (*CorruptNetwork_ConnectAttackerClient) Header ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*CorruptNetwork_ConnectAttackerClient) Recv ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerClient) Recv() (*insecure.Message, error)
Recv provides a mock function with given fields:
func (*CorruptNetwork_ConnectAttackerClient) RecvMsg ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*CorruptNetwork_ConnectAttackerClient) SendMsg ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*CorruptNetwork_ConnectAttackerClient) Trailer ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type CorruptNetwork_ConnectAttackerServer ¶ added in v0.28.0
CorruptNetwork_ConnectAttackerServer is an autogenerated mock type for the CorruptNetwork_ConnectAttackerServer type
func NewCorruptNetwork_ConnectAttackerServer ¶ added in v0.28.0
func NewCorruptNetwork_ConnectAttackerServer(t mockConstructorTestingTNewCorruptNetwork_ConnectAttackerServer) *CorruptNetwork_ConnectAttackerServer
NewCorruptNetwork_ConnectAttackerServer creates a new instance of CorruptNetwork_ConnectAttackerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptNetwork_ConnectAttackerServer) Context ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerServer) Context() context.Context
Context provides a mock function with given fields:
func (*CorruptNetwork_ConnectAttackerServer) RecvMsg ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*CorruptNetwork_ConnectAttackerServer) Send ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerServer) Send(_a0 *insecure.Message) error
Send provides a mock function with given fields: _a0
func (*CorruptNetwork_ConnectAttackerServer) SendHeader ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*CorruptNetwork_ConnectAttackerServer) SendMsg ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*CorruptNetwork_ConnectAttackerServer) SetHeader ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*CorruptNetwork_ConnectAttackerServer) SetTrailer ¶ added in v0.28.0
func (_m *CorruptNetwork_ConnectAttackerServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type CorruptNetwork_ProcessAttackerMessageClient ¶ added in v0.28.0
CorruptNetwork_ProcessAttackerMessageClient is an autogenerated mock type for the CorruptNetwork_ProcessAttackerMessageClient type
func NewCorruptNetwork_ProcessAttackerMessageClient ¶ added in v0.28.0
func NewCorruptNetwork_ProcessAttackerMessageClient(t mockConstructorTestingTNewCorruptNetwork_ProcessAttackerMessageClient) *CorruptNetwork_ProcessAttackerMessageClient
NewCorruptNetwork_ProcessAttackerMessageClient creates a new instance of CorruptNetwork_ProcessAttackerMessageClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptNetwork_ProcessAttackerMessageClient) CloseAndRecv ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageClient) CloseAndRecv() (*emptypb.Empty, error)
CloseAndRecv provides a mock function with given fields:
func (*CorruptNetwork_ProcessAttackerMessageClient) CloseSend ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*CorruptNetwork_ProcessAttackerMessageClient) Context ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageClient) Context() context.Context
Context provides a mock function with given fields:
func (*CorruptNetwork_ProcessAttackerMessageClient) Header ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*CorruptNetwork_ProcessAttackerMessageClient) RecvMsg ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*CorruptNetwork_ProcessAttackerMessageClient) Send ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageClient) Send(_a0 *insecure.Message) error
Send provides a mock function with given fields: _a0
func (*CorruptNetwork_ProcessAttackerMessageClient) SendMsg ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*CorruptNetwork_ProcessAttackerMessageClient) Trailer ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type CorruptNetwork_ProcessAttackerMessageServer ¶ added in v0.28.0
CorruptNetwork_ProcessAttackerMessageServer is an autogenerated mock type for the CorruptNetwork_ProcessAttackerMessageServer type
func NewCorruptNetwork_ProcessAttackerMessageServer ¶ added in v0.28.0
func NewCorruptNetwork_ProcessAttackerMessageServer(t mockConstructorTestingTNewCorruptNetwork_ProcessAttackerMessageServer) *CorruptNetwork_ProcessAttackerMessageServer
NewCorruptNetwork_ProcessAttackerMessageServer creates a new instance of CorruptNetwork_ProcessAttackerMessageServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*CorruptNetwork_ProcessAttackerMessageServer) Context ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageServer) Context() context.Context
Context provides a mock function with given fields:
func (*CorruptNetwork_ProcessAttackerMessageServer) Recv ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageServer) Recv() (*insecure.Message, error)
Recv provides a mock function with given fields:
func (*CorruptNetwork_ProcessAttackerMessageServer) RecvMsg ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*CorruptNetwork_ProcessAttackerMessageServer) SendAndClose ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageServer) SendAndClose(_a0 *emptypb.Empty) error
SendAndClose provides a mock function with given fields: _a0
func (*CorruptNetwork_ProcessAttackerMessageServer) SendHeader ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*CorruptNetwork_ProcessAttackerMessageServer) SendMsg ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*CorruptNetwork_ProcessAttackerMessageServer) SetHeader ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*CorruptNetwork_ProcessAttackerMessageServer) SetTrailer ¶ added in v0.28.0
func (_m *CorruptNetwork_ProcessAttackerMessageServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
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 mockConstructorTestingTNewCorruptedNodeConnection) *CorruptedNodeConnection
NewCorruptedNodeConnection creates a new instance of CorruptedNodeConnection. It also registers a testing 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 mockConstructorTestingTNewCorruptedNodeConnector) *CorruptedNodeConnector
NewCorruptedNodeConnector creates a new instance of CorruptedNodeConnector. It also registers a testing 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 irrecoverable.SignalerContext, _a1 flow.Identifier) (insecure.CorruptedNodeConnection, error)
Connect provides a mock function with given fields: _a0, _a1
func (*CorruptedNodeConnector) WithIncomingMessageHandler ¶ added in v0.27.0
func (_m *CorruptedNodeConnector) WithIncomingMessageHandler(_a0 func(*insecure.Message))
WithIncomingMessageHandler provides a mock function with given fields: _a0
type EgressController ¶ added in v0.28.0
EgressController is an autogenerated mock type for the EgressController type
func NewEgressController ¶ added in v0.28.0
func NewEgressController(t mockConstructorTestingTNewEgressController) *EgressController
NewEgressController creates a new instance of EgressController. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*EgressController) EngineClosingChannel ¶ added in v0.28.0
func (_m *EgressController) EngineClosingChannel(_a0 channels.Channel) error
EngineClosingChannel provides a mock function with given fields: _a0
func (*EgressController) HandleOutgoingEvent ¶ added in v0.28.0
func (_m *EgressController) HandleOutgoingEvent(_a0 interface{}, _a1 channels.Channel, _a2 insecure.Protocol, _a3 uint32, _a4 ...flow.Identifier) error
HandleOutgoingEvent provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4
type IngressController ¶ added in v0.28.0
IngressController is an autogenerated mock type for the IngressController type
func NewIngressController ¶ added in v0.28.0
func NewIngressController(t mockConstructorTestingTNewIngressController) *IngressController
NewIngressController creates a new instance of IngressController. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*IngressController) HandleIncomingEvent ¶ added in v0.28.0
func (_m *IngressController) HandleIncomingEvent(_a0 interface{}, _a1 channels.Channel, _a2 flow.Identifier) bool
HandleIncomingEvent provides a mock function with given fields: _a0, _a1, _a2
type OrchestratorNetwork ¶ added in v0.28.0
OrchestratorNetwork is an autogenerated mock type for the OrchestratorNetwork type
func NewOrchestratorNetwork ¶ added in v0.28.0
func NewOrchestratorNetwork(t mockConstructorTestingTNewOrchestratorNetwork) *OrchestratorNetwork
NewOrchestratorNetwork creates a new instance of OrchestratorNetwork. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*OrchestratorNetwork) Done ¶ added in v0.28.0
func (_m *OrchestratorNetwork) Done() <-chan struct{}
Done provides a mock function with given fields:
func (*OrchestratorNetwork) Observe ¶ added in v0.28.0
func (_m *OrchestratorNetwork) Observe(_a0 *insecure.Message)
Observe provides a mock function with given fields: _a0
func (*OrchestratorNetwork) Ready ¶ added in v0.28.0
func (_m *OrchestratorNetwork) Ready() <-chan struct{}
Ready provides a mock function with given fields:
func (*OrchestratorNetwork) SendEgress ¶ added in v0.28.0
func (_m *OrchestratorNetwork) SendEgress(_a0 *insecure.EgressEvent) error
SendEgress provides a mock function with given fields: _a0
func (*OrchestratorNetwork) SendIngress ¶ added in v0.28.0
func (_m *OrchestratorNetwork) SendIngress(_a0 *insecure.IngressEvent) error
SendIngress provides a mock function with given fields: _a0
func (*OrchestratorNetwork) Start ¶ added in v0.28.0
func (_m *OrchestratorNetwork) Start(_a0 irrecoverable.SignalerContext)
Start provides a mock function with given fields: _a0
Source Files ¶
- attack_orchestrator.go
- corrupt_conduit_factory.go
- corrupt_network__connect_attacker_client.go
- corrupt_network__connect_attacker_server.go
- corrupt_network__process_attacker_message_client.go
- corrupt_network__process_attacker_message_server.go
- corrupt_network_client.go
- corrupt_network_server.go
- corrupted_node_connection.go
- corrupted_node_connector.go
- egress_controller.go
- ingress_controller.go
- orchestrator_network.go