mesh

package

Versions in this module

v1

v1.4.6

Mar 23, 2016 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

Changes in this version

type TargetState

+ const TargetSuspended

v1.4.5

Feb 29, 2016 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

v1.4.4

Feb 9, 2016 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

v1.4.3

Feb 2, 2016 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

v1.4.2

Jan 14, 2016 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

v1.4.1

Dec 22, 2015 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

v1.4.0

Dec 17, 2015 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

Changes in this version

+ func NewTrustedSubnetsSlice(trustedSubnets []*net.IPNet) []string

type Config

+ TrustedSubnets []*net.IPNet

type LocalConnection

+ TrustRemote bool

+ TrustedByRemote bool

+ func (conn *LocalConnection) Untrusted() bool

type Peer

+ func NewPeerPlaceholder(name PeerName) *Peer

type Router

+ func (router *Router) Trusts(remote *RemoteConnection) bool

type Status

+ TrustedSubnets []string

v1.3.1

Nov 23, 2015 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

v1.3.0

Nov 12, 2015 GO-2022-0794

GO-2022-0794: Weave Net clusters susceptible to MitM attacks via IPv6 rogue router advertisements in github.com/weaveworks/weave

Changes in this version

+ const ChannelSize

+ const GossipInterval

+ const InitialInterval

+ const MaxDuration

+ const MaxInterval

+ const MaxTCPMsgSize

+ const NameSize

+ const PeerNameFlavour

+ const PeerShortIDBits

+ const Port

+ const Protocol

+ const ProtocolGossip

+ const ProtocolGossipBroadcast

+ const ProtocolGossipUnicast

+ const ProtocolHeartbeat

+ const ProtocolMaxVersion

+ const ProtocolMinVersion

+ const ProtocolOverlayControlMsg

+ const ProtocolReserved1

+ const ProtocolReserved2

+ const ProtocolReserved3

+ const ResetAfter

+ const TCPHeartbeat

+ const UnknownPeerName

+ var ErrConnectToSelf = fmt.Errorf("Cannot connect to ourself")

+ var ErrExpectedCrypto = fmt.Errorf("Password specified, but peer requested an unencrypted connection")

+ var ErrExpectedNoCrypto = fmt.Errorf("No password specificed, but peer requested an encrypted connection")

+ var HeaderTimeout = 10 * time.Second

+ var ProtocolBytes = []byte(Protocol)

+ var ProtocolV1Features = []string

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

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

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

+ func NewTargetSlice(cm *ConnectionMaker) []string

+ func StartLocalConnection(connRemote *RemoteConnection, tcpConn *net.TCPConn, router *Router, ...)

+ type BroadcastRouteStatus struct

+ Source string

+ Via []string

+ func NewBroadcastRouteStatusSlice(routes *Routes) []BroadcastRouteStatus

+ type Config struct

+ ConnLimit int

+ Password []byte

+ PeerDiscovery bool

+ Port int

+ ProtocolMinVersion byte

+ type Connection interface

+ BreakTie func(Connection) ConnectionTieBreak

+ Established func() bool

+ Local func() *Peer

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

+ Outbound func() bool

+ Remote func() *Peer

+ RemoteTCPAddr func() string

+ Shutdown func(error)

+ type ConnectionAction func() error

+ type ConnectionMaker struct

+ func NewConnectionMaker(ourself *LocalPeer, peers *Peers, port int, discovery bool) *ConnectionMaker

+ func (cm *ConnectionMaker) ConnectionAborted(address string, err error)

+ func (cm *ConnectionMaker) ConnectionCreated(conn Connection)

+ func (cm *ConnectionMaker) ConnectionTerminated(conn Connection, err error)

+ func (cm *ConnectionMaker) ForgetConnections(peers []string)

+ func (cm *ConnectionMaker) InitiateConnections(peers []string, replace bool) []error

+ func (cm *ConnectionMaker) Refresh()

+ type ConnectionMakerAction func() bool

+ type ConnectionSet map[Connection]struct

+ type ConnectionStatus struct

+ Address string

+ Established bool

+ Name string

+ NickName string

+ Outbound bool

+ type ConnectionSummary struct

+ Established bool

+ NameByte []byte

+ Outbound bool

+ RemoteTCPAddr string

+ type ConnectionTieBreak int

+ const TieBreakLost

+ const TieBreakTied

+ const TieBreakWon

+ type EncryptedTCPReceiver struct

+ func NewEncryptedTCPReceiver(receiver TCPReceiver, sessionKey *[32]byte, outbound bool) *EncryptedTCPReceiver

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

+ type EncryptedTCPSender struct

+ func NewEncryptedTCPSender(sender TCPSender, sessionKey *[32]byte, outbound bool) *EncryptedTCPSender

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

+ type GobTCPReceiver struct

+ func NewGobTCPReceiver(decoder *gob.Decoder) *GobTCPReceiver

+ func (receiver *GobTCPReceiver) Receive() ([]byte, error)

+ type GobTCPSender struct

+ func NewGobTCPSender(encoder *gob.Encoder) *GobTCPSender

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

+ type Gossip interface

+ GossipBroadcast func(update GossipData) error

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

+ type GossipChannel struct

+ func NewGossipChannel(channelName string, ourself *LocalPeer, routes *Routes, g Gossiper) *GossipChannel

+ func (c *GossipChannel) GossipBroadcast(update GossipData) error

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

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

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

+ type GossipChannels map[string]*GossipChannel

+ 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) Stop()

+ type Gossiper interface

+ Gossip func() GossipData

+ OnGossip func(update []byte) (GossipData, error)

+ OnGossipBroadcast func(sender PeerName, update []byte) (GossipData, error)

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

+ type LengthPrefixTCPReceiver struct

+ func NewLengthPrefixTCPReceiver(reader io.Reader) *LengthPrefixTCPReceiver

+ func (receiver *LengthPrefixTCPReceiver) Receive() ([]byte, error)

+ type LengthPrefixTCPSender struct

+ func NewLengthPrefixTCPSender(writer io.Writer) *LengthPrefixTCPSender

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

+ type ListOfPeers []*Peer

+ func (lop ListOfPeers) Len() int

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

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

+ type LocalConnection struct

+ OverlayConn OverlayConnection

+ Router *Router

+ SessionKey *[32]byte

+ TCPConn *net.TCPConn

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

+ func (conn *LocalConnection) Established() bool

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

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

+ type LocalConnectionStatus struct

+ Address string

+ Info string

+ Outbound bool

+ State string

+ func NewLocalConnectionStatusSlice(cm *ConnectionMaker) []LocalConnectionStatus

+ type LocalPeer struct

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

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

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

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

+ func (peer *LocalPeer) Connections() ConnectionSet

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

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

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

+ func (peer *LocalPeer) Encode(enc *gob.Encoder)

+ type LocalPeerAction func()

+ type NullOverlay struct

+ func (NullOverlay) AddFeaturesTo(map[string]string)

+ func (NullOverlay) Confirm()

+ func (NullOverlay) ControlMessage(byte, []byte)

+ func (NullOverlay) Diagnostics() interface{}

+ func (NullOverlay) DisplayName() string

+ func (NullOverlay) ErrorChannel() <-chan error

+ func (NullOverlay) EstablishedChannel() <-chan struct{}

+ func (NullOverlay) PrepareConnection(OverlayConnectionParams) (OverlayConnection, error)

+ func (NullOverlay) Stop()

+ type Overlay interface

+ AddFeaturesTo func(map[string]string)

+ Diagnostics func() interface{}

+ PrepareConnection func(OverlayConnectionParams) (OverlayConnection, error)

+ type OverlayConnection interface

+ Confirm func()

+ ControlMessage func(tag byte, msg []byte)

+ DisplayName func() string

+ ErrorChannel func() <-chan error

+ EstablishedChannel func() <-chan struct{}

+ Stop func()

+ type OverlayConnectionParams struct

+ ConnUID uint64

+ Features map[string]string

+ LocalAddr *net.TCPAddr

+ Outbound bool

+ RemoteAddr *net.TCPAddr

+ RemotePeer *Peer

+ SendControlMessage func(tag byte, msg []byte) error

+ SessionKey *[32]byte

+ type Peer struct

+ Name PeerName

+ func NewPeer(name PeerName, nickName string, uid PeerUID, version uint64, ...) *Peer

+ func NewPeerFrom(peer *Peer) *Peer

+ func NewPeerFromSummary(summary PeerSummary) *Peer

+ func (peer *Peer) Encode(enc *gob.Encoder)

+ func (peer *Peer) ForEachConnectedPeer(establishedAndSymmetric bool, exclude map[PeerName]PeerName, f func(*Peer))

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

+ func (peer *Peer) String() string

+ 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 PeerNameSet map[PeerName]struct

+ type PeerShortID uint16

+ type PeerStatus struct

+ Connections []ConnectionStatus

+ Name string

+ NickName string

+ ShortID PeerShortID

+ UID PeerUID

+ Version uint64

+ func NewPeerStatusSlice(peers *Peers) []PeerStatus

+ type PeerSummary struct

+ HasShortID bool

+ NameByte []byte

+ NickName string

+ ShortID PeerShortID

+ UID PeerUID

+ Version uint64

+ type PeerUID uint64

+ func ParsePeerUID(s string) (PeerUID, error)

+ type Peers struct

+ func NewPeers(ourself *LocalPeer) *Peers

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

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

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

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

+ func (peers *Peers) FetchAndAddRef(name PeerName) *Peer

+ func (peers *Peers) FetchByShortID(shortID PeerShortID) *Peer

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

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

+ func (peers *Peers) GarbageCollect()

+ func (peers *Peers) Names() PeerNameSet

+ func (peers *Peers) OnGC(callback func(*Peer))

+ func (peers *Peers) OnInvalidateShortIDs(callback func())

+ type PeersPendingNotifications struct

+ type ProtocolIntroConn interface

+ Read func(b []byte) (n int, err error)

+ SetDeadline func(t time.Time) error

+ SetReadDeadline func(t time.Time) error

+ SetWriteDeadline func(t time.Time) error

+ Write func(b []byte) (n int, err error)

+ type ProtocolIntroParams struct

+ Conn ProtocolIntroConn

+ Features map[string]string

+ MaxVersion byte

+ MinVersion byte

+ Outbound bool

+ Password []byte

+ func (params ProtocolIntroParams) DoIntro() (res ProtocolIntroResults, err error)

+ type ProtocolIntroResults struct

+ Features map[string]string

+ Receiver TCPReceiver

+ Sender TCPSender

+ SessionKey *[32]byte

+ Version byte

+ type ProtocolMsg struct

+ type ProtocolSender interface

+ SendProtocolMsg func(m ProtocolMsg)

+ type ProtocolTag byte

+ type RemoteConnection struct

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

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

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

+ func (conn *RemoteConnection) Established() bool

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

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

+ func (conn *RemoteConnection) Outbound() bool

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

+ func (conn *RemoteConnection) RemoteTCPAddr() string

+ func (conn *RemoteConnection) Shutdown(error)

+ type Router struct

+ ConnectionMaker *ConnectionMaker

+ Ourself *LocalPeer

+ Overlay Overlay

+ Peers *Peers

+ Routes *Routes

+ TopologyGossip Gossip

+ func NewRouter(config Config, name PeerName, nickName string, overlay Overlay) *Router

+ func (router *Router) BroadcastTopologyUpdate(update []*Peer)

+ func (router *Router) Gossip() GossipData

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

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

+ func (router *Router) OnGossipBroadcast(_ PeerName, update []byte) (GossipData, error)

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

+ func (router *Router) SendAllGossip()

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

+ func (router *Router) Start()

+ func (router *Router) Stop() error

+ func (router *Router) UsingPassword() bool

+ type Routes struct

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

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

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

+ func (routes *Routes) EnsureRecalculated()

+ func (routes *Routes) OnChange(callback func())

+ func (routes *Routes) PeerNames() PeerNameSet

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

+ func (routes *Routes) Recalculate()

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

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

+ type ShortIDPeers struct

+ type Status struct

+ BroadcastRoutes []BroadcastRouteStatus

+ Connections []LocalConnectionStatus

+ Encryption bool

+ Name string

+ NickName string

+ OverlayDiagnostics interface{}

+ PeerDiscovery bool

+ Peers []PeerStatus

+ Port int

+ Protocol string

+ ProtocolMaxVersion int

+ ProtocolMinVersion int

+ Targets []string

+ UnicastRoutes []UnicastRouteStatus

+ func NewStatus(router *Router) *Status

+ type SurrogateGossipData struct

+ func NewSurrogateGossipData(msg []byte) *SurrogateGossipData

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

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

+ type SurrogateGossiper struct

+ func (*SurrogateGossiper) Gossip() GossipData

+ func (*SurrogateGossiper) OnGossip(update []byte) (GossipData, error)

+ func (*SurrogateGossiper) OnGossipBroadcast(_ PeerName, update []byte) (GossipData, error)

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

+ type TCPCryptoState struct

+ func NewTCPCryptoState(sessionKey *[32]byte, outbound bool) *TCPCryptoState

+ type TCPReceiver interface

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

+ type TCPSender interface

+ Send func([]byte) error

+ type Target struct

+ type TargetState int

+ const TargetAttempting

+ const TargetConnected

+ const TargetWaiting

+ type TokenBucket struct

+ func NewTokenBucket(capacity int64, tokenInterval time.Duration) *TokenBucket

+ func (tb *TokenBucket) Wait()

+ type TopologyGossipData struct

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

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

+ type UnicastRouteStatus struct

+ Dest string

+ Via string

+ func NewUnicastRouteStatusSlice(routes *Routes) []UnicastRouteStatus

+ type UnknownPeerError struct

+ Name PeerName

+ func (upe UnknownPeerError) Error() string

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