routing

Documentation

Index

• type Table
  • func (t *Table) AddToKnownHosts(h *host.Host)
  • func (t *Table) GetRandomNodes(count int) []host.Host
  • func (t *Table) Inject(nodeKeeper network.NodeKeeper)
  • func (t *Table) Rebalance(network.PartitionPolicy)
  • func (t *Table) Resolve(ref core.RecordRef) (*host.Host, error)
  • func (t *Table) ResolveConsensus(id core.ShortNodeID) (*host.Host, error)
  • func (t *Table) ResolveConsensusRef(ref core.RecordRef) (*host.Host, error)

Types

type Table

type Table struct {
	NodeKeeper network.NodeKeeper
}

func (*Table) AddToKnownHosts

func (t *Table) AddToKnownHosts(h *host.Host)

AddToKnownHosts add host to routing table.

func (*Table) GetRandomNodes

func (t *Table) GetRandomNodes(count int) []host.Host

GetRandomNodes get a specified number of random nodes. Returns less if there are not enough nodes in network.

func (*Table) Inject

func (t *Table) Inject(nodeKeeper network.NodeKeeper)

func (*Table) Rebalance

func (t *Table) Rebalance(network.PartitionPolicy)

Rebalance recreate shards of routing table with known hosts according to new partition policy.

func (*Table) Resolve

func (t *Table) Resolve(ref core.RecordRef) (*host.Host, error)

Resolve NodeID -> ShortID, Address. Can initiate network requests.

func (*Table) ResolveConsensus

func (t *Table) ResolveConsensus(id core.ShortNodeID) (*host.Host, error)

func (*Table) ResolveConsensusRef

func (t *Table) ResolveConsensusRef(ref core.RecordRef) (*host.Host, error)