mockinsecure

Oct 13, 2022

Changes in this version

type AttackOrchestrator

+ func (_m *AttackOrchestrator) HandleEgressEvent(_a0 *insecure.EgressEvent) error

+ func (_m *AttackOrchestrator) HandleIngressEvent(_a0 *insecure.IngressEvent) error

+ func (_m *AttackOrchestrator) Register(_a0 insecure.OrchestratorNetwork)

+ type CorruptConduitFactory struct

+ func NewCorruptConduitFactory(t mockConstructorTestingTNewCorruptConduitFactory) *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 struct

+ func NewCorruptNetworkClient(t mockConstructorTestingTNewCorruptNetworkClient) *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 struct

+ func NewCorruptNetworkServer(t mockConstructorTestingTNewCorruptNetworkServer) *CorruptNetworkServer

+ func (_m *CorruptNetworkServer) ConnectAttacker(_a0 *emptypb.Empty, _a1 insecure.CorruptNetwork_ConnectAttackerServer) error

+ func (_m *CorruptNetworkServer) ProcessAttackerMessage(_a0 insecure.CorruptNetwork_ProcessAttackerMessageServer) error

+ type CorruptNetwork_ConnectAttackerClient struct

+ func NewCorruptNetwork_ConnectAttackerClient(t mockConstructorTestingTNewCorruptNetwork_ConnectAttackerClient) *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 struct

+ func NewCorruptNetwork_ConnectAttackerServer(t mockConstructorTestingTNewCorruptNetwork_ConnectAttackerServer) *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 struct

+ func NewCorruptNetwork_ProcessAttackerMessageClient(t mockConstructorTestingTNewCorruptNetwork_ProcessAttackerMessageClient) *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 struct

+ func NewCorruptNetwork_ProcessAttackerMessageServer(t mockConstructorTestingTNewCorruptNetwork_ProcessAttackerMessageServer) *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 EgressController struct

+ func NewEgressController(t mockConstructorTestingTNewEgressController) *EgressController

+ func (_m *EgressController) EngineClosingChannel(_a0 channels.Channel) error

+ func (_m *EgressController) HandleOutgoingEvent(_a0 interface{}, _a1 channels.Channel, _a2 insecure.Protocol, _a3 uint32, ...) error

+ type IngressController struct

+ func NewIngressController(t mockConstructorTestingTNewIngressController) *IngressController

+ func (_m *IngressController) HandleIncomingEvent(_a0 interface{}, _a1 channels.Channel, _a2 flow.Identifier) bool

+ type OrchestratorNetwork struct

+ func NewOrchestratorNetwork(t mockConstructorTestingTNewOrchestratorNetwork) *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)

Aug 2, 2022

Changes in this version

type AttackNetwork

+ func (_m *AttackNetwork) Observe(_a0 *insecure.Message)

type CorruptedNodeConnector

+ func (_m *CorruptedNodeConnector) WithIncomingMessageHandler(_a0 func(*insecure.Message))

type CorruptibleConduitFactoryClient

+ func (_m *CorruptibleConduitFactoryClient) ConnectAttacker(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (insecure.CorruptibleConduitFactory_ConnectAttackerClient, error)

type CorruptibleConduitFactoryServer

+ func (_m *CorruptibleConduitFactoryServer) ConnectAttacker(_a0 *emptypb.Empty, ...) error

+ type CorruptibleConduitFactory_ConnectAttackerClient struct

+ func NewCorruptibleConduitFactory_ConnectAttackerClient(t NewCorruptibleConduitFactory_ConnectAttackerClientT) *CorruptibleConduitFactory_ConnectAttackerClient

+ func (_m *CorruptibleConduitFactory_ConnectAttackerClient) CloseSend() error

+ func (_m *CorruptibleConduitFactory_ConnectAttackerClient) Context() context.Context

+ func (_m *CorruptibleConduitFactory_ConnectAttackerClient) Header() (metadata.MD, error)

+ func (_m *CorruptibleConduitFactory_ConnectAttackerClient) Recv() (*insecure.Message, error)

+ func (_m *CorruptibleConduitFactory_ConnectAttackerClient) RecvMsg(m interface{}) error

+ func (_m *CorruptibleConduitFactory_ConnectAttackerClient) SendMsg(m interface{}) error

+ func (_m *CorruptibleConduitFactory_ConnectAttackerClient) Trailer() metadata.MD

+ type CorruptibleConduitFactory_ConnectAttackerServer struct

+ func NewCorruptibleConduitFactory_ConnectAttackerServer(t NewCorruptibleConduitFactory_ConnectAttackerServerT) *CorruptibleConduitFactory_ConnectAttackerServer

+ func (_m *CorruptibleConduitFactory_ConnectAttackerServer) Context() context.Context

+ func (_m *CorruptibleConduitFactory_ConnectAttackerServer) RecvMsg(m interface{}) error

+ func (_m *CorruptibleConduitFactory_ConnectAttackerServer) Send(_a0 *insecure.Message) error

+ func (_m *CorruptibleConduitFactory_ConnectAttackerServer) SendHeader(_a0 metadata.MD) error

+ func (_m *CorruptibleConduitFactory_ConnectAttackerServer) SendMsg(m interface{}) error

+ func (_m *CorruptibleConduitFactory_ConnectAttackerServer) SetHeader(_a0 metadata.MD) error

+ func (_m *CorruptibleConduitFactory_ConnectAttackerServer) SetTrailer(_a0 metadata.MD)

+ type NewAttackNetworkT interface

+ Cleanup func(func())

+ type NewAttackOrchestratorT interface

+ Cleanup func(func())

+ type NewAttacker_ObserveClientT interface

+ Cleanup func(func())

+ type NewAttacker_ObserveServerT interface

+ Cleanup func(func())

+ type NewConduitControllerT interface

+ Cleanup func(func())

+ type NewCorruptedNodeConnectionT interface

+ Cleanup func(func())

+ type NewCorruptedNodeConnectorT interface

+ Cleanup func(func())

+ type NewCorruptibleConduitFactoryClientT interface

+ Cleanup func(func())

+ type NewCorruptibleConduitFactoryServerT interface

+ Cleanup func(func())

+ type NewCorruptibleConduitFactory_ConnectAttackerClientT interface

+ Cleanup func(func())

+ type NewCorruptibleConduitFactory_ConnectAttackerServerT interface

+ Cleanup func(func())

+ type NewCorruptibleConduitFactory_ProcessAttackerMessageClientT interface

+ Cleanup func(func())

+ type NewCorruptibleConduitFactory_ProcessAttackerMessageServerT interface

+ Cleanup func(func())

May 25, 2022

Changes in this version

type AttackNetwork

+ func NewAttackNetwork(t testing.TB) *AttackNetwork

type AttackOrchestrator

+ func NewAttackOrchestrator(t testing.TB) *AttackOrchestrator

type AttackerClient

+ func NewAttackerClient(t testing.TB) *AttackerClient

type AttackerServer

+ func NewAttackerServer(t testing.TB) *AttackerServer

type Attacker_ObserveClient

+ func NewAttacker_ObserveClient(t testing.TB) *Attacker_ObserveClient

type Attacker_ObserveServer

+ func NewAttacker_ObserveServer(t testing.TB) *Attacker_ObserveServer

type ConduitController

+ func NewConduitController(t testing.TB) *ConduitController

type CorruptedNodeConnection

+ func NewCorruptedNodeConnection(t testing.TB) *CorruptedNodeConnection

type CorruptedNodeConnector

+ func NewCorruptedNodeConnector(t testing.TB) *CorruptedNodeConnector

type CorruptibleConduitFactoryClient

+ func NewCorruptibleConduitFactoryClient(t testing.TB) *CorruptibleConduitFactoryClient

type CorruptibleConduitFactoryServer

+ func NewCorruptibleConduitFactoryServer(t testing.TB) *CorruptibleConduitFactoryServer

type CorruptibleConduitFactory_ProcessAttackerMessageClient

+ func NewCorruptibleConduitFactory_ProcessAttackerMessageClient(t testing.TB) *CorruptibleConduitFactory_ProcessAttackerMessageClient

type CorruptibleConduitFactory_ProcessAttackerMessageServer

+ func NewCorruptibleConduitFactory_ProcessAttackerMessageServer(t testing.TB) *CorruptibleConduitFactory_ProcessAttackerMessageServer

May 17, 2022

Changes in this version

type CorruptedNodeConnector

+ func (_m *CorruptedNodeConnector) WithAttackerAddress(_a0 string)

Mar 23, 2022

Changes in this version

type AttackNetwork

+ func (_m *AttackNetwork) Send(_a0 *insecure.Event) error

type AttackOrchestrator

+ func (_m *AttackOrchestrator) WithAttackNetwork(_a0 insecure.AttackNetwork)

+ type ConduitController struct

+ func (_m *ConduitController) EngineClosingChannel(_a0 network.Channel) error

+ func (_m *ConduitController) HandleIncomingEvent(_a0 interface{}, _a1 network.Channel, _a2 insecure.Protocol, _a3 uint32, ...) error

+ type CorruptedNodeConnection struct

+ func (_m *CorruptedNodeConnection) CloseConnection() error

+ func (_m *CorruptedNodeConnection) SendMessage(_a0 *insecure.Message) error

+ type CorruptedNodeConnector struct

+ func (_m *CorruptedNodeConnector) Connect(_a0 context.Context, _a1 flow.Identifier) (insecure.CorruptedNodeConnection, error)

Mar 10, 2022

Changes in this version

+ type AttackNetwork struct

+ func (_m *AttackNetwork) Done() <-chan struct{}

+ func (_m *AttackNetwork) Ready() <-chan struct{}

+ func (_m *AttackNetwork) RpcMulticastOnChannel(_a0 flow.Identifier, _a1 network.Channel, _a2 interface{}, _a3 uint32, ...) error

+ func (_m *AttackNetwork) RpcPublishOnChannel(_a0 flow.Identifier, _a1 network.Channel, _a2 interface{}, ...) error

+ func (_m *AttackNetwork) RpcUnicastOnChannel(_a0 flow.Identifier, _a1 network.Channel, _a2 interface{}, _a3 flow.Identifier) error

+ func (_m *AttackNetwork) Start(_a0 irrecoverable.SignalerContext)

+ type AttackOrchestrator struct

+ func (_m *AttackOrchestrator) Done() <-chan struct{}

+ func (_m *AttackOrchestrator) HandleEventFromCorruptedNode(_a0 flow.Identifier, _a1 network.Channel, _a2 interface{}, ...) error

+ func (_m *AttackOrchestrator) Ready() <-chan struct{}

+ func (_m *AttackOrchestrator) Start(_a0 irrecoverable.SignalerContext)

+ type AttackerClient struct

+ func (_m *AttackerClient) Observe(ctx context.Context, opts ...grpc.CallOption) (insecure.Attacker_ObserveClient, error)

+ type AttackerServer struct

+ func (_m *AttackerServer) Observe(_a0 insecure.Attacker_ObserveServer) error

+ type Attacker_ObserveClient struct

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

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

+ func (_m *ConduitMaster) EngineClosingChannel(_a0 network.Channel) error

+ func (_m *ConduitMaster) HandleIncomingEvent(_a0 interface{}, _a1 network.Channel, _a2 insecure.Protocol, _a3 uint32, ...) error

+ type CorruptibleConduitFactoryClient struct

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

+ func (_m *CorruptibleConduitFactoryServer) ProcessAttackerMessage(_a0 insecure.CorruptibleConduitFactory_ProcessAttackerMessageServer) error

+ func (_m *CorruptibleConduitFactoryServer) RegisterAttacker(_a0 context.Context, _a1 *insecure.AttackerRegisterMessage) (*emptypb.Empty, error)

+ type CorruptibleConduitFactory_ProcessAttackerMessageClient struct

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

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