Back to godoc.org

Package router

v0.0.0-...-9f00f78
Latest Go to latest

The latest major version is .

Published: Feb 26, 2020 | License: Apache-2.0 | Module: bitbucket.org/blackxcloudeng/infra

Index

Constants

const (
	FastDatapathHeartbeatAck = iota
	FastDatapathCryptoInitSARemote
)
const (
	ChannelSize         = 16
	MaxUDPPacketSize    = 65535
	FastHeartbeat       = 500 * time.Millisecond
	SlowHeartbeat       = 10 * time.Second
	MaxMissedHeartbeats = 6
	HeartbeatTimeout    = MaxMissedHeartbeats * SlowHeartbeat
	MaxDuration         = time.Duration(math.MaxInt64)
	NameSize            = mesh.NameSize
)
const (
	EthernetOverhead  = 14
	UDPOverhead       = 28 // 20 bytes for IPv4, 8 bytes for UDP
	DefaultMTU        = 65535
	FragTestSize      = 60001
	PMTUDiscoverySize = 60000
	FragTestInterval  = 5 * time.Minute
	MTUVerifyAttempts = 8
	MTUVerifyTimeout  = 10 * time.Millisecond // doubled with each attempt

	ProtocolConnectionEstablished = mesh.ProtocolReserved1
	ProtocolFragmentationReceived = mesh.ProtocolReserved2
	ProtocolPMTUVerified          = mesh.ProtocolReserved3
)
const (
	WindowSize = 20 // bits
)

func PosixError

func PosixError(err error) error

Look inside an error produced by the net package to get to the syscall.Errno at the root of the problem.

type AWSVPC

type AWSVPC struct{}

func NewAWSVPC

func NewAWSVPC() AWSVPC

func (AWSVPC) AddFeaturesTo

func (vpc AWSVPC) AddFeaturesTo(features map[string]string)

func (AWSVPC) Diagnostics

func (vpc AWSVPC) Diagnostics() interface{}

func (AWSVPC) InvalidateRoutes

func (vpc AWSVPC) InvalidateRoutes()

func (AWSVPC) InvalidateShortIDs

func (vpc AWSVPC) InvalidateShortIDs()

func (AWSVPC) PrepareConnection

func (vpc AWSVPC) PrepareConnection(params mesh.OverlayConnectionParams) (mesh.OverlayConnection, error)

func (AWSVPC) StartConsumingPackets

func (vpc AWSVPC) StartConsumingPackets(localPeer *mesh.Peer, peers *mesh.Peers, consumer OverlayConsumer) error

func (AWSVPC) Stop

func (vpc AWSVPC) Stop()

type AWSVPCConnection

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

func (*AWSVPCConnection) Attrs

func (conn *AWSVPCConnection) Attrs() map[string]interface{}

func (*AWSVPCConnection) Confirm

func (conn *AWSVPCConnection) Confirm()

func (*AWSVPCConnection) ControlMessage

func (conn *AWSVPCConnection) ControlMessage(tag byte, msg []byte)

func (*AWSVPCConnection) ErrorChannel

func (conn *AWSVPCConnection) ErrorChannel() <-chan error

func (*AWSVPCConnection) EstablishedChannel

func (conn *AWSVPCConnection) EstablishedChannel() <-chan struct{}

func (*AWSVPCConnection) Forward

func (conn *AWSVPCConnection) Forward(key ForwardPacketKey) FlowOp

func (*AWSVPCConnection) Stop

func (conn *AWSVPCConnection) Stop()

type Consumer

type Consumer func(PacketKey) FlowOp

A function that determines how to handle locally captured packets.

type Decryptor

type Decryptor interface {
	IterateFrames([]byte, FrameConsumer) error
}

type DiscardingFlowOp

type DiscardingFlowOp struct{}

func (DiscardingFlowOp) Discards

func (DiscardingFlowOp) Discards() bool

func (DiscardingFlowOp) Process

func (DiscardingFlowOp) Process([]byte, *EthernetDecoder, bool)

type Encryptor

type Encryptor interface {
	FrameOverhead() int
	PacketOverhead() int
	Bytes() ([]byte, error)
	AppendFrame(src []byte, dst []byte, frame []byte)
	TotalLen() int
}

type EthernetDecoder

type EthernetDecoder struct {
	Eth layers.Ethernet
	IP  layers.IPv4
	// contains filtered or unexported fields
}

func NewEthernetDecoder

func NewEthernetDecoder() *EthernetDecoder

func (*EthernetDecoder) DF

func (dec *EthernetDecoder) DF() bool

func (*EthernetDecoder) DecodeLayers

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

func (*EthernetDecoder) IsSpecial

func (dec *EthernetDecoder) IsSpecial() bool

func (*EthernetDecoder) PacketKey

func (dec *EthernetDecoder) PacketKey() (key PacketKey)

type FastDPMetrics

type FastDPMetrics struct {
	Flows        int
	TotalPackets uint64
	TotalBytes   uint64
}

type FastDPStatus

type FastDPStatus struct {
	Vports []VportStatus
	Flows  []FlowStatus
}

func (FastDPStatus) Metrics

func (s FastDPStatus) Metrics() interface{}

type FastDatapath

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

func NewFastDatapath

func NewFastDatapath(iface *net.Interface, port int, encryptionEnabled bool) (*FastDatapath, error)

func (*FastDatapath) Close

func (fastdp *FastDatapath) Close() error

func (*FastDatapath) Error

func (fastdp *FastDatapath) Error(err error, stopped bool)

func (*FastDatapath) InjectorConsumer

func (fastdp *FastDatapath) InjectorConsumer() InjectorConsumer

func (*FastDatapath) Miss

func (fastdp *FastDatapath) Miss(packet []byte, fks odp.FlowKeys) error

func (*FastDatapath) Overlay

func (fastdp *FastDatapath) Overlay() NetworkOverlay

func (*FastDatapath) VportCreated

func (fastdp *FastDatapath) VportCreated(dpid odp.DatapathID, vport odp.Vport) error

func (*FastDatapath) VportDeleted

func (fastdp *FastDatapath) VportDeleted(dpid odp.DatapathID, vport odp.Vport) error

type FlowOp

type FlowOp interface {
	// The caller must supply an EthernetDecoder specific to this
	// thread, which has already been used to decode the frame.
	// The broadcast parameter is a hint whether the packet is
	// being broadcast.
	Process(frame []byte, dec *EthernetDecoder, broadcast bool)

	// Does the FlowOp discard the packet?
	Discards() bool
}

func FlattenFlowOp

func FlattenFlowOp(fop FlowOp) []FlowOp

Flatten out a FlowOp to eliminate any MultiFlowOps

type FlowStatus

type FlowStatus odp.FlowInfo

func (*FlowStatus) MarshalJSON

func (flowStatus *FlowStatus) MarshalJSON() ([]byte, error)

type ForwardPacketKey

type ForwardPacketKey struct {
	SrcPeer *mesh.Peer
	DstPeer *mesh.Peer
	PacketKey
}

type FrameConsumer

type FrameConsumer func(src []byte, dst []byte, frame []byte)

type InjectorConsumer

type InjectorConsumer interface {
	// Inject a packet to be delivered locally
	InjectPacket(PacketKey) FlowOp

	// Start consuming packets from the bridge.  Injected packets
	// should not be included.
	StartConsumingPackets(Consumer) error

	Interface() *net.Interface
	String() string
	Stats() map[string]int
}

Interface to packet handling on the local virtual bridge

func NewPcap

func NewPcap(iface *net.Interface, bufSz int) (InjectorConsumer, error)

type MAC

type MAC [6]byte

func (MAC) String

func (mac MAC) String() string

type MACStatus

type MACStatus struct {
	Mac      string
	Name     string
	NickName string
	LastSeen time.Time
}

func NewMACStatusSlice

func NewMACStatusSlice(cache *MacCache) []MACStatus

type MacCache

type MacCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMacCache

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

func (*MacCache) Add

func (cache *MacCache) Add(mac net.HardwareAddr, peer *mesh.Peer) (bool, *mesh.Peer)

func (*MacCache) AddForced

func (cache *MacCache) AddForced(mac net.HardwareAddr, peer *mesh.Peer) (bool, *mesh.Peer)

func (*MacCache) Delete

func (cache *MacCache) Delete(peer *mesh.Peer) bool

func (*MacCache) Lookup

func (cache *MacCache) Lookup(mac net.HardwareAddr) *mesh.Peer

type MacCacheEntry

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

type MultiFlowOp

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

func NewMultiFlowOp

func NewMultiFlowOp(broadcast bool, ops ...FlowOp) *MultiFlowOp

func (*MultiFlowOp) Add

func (mfop *MultiFlowOp) Add(op FlowOp)

func (*MultiFlowOp) Discards

func (mfop *MultiFlowOp) Discards() bool

func (*MultiFlowOp) Process

func (mfop *MultiFlowOp) Process(frame []byte, dec *EthernetDecoder, broadcast bool)

type NaClDecryptor

type NaClDecryptor struct {
	NonDecryptor
	// contains filtered or unexported fields
}

func NewNaClDecryptor

func NewNaClDecryptor(sessionKey *[32]byte, outbound bool) *NaClDecryptor

func (*NaClDecryptor) IterateFrames

func (nd *NaClDecryptor) IterateFrames(packet []byte, consumer FrameConsumer) error

type NaClDecryptorInstance

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

func NewNaClDecryptorInstance

func NewNaClDecryptorInstance(outbound bool) *NaClDecryptorInstance

type NaClEncryptor

type NaClEncryptor struct {
	NonEncryptor
	// contains filtered or unexported fields
}

func NewNaClEncryptor

func NewNaClEncryptor(prefix []byte, sessionKey *[32]byte, outbound bool, df bool) *NaClEncryptor

func (*NaClEncryptor) Bytes

func (ne *NaClEncryptor) Bytes() ([]byte, error)

func (*NaClEncryptor) PacketOverhead

func (ne *NaClEncryptor) PacketOverhead() int

func (*NaClEncryptor) TotalLen

func (ne *NaClEncryptor) TotalLen() int

type NetworkConfig

type NetworkConfig struct {
	BufSz            int
	PacketLogging    PacketLogging
	InjectorConsumer InjectorConsumer
}

type NetworkOverlay

type NetworkOverlay interface {
	mesh.Overlay

	// The routes have changed, so any cached information should
	// be discarded.
	InvalidateRoutes()

	// A mapping of a short id to a peer has changed
	InvalidateShortIDs()

	// Start consuming forwarded packets.
	StartConsumingPackets(*mesh.Peer, *mesh.Peers, OverlayConsumer) error
}

Interface to overlay network packet handling

func NewSleeveOverlay

func NewSleeveOverlay(host string, localPort int) NetworkOverlay

type NetworkRouter

type NetworkRouter struct {
	*mesh.Router
	NetworkConfig
	weavenet.BridgeConfig
	Macs *MacCache
	// contains filtered or unexported fields
}

func NewNetworkRouter

func NewNetworkRouter(config mesh.Config, networkConfig NetworkConfig, bridgeConfig weavenet.BridgeConfig, name mesh.PeerName, nickName string, overlay NetworkOverlay, db db.DB) (*NetworkRouter, error)

func (*NetworkRouter) CreateRestartSentinel

func (router *NetworkRouter) CreateRestartSentinel() error

func (*NetworkRouter) ForgetConnections

func (router *NetworkRouter) ForgetConnections(peers []string)

func (*NetworkRouter) HandleHTTP

func (router *NetworkRouter) HandleHTTP(muxRouter *mux.Router)

func (*NetworkRouter) InitialPeers

func (router *NetworkRouter) InitialPeers(resume bool, peers []string) ([]string, error)

func (*NetworkRouter) InitiateConnections

func (router *NetworkRouter) InitiateConnections(peers []string, replace bool) []error

func (*NetworkRouter) Start

func (router *NetworkRouter) Start()

Start listening for TCP connections, locally captured packets, and forwarded packets.

type NetworkRouterStatus

type NetworkRouterStatus struct {
	*mesh.Status
	Interface    string
	CaptureStats map[string]int
	MACs         []MACStatus
}

func NewNetworkRouterStatus

func NewNetworkRouterStatus(router *NetworkRouter) *NetworkRouterStatus

type NonDecryptor

type NonDecryptor struct {
}

func NewNonDecryptor

func NewNonDecryptor() *NonDecryptor

func (*NonDecryptor) IterateFrames

func (nd *NonDecryptor) IterateFrames(packet []byte, consumer FrameConsumer) error

type NonDiscardingFlowOp

type NonDiscardingFlowOp struct{}

func (NonDiscardingFlowOp) Discards

func (NonDiscardingFlowOp) Discards() bool

type NonEncryptor

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

func NewNonEncryptor

func NewNonEncryptor(prefix []byte) *NonEncryptor

func (*NonEncryptor) AppendFrame

func (ne *NonEncryptor) AppendFrame(src []byte, dst []byte, frame []byte)

func (*NonEncryptor) Bytes

func (ne *NonEncryptor) Bytes() ([]byte, error)

func (*NonEncryptor) FrameOverhead

func (ne *NonEncryptor) FrameOverhead() int

func (*NonEncryptor) PacketOverhead

func (ne *NonEncryptor) PacketOverhead() int

func (*NonEncryptor) TotalLen

func (ne *NonEncryptor) TotalLen() int

type NullInjectorConsumer

type NullInjectorConsumer struct{}

func (NullInjectorConsumer) InjectPacket

func (NullInjectorConsumer) InjectPacket(PacketKey) FlowOp

func (NullInjectorConsumer) Interface

func (NullInjectorConsumer) Interface() *net.Interface

func (NullInjectorConsumer) StartConsumingPackets

func (NullInjectorConsumer) StartConsumingPackets(Consumer) error

func (NullInjectorConsumer) Stats

func (NullInjectorConsumer) Stats() map[string]int

func (NullInjectorConsumer) String

func (NullInjectorConsumer) String() string

type NullNetworkOverlay

type NullNetworkOverlay struct{ mesh.NullOverlay }

func (NullNetworkOverlay) Forward

func (NullNetworkOverlay) Forward(ForwardPacketKey) FlowOp

func (NullNetworkOverlay) InvalidateRoutes

func (NullNetworkOverlay) InvalidateRoutes()

func (NullNetworkOverlay) InvalidateShortIDs

func (NullNetworkOverlay) InvalidateShortIDs()

func (NullNetworkOverlay) StartConsumingPackets

func (NullNetworkOverlay) StartConsumingPackets(*mesh.Peer, *mesh.Peers, OverlayConsumer) error

type OverlayConsumer

type OverlayConsumer func(ForwardPacketKey) FlowOp

When a consumer is called, the decoder will already have been used to decode the frame.

type OverlayForwarder

type OverlayForwarder interface {
	mesh.OverlayConnection
	// Forward a packet across the connection.  May be called as soon
	// as the overlay connection is created, in particular before
	// Confirm().  The return value nil means the key could not be
	// handled by this forwarder.
	Forward(ForwardPacketKey) FlowOp

	HealthChannel() <-chan bool
}

All of the machinery to forward packets to a particular peer

type OverlaySwitch

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

func NewOverlaySwitch

func NewOverlaySwitch() *OverlaySwitch

func (*OverlaySwitch) Add

func (osw *OverlaySwitch) Add(name string, overlay NetworkOverlay)

func (*OverlaySwitch) AddFeaturesTo

func (osw *OverlaySwitch) AddFeaturesTo(features map[string]string)

func (*OverlaySwitch) Diagnostics

func (osw *OverlaySwitch) Diagnostics() interface{}

func (*OverlaySwitch) InvalidateRoutes

func (osw *OverlaySwitch) InvalidateRoutes()

func (*OverlaySwitch) InvalidateShortIDs

func (osw *OverlaySwitch) InvalidateShortIDs()

func (*OverlaySwitch) PrepareConnection

func (osw *OverlaySwitch) PrepareConnection(params mesh.OverlayConnectionParams) (mesh.OverlayConnection, error)

func (*OverlaySwitch) SetCompatOverlay

func (osw *OverlaySwitch) SetCompatOverlay(overlay NetworkOverlay)

func (*OverlaySwitch) StartConsumingPackets

func (osw *OverlaySwitch) StartConsumingPackets(localPeer *mesh.Peer, peers *mesh.Peers, consumer OverlayConsumer) error

func (*OverlaySwitch) Stop

func (osw *OverlaySwitch) Stop()

type PacketDecodingError

type PacketDecodingError struct {
	Desc string
}

func (PacketDecodingError) Error

func (pde PacketDecodingError) Error() string

type PacketKey

type PacketKey struct {
	SrcMAC MAC
	DstMAC MAC
}

type PacketLogging

type PacketLogging interface {
	LogPacket(string, PacketKey)
	LogForwardPacket(string, ForwardPacketKey)
}

type Pcap

type Pcap struct {
	NonDiscardingFlowOp
	// contains filtered or unexported fields
}

func (*Pcap) InjectPacket

func (p *Pcap) InjectPacket(PacketKey) FlowOp

func (*Pcap) Interface

func (p *Pcap) Interface() *net.Interface

func (*Pcap) Process

func (p *Pcap) Process(frame []byte, dec *EthernetDecoder, broadcast bool)

func (*Pcap) StartConsumingPackets

func (p *Pcap) StartConsumingPackets(consumer Consumer) error

func (*Pcap) Stats

func (p *Pcap) Stats() map[string]int

func (*Pcap) String

func (p *Pcap) String() string

type SleeveOverlay

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

func (*SleeveOverlay) AddFeaturesTo

func (*SleeveOverlay) AddFeaturesTo(map[string]string)

func (*SleeveOverlay) Diagnostics

func (*SleeveOverlay) Diagnostics() interface{}

func (*SleeveOverlay) InvalidateRoutes

func (*SleeveOverlay) InvalidateRoutes()

func (*SleeveOverlay) InvalidateShortIDs

func (*SleeveOverlay) InvalidateShortIDs()

func (*SleeveOverlay) PrepareConnection

func (sleeve *SleeveOverlay) PrepareConnection(params mesh.OverlayConnectionParams) (mesh.OverlayConnection, error)

func (*SleeveOverlay) StartConsumingPackets

func (sleeve *SleeveOverlay) StartConsumingPackets(localPeer *mesh.Peer, peers *mesh.Peers, consumer OverlayConsumer) error

func (*SleeveOverlay) Stop

func (*SleeveOverlay) Stop()

type VportStatus

type VportStatus odp.Vport

func (*VportStatus) MarshalJSON

func (vport *VportStatus) MarshalJSON() ([]byte, error)

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier