corruptnet

Oct 13, 2022

Changes in this version

+ type Conduit struct

+ func (c *Conduit) Close() error

+ func (c *Conduit) Multicast(event interface{}, num uint, targetIDs ...flow.Identifier) error

+ func (c *Conduit) Publish(event interface{}, targetIDs ...flow.Identifier) error

+ func (c *Conduit) Unicast(event interface{}, targetID flow.Identifier) error

+ type ConduitFactory struct

+ func NewCorruptConduitFactory(logger zerolog.Logger, chainId flow.ChainID) *ConduitFactory

+ func (c *ConduitFactory) NewConduit(ctx context.Context, channel channels.Channel) (network.Conduit, error)

+ func (c *ConduitFactory) RegisterAdapter(adapter network.Adapter) error

+ func (c *ConduitFactory) RegisterEgressController(controller insecure.EgressController) error

+ func (c *ConduitFactory) SendOnFlowNetwork(event interface{}, channel channels.Channel, protocol insecure.Protocol, ...) error

+ func (c *ConduitFactory) UnregisterChannel(channel channels.Channel) error

+ type MessageProcessor struct

+ func NewCorruptMessageProcessor(logger zerolog.Logger, originalProcessor flownet.MessageProcessor, ...) *MessageProcessor

+ func (m *MessageProcessor) Process(channel channels.Channel, originID flow.Identifier, event interface{}) error

+ type Network struct

+ func NewCorruptNetwork(logger zerolog.Logger, chainId flow.ChainID, address string, me module.Local, ...) (*Network, error)

+ func (n *Network) AttackerRegistered() bool

+ func (n *Network) ConnectAttacker(_ *empty.Empty, stream insecure.CorruptNetwork_ConnectAttackerServer) error

+ func (n *Network) EngineClosingChannel(channel channels.Channel) error

+ func (n *Network) HandleIncomingEvent(event interface{}, channel channels.Channel, originId flow.Identifier) bool

+ func (n *Network) HandleOutgoingEvent(event interface{}, channel channels.Channel, protocol insecure.Protocol, ...) error

+ func (n *Network) ProcessAttackerMessage(stream insecure.CorruptNetwork_ProcessAttackerMessageServer) error

+ func (n *Network) Register(channel channels.Channel, messageProcessor flownet.MessageProcessor) (flownet.Conduit, error)

+ func (n *Network) RegisterBlobService(channel channels.Channel, store datastore.Batching, ...) (flownet.BlobService, error)

+ func (n *Network) RegisterPingService(pingProtocolID protocol.ID, pingInfoProvider flownet.PingInfoProvider) (flownet.PingService, error)

+ func (n *Network) ServerAddress() string