gossip

Documentation

Index

• type TestRouter
  • func NewTestRouter(loss float32) *TestRouter
  • func (grouter *TestRouter) Connect(sender mesh.PeerName, gossiper mesh.Gossiper) mesh.Gossip
  • func (grouter *TestRouter) Flush()
  • func (grouter *TestRouter) RemovePeer(peer mesh.PeerName)
  • func (grouter *TestRouter) Stop()
• type TestRouterClient
  • func (client TestRouterClient) GossipBroadcast(update mesh.GossipData) error
  • func (client TestRouterClient) GossipUnicast(dstPeerName mesh.PeerName, buf []byte) error

Types

type TestRouter

type TestRouter struct {
	// contains filtered or unexported fields
}

func NewTestRouter

func NewTestRouter(loss float32) *TestRouter

func (*TestRouter) Connect

func (grouter *TestRouter) Connect(sender mesh.PeerName, gossiper mesh.Gossiper) mesh.Gossip

func (*TestRouter) Flush

func (grouter *TestRouter) Flush()

func (*TestRouter) RemovePeer

func (grouter *TestRouter) RemovePeer(peer mesh.PeerName)

func (*TestRouter) Stop

func (grouter *TestRouter) Stop()

type TestRouterClient

type TestRouterClient struct {
	// contains filtered or unexported fields
}

func (TestRouterClient) GossipBroadcast

func (client TestRouterClient) GossipBroadcast(update mesh.GossipData) error

func (TestRouterClient) GossipUnicast

func (client TestRouterClient) GossipUnicast(dstPeerName mesh.PeerName, buf []byte) error