router

package

Go to main page

Versions in this module

v0

v0.10.0

Apr 21, 2015

Changes in this version

+ const HTTPPort

+ const HeartbeatTimeout

+ const MaxMissedHeartbeats

+ const TCPHeartbeat

type Connection

+ Log func(args ...interface{})

+ Outbound func() bool

+ type ConnectionAction func() error

type ConnectionMaker

+ func (cm *ConnectionMaker) ForgetConnection(peer string)

+ type ConnectionMakerAction func() bool

+ type ConnectionSet map[Connection]struct

+ type FieldValidator struct

+ func NewFieldValidator(fields map[string]string) *FieldValidator

+ func (fv *FieldValidator) CheckEqual(fieldName, expectedValue string) error

+ func (fv *FieldValidator) Err() error

+ func (fv *FieldValidator) Value(fieldName string) (string, error)

type Forwarder

+ func (fwd *Forwarder) Forward(frame *ForwardedFrame)

+ func (fwd *Forwarder) Shutdown()

+ type ForwarderDF struct

+ func NewForwarderDF(conn *LocalConnection, enc Encryptor, udpSender UDPSender, pmtu int) *ForwarderDF

+ func (fwd *ForwarderDF) PMTUVerified(pmtu int)

+ func (fwd *ForwarderDF) Start()

type GossipChannel

+ func (c *GossipChannel) Send(srcName PeerName, data GossipData)

+ func (c *GossipChannel) SendDown(conn Connection, data GossipData)

+ type GossipData interface

+ Encode func() []byte

+ Merge func(GossipData)

+ type GossipSender struct

+ func NewGossipSender(send func(GossipData)) *GossipSender

+ func (sender *GossipSender) Send(data GossipData)

+ func (sender *GossipSender) Start()

+ func (sender *GossipSender) Stop()

type LocalPeer

+ func (peer *LocalPeer) ConnectionsTo(names []PeerName) []Connection

+ type LocalPeerAction func()

+ type LogFrameFunc func(string, []byte, *layers.Ethernet)

type MacCache

+ func (cache *MacCache) MarshalJSON() ([]byte, error)

type Peer

+ NickName string

+ func (peer *Peer) Connections() ConnectionSet

+ func (peer *Peer) FullName() string

+ func (peer *Peer) MarshalJSON() ([]byte, error)

type PeerName

+ func (name PeerName) MarshalJSON() ([]byte, error)

+ type PeerNameSet map[PeerName]struct

type Peers

+ func (peers *Peers) EncodePeers(names PeerNameSet) []byte

+ func (peers *Peers) MarshalJSON() ([]byte, error)

+ func (peers *Peers) Names() PeerNameSet

type ProtocolTag

+ const ProtocolHeartbeat

type RemoteConnection

+ func (conn *RemoteConnection) Log(args ...interface{})

+ func (conn *RemoteConnection) MarshalJSON() ([]byte, error)

+ func (conn *RemoteConnection) Outbound() bool

type Router

+ func (router *Router) GenerateStatusJSON(version, encryption string) ([]byte, error)

+ type RouterConfig struct

+ BufSz int

+ ConnLimit int

+ Iface *net.Interface

+ LogFrame LogFrameFunc

+ Password []byte

+ Port int

type Routes

+ func (routes *Routes) BroadcastAll(name PeerName) []PeerName

+ func (routes *Routes) EnsureRecalculated()

+ func (routes *Routes) MarshalJSON() ([]byte, error)

+ func (routes *Routes) PeerNames() PeerNameSet

+ func (routes *Routes) RandomNeighbours(except PeerName) PeerNameSet

+ func (routes *Routes) UnicastAll(name PeerName) (PeerName, bool)

+ type TopologyGossipData struct

+ func NewTopologyGossipData(peers *Peers, update ...*Peer) *TopologyGossipData

+ func (d *TopologyGossipData) Encode() []byte

+ func (d *TopologyGossipData) Merge(other GossipData)

v0.9.0

Feb 3, 2015

Changes in this version

+ const CReceivedHeartbeat

+ const CSendProtocolMsg

+ const EstablishedTimeout

+ const GossipInterval

+ const PSendProtocolMsg

+ func GobEncode(items ...interface{}) []byte

type Connection

+ BreakTie func(Connection) ConnectionTieBreak

type ConnectionMaker

+ func NewConnectionMaker(ourself *LocalPeer, peers *Peers) *ConnectionMaker

+ func (cm *ConnectionMaker) Start()

+ type ConnectionTieBreak int

+ const TieBreakLost

+ const TieBreakTied

+ const TieBreakWon

type EthernetDecoder

+ func (dec *EthernetDecoder) IsSpecial() bool

type Forwarder

+ func (fwd *Forwarder) Start()

+ type Gossip interface

+ GossipBroadcast func(buf []byte) error

+ GossipUnicast func(dstPeerName PeerName, buf []byte) error

+ type GossipChannel struct

+ func (c *GossipChannel) GossipBroadcast(buf []byte) error

+ func (c *GossipChannel) GossipUnicast(dstPeerName PeerName, buf []byte) error

+ func (c *GossipChannel) SendGossipMsg(buf []byte)

+ type Gossiper interface

+ Gossip func() []byte

+ OnGossip func(buf []byte) ([]byte, error)

+ OnGossipBroadcast func(msg []byte) error

+ OnGossipUnicast func(sender PeerName, msg []byte) error

type LocalConnection

+ func (conn *LocalConnection) BreakTie(dupConn Connection) ConnectionTieBreak

+ func (conn *LocalConnection) ReceivedHeartbeat(remoteUDPAddr *net.UDPAddr, connUID uint64)

+ func (conn *LocalConnection) SendProtocolMsg(m ProtocolMsg)

+ func (conn *LocalConnection) Start(acceptNewPeer bool)

type LocalPeer

+ func NewLocalPeer(name PeerName, router *Router) *LocalPeer

+ func (peer *LocalPeer) NextBroadcastHops(srcPeer *Peer) []*LocalConnection

+ func (peer *LocalPeer) SendProtocolMsg(m ProtocolMsg)

+ func (peer *LocalPeer) Start()

type MacCache

+ func (cache *MacCache) Start()

+ type ProtocolMsg struct

+ type ProtocolSender interface

+ SendProtocolMsg func(m ProtocolMsg)

+ type ProtocolTag byte

+ const ProtocolGossip

+ const ProtocolGossipBroadcast

+ const ProtocolGossipUnicast

type RemoteConnection

+ func (conn *RemoteConnection) BreakTie(Connection) ConnectionTieBreak

type Router

+ GossipChannels map[uint32]*GossipChannel

+ TopologyGossip Gossip

+ func (router *Router) Gossip() []byte

+ func (router *Router) NewGossip(channelName string, g Gossiper) Gossip

+ func (router *Router) OnGossip(buf []byte) ([]byte, error)

+ func (router *Router) OnGossipBroadcast(msg []byte) error

+ func (router *Router) OnGossipUnicast(sender PeerName, msg []byte) error

+ func (router *Router) SendAllGossip()

+ func (router *Router) SendAllGossipDown(conn Connection)

type Routes

+ func NewRoutes(ourself *Peer, peers *Peers) *Routes

+ func (routes *Routes) Start()

+ type UnknownPeerError struct

+ Name PeerName

+ func (upe UnknownPeerError) Error() string

v0.8.0

Jan 4, 2015

v0.7.0

Dec 30, 2014

Changes in this version

+ const CMInitiate

+ const CMRefresh

+ const CMStatus

+ const CMTerminated

+ const CSendTCP

+ const CSetEstablished

+ const CSetRemoteUDPAddr

+ const CShutdown

+ const ChannelSize

+ const DefaultPMTU

+ const EthernetOverhead

+ const FastHeartbeat

+ const FetchAllInterval

+ const FragTestInterval

+ const FragTestSize

+ const HttpPort

+ const InitialInterval

+ const MaxDuration

+ const MaxInterval

+ const MaxUDPPacketSize

+ const NameSize

+ const PAddConnection

+ const PBroadcastTCP

+ const PConnectionEstablished

+ const PDeleteConnection

+ const PMTUDiscoverySize

+ const PMTUVerifyAttempts

+ const PMTUVerifyTimeout

+ const PeerNameFlavour

+ const Port

+ const Protocol

+ const ProtocolConnectionEstablished

+ const ProtocolFetchAll

+ const ProtocolFragmentationReceived

+ const ProtocolNonce

+ const ProtocolPMTUVerified

+ const ProtocolStartFragmentationTest

+ const ProtocolUpdate

+ const ProtocolVersion

+ const RRecalculate

+ const ReadTimeout

+ const SlowHeartbeat

+ const UDPNonceSendAt

+ const UDPOverhead

+ const UnknownPeerName

+ var FragTest = make([]byte, FragTestSize)

+ var PMTUDiscovery = make([]byte, PMTUDiscoverySize)

+ var ProtocolConnectionEstablishedByte = []byte

+ var ProtocolFetchAllByte = []byte

+ var ProtocolFragmentationReceivedByte = []byte

+ var ProtocolNonceByte = []byte

+ var ProtocolPMTUVerifiedByte = []byte

+ var ProtocolStartFragmentationTestByte = []byte

+ var ProtocolUpdateByte = []byte

+ func Concat(elems ...[]byte) []byte

+ func DecodeNonce(msg []byte) (bool, *[24]byte)

+ func DecryptPrefixNonce(ciphertxt []byte, secret *[32]byte) ([]byte, bool)

+ func EncodeNonce(df bool) (*[24]byte, []byte, error)

+ func EncodePeers(peers ...*Peer) []byte

+ func EncryptPrefixNonce(plaintxt []byte, nonce *[24]byte, secret *[32]byte) []byte

+ func FormSessionKey(remotePublicKey, localPrivateKey *[32]byte, secretKey *[]byte) *[32]byte

+ func GenerateKeyPair() (publicKey, privateKey *[32]byte, err error)

+ func GenerateRandomNonce() ([24]byte, error)

+ func NewLocalConnection(connRemote *RemoteConnection, acceptNewPeer bool, tcpConn *net.TCPConn, ...)

+ func NormalisePeerAddr(peerAddr string) string

+ func PosixError(err error) error

+ func SetNonceLow15Bits(nonce *[24]byte, offset uint16)

+ type Connection interface

+ Established func() bool

+ Local func() *Peer

+ Remote func() *Peer

+ RemoteTCPAddr func() string

+ Shutdown func()

+ type ConnectionInteraction struct

+ type ConnectionMaker struct

+ func StartConnectionMaker(ourself *LocalPeer, peers *Peers) *ConnectionMaker

+ func (cm *ConnectionMaker) ConnectionTerminated(address string)

+ func (cm *ConnectionMaker) InitiateConnection(address string)

+ func (cm *ConnectionMaker) Refresh()

+ func (cm *ConnectionMaker) String() string

+ type ConnectionMakerInteraction struct

+ type Decryptor interface

+ IterateFrames func(FrameConsumer, *UDPPacket) error

+ ReceiveNonce func([]byte)

+ Shutdown func()

+ type EncryptedTCPMessage struct

+ Body []byte

+ Number int

+ type EncryptedTCPReceiver struct

+ func NewEncryptedTCPReceiver(conn *LocalConnection) *EncryptedTCPReceiver

+ func (receiver *EncryptedTCPReceiver) Decode(msg []byte) ([]byte, error)

+ type EncryptedTCPSender struct

+ func NewEncryptedTCPSender(encoder *gob.Encoder, conn *LocalConnection) *EncryptedTCPSender

+ func (sender *EncryptedTCPSender) Send(msg []byte) error

+ type Encryptor interface

+ AppendFrame func(*ForwardedFrame)

+ Bytes func() []byte

+ FrameOverhead func() int

+ IsEmpty func() bool

+ PacketOverhead func() int

+ TotalLen func() int

+ type EthernetDecoder struct

+ func NewEthernetDecoder() *EthernetDecoder

+ func (dec *EthernetDecoder) CheckFrameTooBig(err error, sendFrame func([]byte) error) error

+ func (dec *EthernetDecoder) DecodeLayers(data []byte) error

+ func (dec *EthernetDecoder) DropFrame() bool

+ func (dec *EthernetDecoder) IsPMTUVerify() bool

+ type ForwardedFrame struct

+ type Forwarder struct

+ func NewForwarder(conn *LocalConnection, ch <-chan *ForwardedFrame, stop <-chan interface{}, ...) *Forwarder

+ func (fwd *Forwarder) Run()

+ type FrameConsumer func(*LocalConnection, *net.UDPAddr, []byte, []byte, uint16, []byte) error

+ type FrameTooBigError struct

+ EPMTU int

+ func (ftbe FrameTooBigError) Error() string

+ type Interaction struct

+ type ListOfPeers []*Peer

+ func (lop ListOfPeers) Len() int

+ func (lop ListOfPeers) Less(i, j int) bool

+ func (lop ListOfPeers) Swap(i, j int)

+ type LocalAddress struct

+ type LocalConnection struct

+ Decryptor Decryptor

+ Router *Router

+ SessionKey *[32]byte

+ TCPConn *net.TCPConn

+ UID uint64

+ func (conn *LocalConnection) CheckFatal(err error) error

+ func (conn *LocalConnection) Established() bool

+ func (conn *LocalConnection) Forward(df bool, frame *ForwardedFrame, dec *EthernetDecoder) error

+ func (conn *LocalConnection) RemoteUDPAddr() *net.UDPAddr

+ func (conn *LocalConnection) SendTCP(msg []byte)

+ func (conn *LocalConnection) SetEstablished()

+ func (conn *LocalConnection) SetRemoteUDPAddr(remoteUDPAddr *net.UDPAddr)

+ func (conn *LocalConnection) Shutdown()

+ type LocalPeer struct

+ Router *Router

+ func StartLocalPeer(name PeerName, router *Router) *LocalPeer

+ func (peer *LocalPeer) AddConnection(conn *LocalConnection)

+ func (peer *LocalPeer) Broadcast(df bool, frame []byte, dec *EthernetDecoder) error

+ func (peer *LocalPeer) BroadcastTCP(msg []byte)

+ func (peer *LocalPeer) ConnectionEstablished(conn *LocalConnection)

+ func (peer *LocalPeer) CreateConnection(peerAddr string, acceptNewPeer bool) error

+ func (peer *LocalPeer) DeleteConnection(conn *LocalConnection)

+ func (peer *LocalPeer) Forward(dstPeer *Peer, df bool, frame []byte, dec *EthernetDecoder) error

+ func (peer *LocalPeer) Relay(srcPeer, dstPeer *Peer, df bool, frame []byte, dec *EthernetDecoder) error

+ func (peer *LocalPeer) RelayBroadcast(srcPeer *Peer, df bool, frame []byte, dec *EthernetDecoder) error

+ type MacCache struct

+ func NewMacCache(maxAge time.Duration, onExpiry func(net.HardwareAddr, *Peer)) *MacCache

+ func (cache *MacCache) Delete(peer *Peer) bool

+ func (cache *MacCache) Enter(mac net.HardwareAddr, peer *Peer) bool

+ func (cache *MacCache) Lookup(mac net.HardwareAddr) (*Peer, bool)

+ func (cache *MacCache) String() string

+ type MacCacheEntry struct

+ type MsgTooBigError struct

+ PMTU int

+ func (mtbe MsgTooBigError) Error() string

+ type NaClDecryptor struct

+ func NewNaClDecryptor(conn *LocalConnection) *NaClDecryptor

+ func (nd *NaClDecryptor) IterateFrames(fun FrameConsumer, packet *UDPPacket) error

+ func (nd *NaClDecryptor) ReceiveNonce(msg []byte)

+ func (nd *NaClDecryptor) Shutdown()

+ type NaClDecryptorInstance struct

+ type NaClEncryptor struct

+ func NewNaClEncryptor(prefix []byte, conn *LocalConnection, df bool) *NaClEncryptor

+ func (ne *NaClEncryptor) Bytes() []byte

+ func (ne *NaClEncryptor) PacketOverhead() int

+ func (ne *NaClEncryptor) TotalLen() int

+ type NameCollisionError struct

+ Name PeerName

+ func (nce NameCollisionError) Error() string

+ type NonDecryptor struct

+ func NewNonDecryptor(conn *LocalConnection) *NonDecryptor

+ func (nd *NonDecryptor) IterateFrames(fun FrameConsumer, packet *UDPPacket) error

+ func (nd *NonDecryptor) ReceiveNonce(msg []byte)

+ func (nd *NonDecryptor) Shutdown()

+ type NonEncryptor struct

+ func NewNonEncryptor(prefix []byte) *NonEncryptor

+ func (ne *NonEncryptor) AppendFrame(frame *ForwardedFrame)

+ func (ne *NonEncryptor) Bytes() []byte

+ func (ne *NonEncryptor) FrameOverhead() int

+ func (ne *NonEncryptor) IsEmpty() bool

+ func (ne *NonEncryptor) PacketOverhead() int

+ func (ne *NonEncryptor) TotalLen() int

+ type PacketDecodingError struct

+ Desc string

+ Fatal bool

+ func (pde PacketDecodingError) Error() string

+ type PacketSink interface

+ WritePacket func([]byte) error

+ func NewPcapO(ifName string) (po PacketSink, err error)

+ type PacketSource interface

+ ReadPacket func() ([]byte, error)

+ type PacketSourceSink interface

+ func NewPcapIO(ifName string, bufSz int) (PacketSourceSink, error)

+ type PcapIO struct

+ func (pi *PcapIO) ReadPacket() (data []byte, err error)

+ func (po *PcapIO) WritePacket(data []byte) error

+ type Peer struct

+ Name PeerName

+ NameByte []byte

+ UID uint64

+ func NewPeer(name PeerName, uid uint64, version uint64) *Peer

+ func (peer *Peer) ConnectionCount() int

+ func (peer *Peer) ConnectionTo(name PeerName) (Connection, bool)

+ func (peer *Peer) DecrementLocalRefCount()

+ func (peer *Peer) ForEachConnection(fun func(PeerName, Connection))

+ func (peer *Peer) IncrementLocalRefCount()

+ func (peer *Peer) IsLocallyReferenced() bool

+ func (peer *Peer) Routes(stopAt *Peer, symmetric bool) (bool, map[PeerName]PeerName)

+ func (peer *Peer) SetVersionAndConnections(version uint64, connections map[PeerName]Connection)

+ func (peer *Peer) String() string

+ func (peer *Peer) Version() uint64

+ type PeerInteraction struct

+ type PeerName uint64

+ func PeerNameFromBin(nameByte []byte) PeerName

+ func PeerNameFromString(nameStr string) (PeerName, error)

+ func PeerNameFromUserInput(userInput string) (PeerName, error)

+ func (name PeerName) Bin() []byte

+ func (name PeerName) String() string

+ type Peers struct

+ func NewPeers(ourself *Peer, macs *MacCache, onGC func(*Peer)) *Peers

+ func (peers *Peers) ApplyUpdate(update []byte) ([]byte, error)

+ func (peers *Peers) EncodeAllPeers() []byte

+ func (peers *Peers) Fetch(name PeerName) (*Peer, bool)

+ func (peers *Peers) FetchWithDefault(peer *Peer) *Peer

+ func (peers *Peers) ForEach(fun func(PeerName, *Peer))

+ func (peers *Peers) GarbageCollect() []*Peer

+ func (peers *Peers) String() string

+ type RawUDPSender struct

+ func NewRawUDPSender(conn *LocalConnection) (*RawUDPSender, error)

+ func (sender *RawUDPSender) Send(msg []byte) error

+ func (sender *RawUDPSender) Shutdown() error

+ type RemoteConnection struct

+ func NewRemoteConnection(from, to *Peer, tcpAddr string) *RemoteConnection

+ func (conn *RemoteConnection) Established() bool

+ func (conn *RemoteConnection) Local() *Peer

+ func (conn *RemoteConnection) Remote() *Peer

+ func (conn *RemoteConnection) RemoteTCPAddr() string

+ func (conn *RemoteConnection) Shutdown()

+ func (conn *RemoteConnection) String() string

+ type Router struct

+ BufSz int

+ ConnLimit int

+ ConnectionMaker *ConnectionMaker

+ Iface *net.Interface

+ LogFrame func(string, []byte, *layers.Ethernet)

+ Macs *MacCache

+ Ourself *LocalPeer

+ Password *[]byte

+ Peers *Peers

+ Routes *Routes

+ UDPListener *net.UDPConn

+ func NewRouter(iface *net.Interface, name PeerName, password []byte, connLimit int, bufSz int, ...) *Router

+ func (router *Router) Start()

+ func (router *Router) Status() string

+ func (router *Router) UsingPassword() bool

+ type Routes struct

+ func StartRoutes(ourself *Peer, peers *Peers) *Routes

+ func (routes *Routes) Broadcast(name PeerName) []PeerName

+ func (routes *Routes) Recalculate()

+ func (routes *Routes) String() string

+ func (routes *Routes) Unicast(name PeerName) (PeerName, bool)

+ type SimpleTCPReceiver struct

+ func NewSimpleTCPReceiver() *SimpleTCPReceiver

+ func (receiver *SimpleTCPReceiver) Decode(msg []byte) ([]byte, error)

+ type SimpleTCPSender struct

+ func NewSimpleTCPSender(encoder *gob.Encoder) *SimpleTCPSender

+ func (sender *SimpleTCPSender) Send(msg []byte) error

+ type SimpleUDPSender struct

+ func NewSimpleUDPSender(conn *LocalConnection) *SimpleUDPSender

+ func (sender *SimpleUDPSender) Send(msg []byte) error

+ func (sender *SimpleUDPSender) Shutdown() error

+ type TCPReceiver interface

+ Decode func([]byte) ([]byte, error)

+ type TCPSender interface

+ Send func([]byte) error

+ type Target struct

+ type UDPPacket struct

+ Name PeerName

+ Packet []byte

+ Sender *net.UDPAddr

+ func (packet UDPPacket) String() string

+ type UDPSender interface

+ Send func([]byte) error

+ Shutdown func() error

+ type UnknownPeersError struct

+ func (upe UnknownPeersError) Error() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL