topology

Documentation

Index

• Variables
• type Topology
  • func (t *Topology) AddLink(link network.ILink)
  • func (t *Topology) BuildNodeID(_ network.Node) string
  • func (t *Topology) GetAllNodes() (all []network.LinkNode)
  • func (t *Topology) GetLink(node network.Node) (link network.ILink, err error)
  • func (t *Topology) GetLocalNode() (node network.LinkNode)
  • func (t *Topology) InterestedMessage(msg network.Message) (interested bool)
  • func (t *Topology) Join(node network.LinkNode) (err error)
  • func (t *Topology) Leave()
  • func (t *Topology) MessageProcessor(msg network.Message, link network.ILink)
  • func (t *Topology) MountTo(router network.IRouter)
  • func (t Topology) Name() string
  • func (t *Topology) RemoveLink(link network.ILink)
  • func (t *Topology) SetLocalNode(node network.LinkNode)

Variables

var GetNeighborsMessageProcessor = &getNeighborsMessageProcessor{}

var GetNeighborsReplyMessageProcessor = &getNeighborsReplyMessageProcessor{}

var JoinMessageProcessor = &joinMessageProcessor{}

var JoinReplyMessageProcessor = &joinReplyMessageProcessor{}

var PingMessageProcessor = &pingMessageProcessor{}

var PongMessageProcessor = &pongMessageProcessor{}

Types

type Topology

type Topology struct {
	LocalNode network.LinkNode
	// contains filtered or unexported fields
}

func (*Topology) AddLink

func (t *Topology) AddLink(link network.ILink)

func (*Topology) BuildNodeID

func (t *Topology) BuildNodeID(_ network.Node) string

func (*Topology) GetAllNodes

func (t *Topology) GetAllNodes() (all []network.LinkNode)

func (*Topology) GetLink

func (t *Topology) GetLink(node network.Node) (link network.ILink, err error)

func (*Topology) GetLocalNode

func (t *Topology) GetLocalNode() (node network.LinkNode)

func (*Topology) InterestedMessage

func (t *Topology) InterestedMessage(msg network.Message) (interested bool)

func (*Topology) Join

func (t *Topology) Join(node network.LinkNode) (err error)

func (*Topology) Leave

func (t *Topology) Leave()

func (*Topology) MessageProcessor

func (t *Topology) MessageProcessor(msg network.Message, link network.ILink)

func (*Topology) MountTo

func (t *Topology) MountTo(router network.IRouter)

func (Topology) Name

func (t Topology) Name() string

func (*Topology) RemoveLink

func (t *Topology) RemoveLink(link network.ILink)

func (*Topology) SetLocalNode

func (t *Topology) SetLocalNode(node network.LinkNode)