mocknetwork

Oct 3, 2023

Changes in this version

+ type ConduitAdapter struct

+ func NewConduitAdapter(t mockConstructorTestingTNewConduitAdapter) *ConduitAdapter

+ func (_m *ConduitAdapter) MulticastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 uint, _a3 ...flow.Identifier) error

+ func (_m *ConduitAdapter) PublishOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 ...flow.Identifier) error

+ func (_m *ConduitAdapter) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)

+ func (_m *ConduitAdapter) UnRegisterChannel(channel channels.Channel) error

+ func (_m *ConduitAdapter) UnicastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 flow.Identifier) error

type Connector

+ func (_m *Connector) Connect(ctx context.Context, peerChan <-chan peer.AddrInfo)

+ type ConnectorFactory struct

+ func NewConnectorFactory(t mockConstructorTestingTNewConnectorFactory) *ConnectorFactory

+ func (_m *ConnectorFactory) Execute(_a0 host.Host) (p2p.Connector, error)

type ConnectorHost

+ func (_m *ConnectorHost) IsConnectedTo(peerId peer.ID) bool

+ type DisallowListNotificationConsumer struct

+ func NewDisallowListNotificationConsumer(t mockConstructorTestingTNewDisallowListNotificationConsumer) *DisallowListNotificationConsumer

+ func (_m *DisallowListNotificationConsumer) OnAllowListNotification(_a0 *network.AllowListingUpdate)

+ func (_m *DisallowListNotificationConsumer) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)

+ type DisallowListOracle struct

+ func NewDisallowListOracle(t mockConstructorTestingTNewDisallowListOracle) *DisallowListOracle

+ func (_m *DisallowListOracle) GetAllDisallowedListCausesFor(_a0 peer.ID) []network.DisallowListedCause

+ type EngineRegistry struct

+ func NewEngineRegistry(t mockConstructorTestingTNewEngineRegistry) *EngineRegistry

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

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

+ func (_m *EngineRegistry) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)

+ func (_m *EngineRegistry) RegisterBlobService(channel channels.Channel, store datastore.Batching, ...) (network.BlobService, error)

+ func (_m *EngineRegistry) RegisterPingService(pingProtocolID protocol.ID, pingInfoProvider network.PingInfoProvider) (network.PingService, error)

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

+ type IncomingMessageScope struct

+ func NewIncomingMessageScope(t mockConstructorTestingTNewIncomingMessageScope) *IncomingMessageScope

+ func (_m *IncomingMessageScope) Channel() channels.Channel

+ func (_m *IncomingMessageScope) DecodedPayload() interface{}

+ func (_m *IncomingMessageScope) EventID() []byte

+ func (_m *IncomingMessageScope) OriginId() flow.Identifier

+ func (_m *IncomingMessageScope) PayloadType() string

+ func (_m *IncomingMessageScope) Proto() *message.Message

+ func (_m *IncomingMessageScope) Protocol() message.ProtocolType

+ func (_m *IncomingMessageScope) Size() int

+ func (_m *IncomingMessageScope) TargetIDs() flow.IdentifierList

type Middleware

+ func (_m *Middleware) OnAllowListNotification(_a0 *network.AllowListingUpdate)

+ func (_m *Middleware) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)

+ type MisbehaviorReportConsumer struct

+ func NewMisbehaviorReportConsumer(t mockConstructorTestingTNewMisbehaviorReportConsumer) *MisbehaviorReportConsumer

+ func (_m *MisbehaviorReportConsumer) ReportMisbehaviorOnChannel(channel channels.Channel, report network.MisbehaviorReport)

+ type MockEngineRegistry struct

+ func NewMockEngineRegistry(ctrl *gomock.Controller) *MockEngineRegistry

+ func (m *MockEngineRegistry) Done() <-chan struct{}

+ func (m *MockEngineRegistry) EXPECT() *MockEngineRegistryMockRecorder

+ func (m *MockEngineRegistry) Ready() <-chan struct{}

+ func (m *MockEngineRegistry) Register(arg0 channels.Channel, arg1 network.MessageProcessor) (network.Conduit, error)

+ func (m *MockEngineRegistry) RegisterBlobService(arg0 channels.Channel, arg1 datastore.Batching, ...) (network.BlobService, error)

+ func (m *MockEngineRegistry) RegisterPingService(arg0 protocol.ID, arg1 network.PingInfoProvider) (network.PingService, error)

+ func (m *MockEngineRegistry) Start(arg0 irrecoverable.SignalerContext)

+ type MockEngineRegistryMockRecorder struct

+ func (mr *MockEngineRegistryMockRecorder) Done() *gomock.Call

+ func (mr *MockEngineRegistryMockRecorder) Ready() *gomock.Call

+ func (mr *MockEngineRegistryMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEngineRegistryMockRecorder) RegisterBlobService(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockEngineRegistryMockRecorder) RegisterPingService(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEngineRegistryMockRecorder) Start(arg0 interface{}) *gomock.Call

+ type OutgoingMessageScope struct

+ func NewOutgoingMessageScope(t mockConstructorTestingTNewOutgoingMessageScope) *OutgoingMessageScope

+ func (_m *OutgoingMessageScope) PayloadType() string

+ func (_m *OutgoingMessageScope) Proto() *message.Message

+ func (_m *OutgoingMessageScope) Size() int

+ func (_m *OutgoingMessageScope) TargetIds() flow.IdentifierList

+ func (_m *OutgoingMessageScope) Topic() channels.Topic

+ type Underlay struct

+ func NewUnderlay(t mockConstructorTestingTNewUnderlay) *Underlay

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

+ func (_m *Underlay) OnAllowListNotification(_a0 *network.AllowListingUpdate)

+ func (_m *Underlay) OnDisallowListNotification(_a0 *network.DisallowListingUpdate)

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

+ func (_m *Underlay) Subscribe(channel channels.Channel) error

+ func (_m *Underlay) Unsubscribe(channel channels.Channel) error

+ func (_m *Underlay) UpdateNodeAddresses()

type ViolationsConsumer

+ func (_m *ViolationsConsumer) OnUnauthorizedPublishOnChannel(violation *network.Violation)

Jun 5, 2023

Changes in this version

type Adapter

+ func (_m *Adapter) ReportMisbehaviorOnChannel(_a0 channels.Channel, _a1 network.MisbehaviorReport)

type Conduit

+ func (_m *Conduit) ReportMisbehavior(_a0 network.MisbehaviorReport)

+ type ConnectorHost struct

+ func NewConnectorHost(t mockConstructorTestingTNewConnectorHost) *ConnectorHost

+ func (_m *ConnectorHost) ClosePeer(id peer.ID) error

+ func (_m *ConnectorHost) Connections() []network.Conn

+ func (_m *ConnectorHost) ID() peer.ID

+ func (_m *ConnectorHost) IsProtected(id peer.ID) bool

+ func (_m *ConnectorHost) PeerInfo(id peer.ID) peer.AddrInfo

+ type MisbehaviorReport struct

+ func NewMisbehaviorReport(t mockConstructorTestingTNewMisbehaviorReport) *MisbehaviorReport

+ func (_m *MisbehaviorReport) OriginId() flow.Identifier

+ func (_m *MisbehaviorReport) Penalty() float64

+ func (_m *MisbehaviorReport) Reason() network.Misbehavior

+ type MisbehaviorReportManager struct

+ func NewMisbehaviorReportManager(t mockConstructorTestingTNewMisbehaviorReportManager) *MisbehaviorReportManager

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

+ func (_m *MisbehaviorReportManager) HandleMisbehaviorReport(_a0 channels.Channel, _a1 network.MisbehaviorReport)

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

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

+ type MisbehaviorReporter struct

+ func NewMisbehaviorReporter(t mockConstructorTestingTNewMisbehaviorReporter) *MisbehaviorReporter

+ func (_m *MisbehaviorReporter) ReportMisbehavior(_a0 network.MisbehaviorReport)

Dec 16, 2022

Changes in this version

type ViolationsConsumer

+ func (_m *ViolationsConsumer) OnUnauthorizedUnicastOnChannel(violation *slashing.Violation)

Oct 13, 2022

Changes in this version

type Topology

+ func (_m *Topology) Fanout(ids flow.IdentityList) flow.IdentityList

type ViolationsConsumer

+ func (_m *ViolationsConsumer) OnUnexpectedError(violation *slashing.Violation)

Aug 21, 2022

Changes in this version

+ type ViolationsConsumer struct

+ func NewViolationsConsumer(t mockConstructorTestingTNewViolationsConsumer) *ViolationsConsumer

+ func (_m *ViolationsConsumer) OnInvalidMsgError(violation *slashing.Violation)

+ func (_m *ViolationsConsumer) OnSenderEjectedError(violation *slashing.Violation)

+ func (_m *ViolationsConsumer) OnUnAuthorizedSenderError(violation *slashing.Violation)

+ func (_m *ViolationsConsumer) OnUnknownMsgTypeError(violation *slashing.Violation)

Aug 2, 2022

Changes in this version

+ type NewAdapterT interface

+ Cleanup func(func())

+ type NewBasicResolverT interface

+ Cleanup func(func())

+ type NewBlobGetterT interface

+ Cleanup func(func())

+ type NewBlobServiceOptionT interface

+ Cleanup func(func())

+ type NewBlobServiceT interface

+ Cleanup func(func())

+ type NewCodecT interface

+ Cleanup func(func())

+ type NewCompressorT interface

+ Cleanup func(func())

+ type NewConduitFactoryT interface

+ Cleanup func(func())

+ type NewConduitT interface

+ Cleanup func(func())

+ type NewConnectionT interface

+ Cleanup func(func())

+ type NewDecoderT interface

+ Cleanup func(func())

+ type NewEncoderT interface

+ Cleanup func(func())

+ type NewEngineT interface

+ Cleanup func(func())

+ type NewMessageProcessorT interface

+ Cleanup func(func())

+ type NewMessageQueueT interface

+ Cleanup func(func())

+ type NewMessageValidatorT interface

+ Cleanup func(func())

+ type NewMiddlewareT interface

+ Cleanup func(func())

+ type NewNetworkT interface

+ Cleanup func(func())

+ type NewOverlayT interface

+ Cleanup func(func())

+ type NewPingInfoProviderT interface

+ Cleanup func(func())

+ type NewPingServiceT interface

+ Cleanup func(func())

+ type NewSubscriptionManagerT interface

+ Cleanup func(func())

+ type NewTopologyT interface

+ Cleanup func(func())

+ type NewWriteCloseFlusherT interface

+ Cleanup func(func())

Jul 11, 2022

Changes in this version

+ type NewConnectorOptionT interface

+ Cleanup func(func())

+ type NewConnectorT interface

+ Cleanup func(func())

May 25, 2022

Changes in this version

type Adapter

+ func NewAdapter(t testing.TB) *Adapter

type BasicResolver

+ func NewBasicResolver(t testing.TB) *BasicResolver

type BlobGetter

+ func NewBlobGetter(t testing.TB) *BlobGetter

type BlobService

+ func NewBlobService(t testing.TB) *BlobService

+ type BlobServiceOption struct

+ func NewBlobServiceOption(t testing.TB) *BlobServiceOption

+ func (_m *BlobServiceOption) Execute(_a0 network.BlobService)

type Codec

+ func NewCodec(t testing.TB) *Codec

type Compressor

+ func NewCompressor(t testing.TB) *Compressor

type Conduit

+ func NewConduit(t testing.TB) *Conduit

type ConduitFactory

+ func NewConduitFactory(t testing.TB) *ConduitFactory

type Connection

+ func NewConnection(t testing.TB) *Connection

type Connector

+ func NewConnector(t testing.TB) *Connector

+ type ConnectorOption struct

+ func NewConnectorOption(t testing.TB) *ConnectorOption

+ func (_m *ConnectorOption) Execute(connector *p2p.Libp2pConnector)

type Decoder

+ func NewDecoder(t testing.TB) *Decoder

type Encoder

+ func NewEncoder(t testing.TB) *Encoder

type Engine

+ func NewEngine(t testing.TB) *Engine

type MessageProcessor

+ func NewMessageProcessor(t testing.TB) *MessageProcessor

type MessageQueue

+ func NewMessageQueue(t testing.TB) *MessageQueue

type MessageValidator

+ func NewMessageValidator(t testing.TB) *MessageValidator

type Middleware

+ func NewMiddleware(t testing.TB) *Middleware

type Network

+ func NewNetwork(t testing.TB) *Network

type Overlay

+ func NewOverlay(t testing.TB) *Overlay

type PingInfoProvider

+ func NewPingInfoProvider(t testing.TB) *PingInfoProvider

type PingService

+ func NewPingService(t testing.TB) *PingService

type SubscriptionManager

+ func NewSubscriptionManager(t testing.TB) *SubscriptionManager

type Topology

+ func NewTopology(t testing.TB) *Topology

type WriteCloseFlusher

+ func NewWriteCloseFlusher(t testing.TB) *WriteCloseFlusher

Mar 10, 2022

Changes in this version

+ type ConduitFactory struct

+ func (_m *ConduitFactory) NewConduit(_a0 context.Context, _a1 network.Channel) (network.Conduit, error)

+ func (_m *ConduitFactory) RegisterAdapter(_a0 network.Adapter) error

Feb 16, 2022

Changes in this version

+ type Adapter struct

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

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

+ func (_m *Adapter) UnRegisterChannel(channel network.Channel) error

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

Feb 6, 2022

Changes in this version

+ type BlobGetter struct

+ func (_m *BlobGetter) GetBlob(ctx context.Context, c cid.Cid) (blocks.Block, error)

+ func (_m *BlobGetter) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blocks.Block

+ type BlobService struct

+ func (_m *BlobService) AddBlob(ctx context.Context, b blocks.Block) error

+ func (_m *BlobService) AddBlobs(ctx context.Context, bs []blocks.Block) error

+ func (_m *BlobService) DeleteBlob(ctx context.Context, c cid.Cid) error

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

+ func (_m *BlobService) GetBlob(ctx context.Context, c cid.Cid) (blocks.Block, error)

+ func (_m *BlobService) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blocks.Block

+ func (_m *BlobService) GetSession(ctx context.Context) network.BlobGetter

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

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

+ func (_m *BlobService) TriggerReprovide(ctx context.Context) error

type Middleware

+ func (_m *Middleware) IsConnected(nodeID flow.Identifier) (bool, error)

+ func (_m *Middleware) NewBlobService(channel network.Channel, store datastore.Batching, ...) network.BlobService

+ func (_m *Middleware) NewPingService(pingProtocol protocol.ID, provider network.PingInfoProvider) network.PingService

type MockNetwork

+ func (m *MockNetwork) RegisterBlobService(arg0 network.Channel, arg1 go_datastore.Batching, ...) (network.BlobService, error)

+ func (m *MockNetwork) RegisterPingService(arg0 protocol.ID, arg1 network.PingInfoProvider) (network.PingService, error)

type MockNetworkMockRecorder

+ func (mr *MockNetworkMockRecorder) RegisterBlobService(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockNetworkMockRecorder) RegisterPingService(arg0, arg1 interface{}) *gomock.Call

type Network

+ func (_m *Network) RegisterBlobService(channel network.Channel, store datastore.Batching, ...) (network.BlobService, error)

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

+ type PingService struct

+ func (_m *PingService) Ping(ctx context.Context, peerID peer.ID) (message.PingResponse, time.Duration, error)

Nov 25, 2021

Changes in this version

+ type BlockExchange struct

+ func (_m *BlockExchange) Close()

+ func (_m *BlockExchange) GetBlocks(cids ...cid.Cid) network.BlocksPromise

+ func (_m *BlockExchange) GetSession(ctx context.Context) network.BlockExchangeFetcher

+ func (_m *BlockExchange) HasBlock(block blocks.Block) error

+ type BlockExchangeFetcher struct

+ func (_m *BlockExchangeFetcher) GetBlocks(cids ...cid.Cid) network.BlocksPromise

+ type BlocksPromise struct

+ func (_m *BlocksPromise) ForEach(cb func(blocks.Block)) network.BlocksRequest

+ type BlocksRequest struct

+ func (_m *BlocksRequest) Send(ctx context.Context) (<-chan struct{}, error)

type MockNetwork

+ func (m *MockNetwork) RegisterBlockExchange(arg0 network.Channel, arg1 go_ipfs_blockstore.Blockstore) (network.BlockExchange, error)

type MockNetworkMockRecorder

+ func (mr *MockNetworkMockRecorder) RegisterBlockExchange(arg0, arg1 interface{}) *gomock.Call

type Network

+ func (_m *Network) RegisterBlockExchange(channel network.Channel, store blockstore.Blockstore) (network.BlockExchange, error)

Nov 8, 2021

Changes in this version

+ type Compressor struct

+ func (_m *Compressor) NewReader(_a0 io.Reader) (io.ReadCloser, error)

+ func (_m *Compressor) NewWriter(_a0 io.Writer) (network.WriteCloseFlusher, error)

+ type WriteCloseFlusher struct

+ func (_m *WriteCloseFlusher) Close() error

+ func (_m *WriteCloseFlusher) Flush() error

+ func (_m *WriteCloseFlusher) Write(p []byte) (int, error)

Oct 26, 2021

Changes in this version

type Engine

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

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

type Middleware

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

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

+ func (_m *Middleware) SetOverlay(_a0 network.Overlay)

+ type MockNetwork struct

+ func NewMockNetwork(ctrl *gomock.Controller) *MockNetwork

+ func (m *MockNetwork) Done() <-chan struct{}

+ func (m *MockNetwork) EXPECT() *MockNetworkMockRecorder

+ func (m *MockNetwork) Ready() <-chan struct{}

+ func (m *MockNetwork) Register(arg0 network.Channel, arg1 network.Engine) (network.Conduit, error)

+ func (m *MockNetwork) Start(arg0 irrecoverable.SignalerContext)

+ type MockNetworkMockRecorder struct

+ func (mr *MockNetworkMockRecorder) Done() *gomock.Call

+ func (mr *MockNetworkMockRecorder) Ready() *gomock.Call

+ func (mr *MockNetworkMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockNetworkMockRecorder) Start(arg0 interface{}) *gomock.Call

+ type Network struct

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

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

+ func (_m *Network) Register(channel network.Channel, engine network.Engine) (network.Conduit, error)

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

Oct 9, 2021

Changes in this version

type PingInfoProvider

+ func (_m *PingInfoProvider) HotstuffView() uint64

Sep 8, 2021

Changes in this version

type Middleware

+ func (_m *Middleware) UpdateNodeAddresses()

type Overlay

+ func (_m *Overlay) Identities() flow.IdentityList

Sep 1, 2021

Changes in this version

+ type BasicResolver struct

+ func (_m *BasicResolver) LookupIPAddr(_a0 context.Context, _a1 string) ([]net.IPAddr, error)

+ func (_m *BasicResolver) LookupTXT(_a0 context.Context, _a1 string) ([]string, error)

Jul 27, 2021

Changes in this version

+ type ReadyDoneAwareNetwork struct

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

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

+ func (_m *ReadyDoneAwareNetwork) Register(channel network.Channel, engine network.Engine) (network.Conduit, error)

Jun 4, 2021

Changes in this version

+ type MessageProcessor struct

+ func (_m *MessageProcessor) Process(originID flow.Identifier, message interface{}) error

May 18, 2021

Changes in this version

type PingInfoProvider

+ func (_m *PingInfoProvider) SealedBlockHeight() uint64

May 12, 2021

Changes in this version

+ type PingInfoProvider struct

+ func (_m *PingInfoProvider) LatestFinalizedBlockHeight() uint64

+ func (_m *PingInfoProvider) SoftwareVersion() string

Feb 3, 2021

Changes in this version

type Connector

+ func (_m *Connector) UpdatePeers(ctx context.Context, ids flow.IdentityList) error

type SubscriptionManager

+ func (_m *SubscriptionManager) Channels() network.ChannelList

Nov 30, 2020

Changes in this version

+ type Codec struct

+ func (_m *Codec) Decode(data []byte) (interface{}, error)

+ func (_m *Codec) Encode(v interface{}) ([]byte, error)

+ func (_m *Codec) NewDecoder(r io.Reader) network.Decoder

+ func (_m *Codec) NewEncoder(w io.Writer) network.Encoder

+ type Conduit struct

+ func (_m *Conduit) Close() error

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

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

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

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

+ type Connection struct

+ func (_m *Connection) Receive() (interface{}, error)

+ func (_m *Connection) Send(msg interface{}) error

+ type Connector struct

+ func (_m *Connector) ConnectPeers(ctx context.Context, ids flow.IdentityList) map[flow.Identifier]error

+ func (_m *Connector) DisconnectPeers(ctx context.Context, ids flow.IdentityList) map[flow.Identifier]error

+ type Decoder struct

+ func (_m *Decoder) Decode() (interface{}, error)

+ type Encoder struct

+ func (_m *Encoder) Encode(v interface{}) error

+ type Engine struct

+ func (_m *Engine) Process(originID flow.Identifier, event interface{}) error

+ func (_m *Engine) ProcessLocal(event interface{}) error

+ func (_m *Engine) Submit(originID flow.Identifier, event interface{})

+ func (_m *Engine) SubmitLocal(event interface{})

+ type MessageQueue struct

+ func (_m *MessageQueue) Insert(message interface{}) error

+ func (_m *MessageQueue) Len() int

+ func (_m *MessageQueue) Remove() interface{}

+ type MessageValidator struct

+ func (_m *MessageValidator) Validate(msg message.Message) bool

+ type Middleware struct

+ func (_m *Middleware) Ping(targetID flow.Identifier) (time.Duration, error)

+ func (_m *Middleware) Publish(msg *message.Message, channelID string) error

+ func (_m *Middleware) Send(channelID string, msg *message.Message, targetIDs ...flow.Identifier) error

+ func (_m *Middleware) SendDirect(msg *message.Message, targetID flow.Identifier) error

+ func (_m *Middleware) Start(overlay network.Overlay) error

+ func (_m *Middleware) Stop()

+ func (_m *Middleware) Subscribe(channelID string) error

+ func (_m *Middleware) Unsubscribe(channelID string) error

+ func (_m *Middleware) UpdateAllowList() error

+ type Overlay struct

+ func (_m *Overlay) Identity() (map[flow.Identifier]flow.Identity, error)

+ func (_m *Overlay) Receive(nodeID flow.Identifier, msg *message.Message) error

+ func (_m *Overlay) Topology() (flow.IdentityList, error)

+ type SubscriptionManager struct

+ func (_m *SubscriptionManager) GetChannelIDs() []string

+ func (_m *SubscriptionManager) GetEngine(channelID string) (network.Engine, error)

+ func (_m *SubscriptionManager) Register(channelID string, engine network.Engine) error

+ func (_m *SubscriptionManager) Unregister(channelID string) error

+ type Topology struct

+ func (_m *Topology) GenerateFanout(ids flow.IdentityList) (flow.IdentityList, error)