network

package

Go to main page

Versions in this module

v0

v0.9.0

Oct 20, 2021

retracted

Changes in this version

+ const ConnectionByteKeyMaxLen

+ const DNSResponseCodeNoError

+ func DNSKey(c *ConnectionStats) (dns.Key, bool)

+ func GetNATLocalAddress(c ConnectionStats) (util.Address, uint16)

+ func GetNATRemoteAddress(c ConnectionStats) (util.Address, uint16)

+ func IsEphemeralPort(port int) bool

+ func IsExcludedConnection(scf []*ConnectionFilter, dcf []*ConnectionFilter, conn *ConnectionStats) bool

+ func ReadInitialState(procRoot string, protocol ConnectionType, collectIPv6 bool) (map[PortMapping]struct{}, error) — linux/amd64

+ func Reclaim(c *Connections)

+ type BufferedData struct

+ Conns []ConnectionStats

+ type ConnectionBuffer struct

+ func NewConnectionBuffer(initSize, minSize int) *ConnectionBuffer

+ func (b *ConnectionBuffer) Append(slice []ConnectionStats)

+ func (b *ConnectionBuffer) Capacity() int

+ func (b *ConnectionBuffer) Connections() []ConnectionStats

+ func (b *ConnectionBuffer) Len() int

+ func (b *ConnectionBuffer) Next() *ConnectionStats

+ func (b *ConnectionBuffer) Reclaim(n int)

+ func (b *ConnectionBuffer) Reset()

type ConnectionFamily

+ func (c ConnectionFamily) String() string

type ConnectionStats

+ IsAssured bool

+ LastRecvPackets uint64

+ LastSentPackets uint64

+ LastTCPClosed uint32

+ LastTCPEstablished uint32

+ MonotonicRecvPackets uint64

+ MonotonicSentPackets uint64

+ MonotonicTCPClosed uint32

+ MonotonicTCPEstablished uint32

+ SPortIsEphemeral EphemeralPortType

+ Via *Via

+ func (c ConnectionStats) IsExpired(now uint64, timeout uint64) bool

type Connections

+ CompilationTelemetryByAsset map[string]RuntimeCompilationTelemetry

+ ConnTelemetry *ConnectionsTelemetry

+ DNSStats dns.StatsByKeyByNameByType

+ HTTP map[http.Key]http.RequestStats

type ConnectionsTelemetry

+ ConntrackSamplingPercent int64

+ DNSStatsDropped int64

+ MonotonicUDPSendsMissed int64

+ MonotonicUDPSendsProcessed int64

+ type Delta struct

+ DNSStats dns.StatsByKeyByNameByType

+ HTTP map[http.Key]http.RequestStats

+ type EphemeralPortType uint8

+ const EphemeralFalse

+ const EphemeralTrue

+ const EphemeralUnknown

+ func IsPortInEphemeralRange(f ConnectionFamily, t ConnectionType, p uint16) EphemeralPortType

+ func IsPortInEphemeralRange(p uint16) EphemeralPortType

+ func (e EphemeralPortType) String() string

type PortMapping — linux/amd64

+ Ino uint32

+ Port uint16

+ type Route struct — linux/amd64

+ Gateway util.Address

+ IfIndex int

+ type RouteCache interface — linux/amd64

+ Get func(source, dest util.Address, netns uint32) (Route, bool)

+ func NewRouteCache(size int, router Router) RouteCache

+ type Router interface — linux/amd64

+ Route func(source, dest util.Address, netns uint32) (Route, bool)

+ func NewNetlinkRouter(procRoot string) (Router, error)

+ type RuntimeCompilationTelemetry struct

+ KernelHeaderFetchResult int32

+ RuntimeCompilationDuration int64

+ RuntimeCompilationEnabled bool

+ RuntimeCompilationResult int32

type State

+ GetDelta func(clientID string, latestTime uint64, active []ConnectionStats, ...) Delta

+ StoreClosedConnections func(connections []ConnectionStats)

+ type Subnet struct

+ Alias string

+ type Via struct

+ Subnet Subnet

v0.8.0

Jul 23, 2020

retracted

Changes in this version

+ const DEBUGCLIENT

+ const MaxStateMapSize

+ const TCPProtocol — windows/amd64

+ const UDPProtocol — windows/amd64

+ func BeautifyKey(key string) string

+ func ConnectionSummary(c ConnectionStats, names map[util.Address][]string) string

+ func IsBlacklistedConnection(scf []*ConnectionFilter, dcf []*ConnectionFilter, conn *ConnectionStats) bool

+ type ConnTypeFilter struct

+ TCP bool

+ UDP bool

+ type ConnectionDirection uint8

+ const INCOMING

+ const LOCAL

+ const NONE

+ const OUTGOING

+ func (d ConnectionDirection) String() string

+ type ConnectionFamily uint8

+ const AFINET

+ const AFINET6

+ type ConnectionFilter struct

+ AllPorts ConnTypeFilter

+ IP *net.IPNet

+ Ports map[uint16]ConnTypeFilter

+ func ParseConnectionFilters(filters map[string][]string) (blacklist []*ConnectionFilter)

+ type ConnectionStats struct

+ DNSFailedResponses uint32

+ DNSFailureLatencySum uint64

+ DNSSuccessLatencySum uint64

+ DNSSuccessfulResponses uint32

+ DNSTimeouts uint32

+ DPort uint16

+ Dest util.Address

+ Direction ConnectionDirection

+ Family ConnectionFamily

+ IPTranslation *IPTranslation

+ IntraHost bool

+ LastRecvBytes uint64

+ LastRetransmits uint32

+ LastSentBytes uint64

+ LastUpdateEpoch uint64

+ MonotonicRecvBytes uint64

+ MonotonicRetransmits uint32

+ MonotonicSentBytes uint64

+ NetNS uint32

+ Pid uint32

+ RTT uint32

+ RTTVar uint32

+ SPort uint16

+ Source util.Address

+ Type ConnectionType

+ func FlowToConnStat(flow *C.struct__perFlowData) ConnectionStats

+ func (c ConnectionStats) ByteKey(buffer *bytes.Buffer) ([]byte, error)

+ func (c ConnectionStats) String() string

+ type ConnectionType uint8

+ const TCP

+ const UDP

+ func (c ConnectionType) String() string

+ type Connections struct

+ Conns []ConnectionStats

+ DNS map[util.Address][]string

+ Telemetry *ConnectionsTelemetry

+ type ConnectionsTelemetry struct

+ ConnsBpfMapSize int64

+ MonotonicConnsClosed int64

+ MonotonicConntrackRegisters int64

+ MonotonicConntrackRegistersDropped int64

+ MonotonicDNSPacketsProcessed int64

+ MonotonicKprobesMissed int64

+ MonotonicKprobesTriggered int64

+ type DNSPacketType uint8

+ const FailedResponse

+ const Query

+ const SuccessfulResponse

+ type DriverHandle struct — windows/amd64

+ func NewDriverHandle(h windows.Handle, handleType HandleType) (*DriverHandle, error)

+ type DriverInterface struct — windows/amd64

+ func NewDriverInterface() (*DriverInterface, error)

+ func (di *DriverInterface) Close() error

+ func (di *DriverInterface) GetConnectionStats() ([]ConnectionStats, []ConnectionStats, error)

+ func (di *DriverInterface) GetStats() (map[string]interface{}, error)

+ type HandleType string — windows/amd64

+ const DataHandle

+ const FlowHandle

+ const StatsHandle

+ type IPTranslation struct

+ ReplDstIP util.Address

+ ReplDstPort uint16

+ ReplSrcIP util.Address

+ ReplSrcPort uint16

+ type PortMapping struct

+ func NewPortMapping(procRoot string, collectTCP, collectIPv6 bool) *PortMapping

+ func (pm *PortMapping) AddMapping(port uint16)

+ func (pm *PortMapping) IsListening(port uint16) bool

+ func (pm *PortMapping) ReadInitialState() error

+ func (pm *PortMapping) ReadInitialUDPState() error

+ func (pm *PortMapping) RemoveMapping(port uint16)

+ type ReverseDNS interface

+ Close func()

+ GetDNSStats func() map[dnsKey]dnsStats

+ GetStats func() map[string]int64

+ Resolve func([]ConnectionStats) map[util.Address][]string

+ func NewNullReverseDNS() ReverseDNS

+ type State interface

+ Connections func(clientID string, latestTime uint64, latestConns []ConnectionStats, ...) []ConnectionStats

+ DumpState func(clientID string) map[string]interface{}

+ GetStats func() map[string]interface{}

+ RemoveClient func(clientID string)

+ RemoveConnections func(keys []string)

+ RemoveExpiredClients func(now time.Time)

+ StoreClosedConnection func(conn ConnectionStats)

+ func NewState(clientExpiry time.Duration, maxClosedConns, maxClientStats int, ...) State

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