ebpf

May 21, 2024

Changes in this version

+ func RecordGetters(name attr.Name) (attributes.Getter[*Record, string], bool)

Apr 19, 2024

Changes in this version

+ func LoadNetSk() (*ebpf.CollectionSpec, error) — darwin/amd64, linux/amd64, windows/amd64

+ func LoadNetSkObjects(obj interface{}, opts *ebpf.CollectionOptions) error — darwin/amd64, linux/amd64, windows/amd64

+ type NetSkFlowId NetSkFlowIdT — darwin/amd64, linux/amd64, windows/amd64

+ type NetSkFlowIdT struct — darwin/amd64, linux/amd64, windows/amd64

+ Direction uint8

+ DstIp struct{ ... }

+ DstPort uint16

+ EthProtocol uint16

+ IfIndex uint32

+ SrcIp struct{ ... }

+ SrcPort uint16

+ TransportProtocol uint8

+ type NetSkFlowMetrics NetSkFlowMetricsT — darwin/amd64, linux/amd64, windows/amd64

+ type NetSkFlowMetricsT struct — darwin/amd64, linux/amd64, windows/amd64

+ Bytes uint64

+ EndMonoTimeNs uint64

+ Errno uint8

+ Flags uint16

+ Packets uint32

+ StartMonoTimeNs uint64

+ type NetSkFlowRecordT struct — darwin/amd64, linux/amd64, windows/amd64

+ Id NetSkFlowId

+ Metrics NetSkFlowMetrics

+ type NetSkMapSpecs struct — darwin/amd64, linux/amd64, windows/amd64

+ AggregatedFlows *ebpf.MapSpec

+ DirectFlows *ebpf.MapSpec

+ type NetSkMaps struct — darwin/amd64, linux/amd64, windows/amd64

+ AggregatedFlows *ebpf.Map

+ DirectFlows *ebpf.Map

+ func (m *NetSkMaps) Close() error

+ type NetSkObjects struct — darwin/amd64, linux/amd64, windows/amd64

+ func (o *NetSkObjects) Close() error

+ type NetSkProgramSpecs struct — darwin/amd64, linux/amd64, windows/amd64

+ SocketHttpFilter *ebpf.ProgramSpec

+ type NetSkPrograms struct — darwin/amd64, linux/amd64, windows/amd64

+ SocketHttpFilter *ebpf.Program

+ func (p *NetSkPrograms) Close() error

+ type NetSkSpecs struct — darwin/amd64, linux/amd64, windows/amd64

+ type SockFlowFetcher struct

+ func NewSockFlowFetcher(_, _ int) (*SockFlowFetcher, error)

+ func NewSockFlowFetcher(sampling, cacheMaxSize int) (*SockFlowFetcher, error)

+ func (m *SockFlowFetcher) Close() error

+ func (m *SockFlowFetcher) LookupAndDeleteMap() map[NetFlowId][]NetFlowMetrics

+ func (m *SockFlowFetcher) ReadRingBuf() (ringbuf.Record, error)

+ func (m *SockFlowFetcher) Register(_ ifaces.Interface) error

+ func (s *SockFlowFetcher) Close() error

+ func (s *SockFlowFetcher) LookupAndDeleteMap() map[NetFlowId][]NetFlowMetrics

+ func (s *SockFlowFetcher) ReadRingBuf() (ringbuf.Record, error)

+ func (s *SockFlowFetcher) Register(_ ifaces.Interface) error

Mar 15, 2024

Changes in this version

+ const DirectionEgress

+ const DirectionIngress

+ const DirectionUnset

+ const InterfaceUnset

type Record

+ Attrs RecordAttrs

+ type RecordAttrs struct

+ BeylaIP string

+ DstName string

+ Interface string

+ Metadata map[string]string

+ SrcName string

Feb 20, 2024

Changes in this version

+ const MacLen

+ func LoadNet() (*ebpf.CollectionSpec, error) — darwin/amd64, linux/amd64, windows/amd64

+ func LoadNetObjects(obj interface{}, opts *ebpf.CollectionOptions) error — darwin/amd64, linux/amd64, windows/amd64

+ func ReadFrom(reader io.Reader) (*NetFlowRecordT, error) — js/wasm

+ type FlowFetcher struct

+ func NewFlowFetcher(_, _ int, _, _ bool) (*FlowFetcher, error)

+ func NewFlowFetcher(sampling, cacheMaxSize int, ingress, egress bool) (*FlowFetcher, error)

+ func (m *FlowFetcher) Close() error

+ func (m *FlowFetcher) LookupAndDeleteMap() map[NetFlowId][]NetFlowMetrics

+ func (m *FlowFetcher) ReadRingBuf() (ringbuf.Record, error)

+ func (m *FlowFetcher) Register(_ ifaces.Interface) error

+ func (m *FlowFetcher) Register(iface ifaces.Interface) error

+ type IPAddr [net.IPv6len]uint8

+ func (ia *IPAddr) IP() net.IP

+ func (ia *IPAddr) IntEncodeV4() uint32

+ func (ia *IPAddr) MarshalJSON() ([]byte, error)

+ type MacAddr [MacLen]uint8

+ func (m *MacAddr) MarshalJSON() ([]byte, error)

+ func (m *MacAddr) String() string

+ type NetFlowId NetFlowIdT — darwin/amd64, linux/amd64, windows/amd64

+ func (fi *NetFlowId) DstIP() *IPAddr

+ func (fi *NetFlowId) DstMAC() *MacAddr

+ func (fi *NetFlowId) SrcIP() *IPAddr

+ func (fi *NetFlowId) SrcMAC() *MacAddr

+ type NetFlowIdT struct — darwin/amd64, linux/amd64, windows/amd64

+ Direction uint8

+ DstIp struct{ ... }

+ DstMac [6]uint8

+ DstPort uint16

+ EthProtocol uint16

+ IfIndex uint32

+ SrcIp struct{ ... }

+ SrcMac [6]uint8

+ SrcPort uint16

+ TransportProtocol uint8

+ type NetFlowMetrics NetFlowMetricsT — darwin/amd64, linux/amd64, windows/amd64

+ func (fm *NetFlowMetrics) Accumulate(src *NetFlowMetrics)

+ type NetFlowMetricsT struct — darwin/amd64, linux/amd64, windows/amd64

+ Bytes uint64

+ EndMonoTimeNs uint64

+ Errno uint8

+ Flags uint16

+ Packets uint32

+ StartMonoTimeNs uint64

+ type NetFlowRecordT struct — darwin/amd64, linux/amd64, windows/amd64

+ Id NetFlowId

+ Metrics NetFlowMetrics

+ func ReadFrom(reader io.Reader) (*NetFlowRecordT, error)

+ type NetMapSpecs struct — darwin/amd64, linux/amd64, windows/amd64

+ AggregatedFlows *ebpf.MapSpec

+ DirectFlows *ebpf.MapSpec

+ type NetMaps struct — darwin/amd64, linux/amd64, windows/amd64

+ AggregatedFlows *ebpf.Map

+ DirectFlows *ebpf.Map

+ func (m *NetMaps) Close() error

+ type NetObjects struct — darwin/amd64, linux/amd64, windows/amd64

+ func (o *NetObjects) Close() error

+ type NetProgramSpecs struct — darwin/amd64, linux/amd64, windows/amd64

+ EgressFlowParse *ebpf.ProgramSpec

+ IngressFlowParse *ebpf.ProgramSpec

+ type NetPrograms struct — darwin/amd64, linux/amd64, windows/amd64

+ EgressFlowParse *ebpf.Program

+ IngressFlowParse *ebpf.Program

+ func (p *NetPrograms) Close() error

+ type NetSpecs struct — darwin/amd64, linux/amd64, windows/amd64

+ type Record struct

+ AgentIP string

+ Duplicate bool

+ Interface string

+ Metadata map[string]string

+ TimeFlowEnd time.Time

+ TimeFlowStart time.Time

+ func NewRecord(key NetFlowId, metrics NetFlowMetrics, currentTime time.Time, ...) *Record