Documentation ¶
Index ¶
- type GossipMock
- func (g *GossipMock) Accept(acceptor common.MessageAcceptor, passThrough bool) (<-chan *proto.GossipMessage, <-chan proto.ReceivedMessage)
- func (g *GossipMock) Gossip(msg *proto.GossipMessage)
- func (g *GossipMock) JoinChan(joinMsg api.JoinChannelMessage, chainID common.ChainID)
- func (g *GossipMock) LeaveChan(_ common.ChainID)
- func (*GossipMock) PeerFilter(channel common.ChainID, messagePredicate api.SubChannelSelectionCriteria) (filter.RoutingFilter, error)
- func (g *GossipMock) Peers() []discovery.NetworkMember
- func (g *GossipMock) PeersOfChannel(chainID common.ChainID) []discovery.NetworkMember
- func (g *GossipMock) Send(msg *proto.GossipMessage, peers ...*comm.RemotePeer)
- func (g *GossipMock) SendByCriteria(*proto.SignedGossipMessage, gossip.SendCriteria) error
- func (g *GossipMock) Stop()
- func (g *GossipMock) SuspectPeers(s api.PeerSuspector)
- func (g *GossipMock) UpdateChannelMetadata(metadata []byte, chainID common.ChainID)
- func (g *GossipMock) UpdateMetadata(metadata []byte)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GossipMock ¶
func (*GossipMock) Accept ¶
func (g *GossipMock) Accept(acceptor common.MessageAcceptor, passThrough bool) (<-chan *proto.GossipMessage, <-chan proto.ReceivedMessage)
func (*GossipMock) Gossip ¶
func (g *GossipMock) Gossip(msg *proto.GossipMessage)
func (*GossipMock) JoinChan ¶
func (g *GossipMock) JoinChan(joinMsg api.JoinChannelMessage, chainID common.ChainID)
func (*GossipMock) LeaveChan ¶
func (g *GossipMock) LeaveChan(_ common.ChainID)
func (*GossipMock) PeerFilter ¶
func (*GossipMock) PeerFilter(channel common.ChainID, messagePredicate api.SubChannelSelectionCriteria) (filter.RoutingFilter, error)
func (*GossipMock) Peers ¶
func (g *GossipMock) Peers() []discovery.NetworkMember
func (*GossipMock) PeersOfChannel ¶
func (g *GossipMock) PeersOfChannel(chainID common.ChainID) []discovery.NetworkMember
func (*GossipMock) Send ¶
func (g *GossipMock) Send(msg *proto.GossipMessage, peers ...*comm.RemotePeer)
func (*GossipMock) SendByCriteria ¶
func (g *GossipMock) SendByCriteria(*proto.SignedGossipMessage, gossip.SendCriteria) error
func (*GossipMock) Stop ¶
func (g *GossipMock) Stop()
func (*GossipMock) SuspectPeers ¶
func (g *GossipMock) SuspectPeers(s api.PeerSuspector)
func (*GossipMock) UpdateChannelMetadata ¶
func (g *GossipMock) UpdateChannelMetadata(metadata []byte, chainID common.ChainID)
func (*GossipMock) UpdateMetadata ¶
func (g *GossipMock) UpdateMetadata(metadata []byte)
Click to show internal directories.
Click to hide internal directories.