mocks

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)

Types

type GossipMock

type GossipMock struct {
	mock.Mock
}

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)