logic

package

v0.3.0 Latest Latest Go to latest Published: Mar 21, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func ExtractNames(ctx context.Context, pkt gopacket.Packet, repo interfaces.Repository)

ExtractNames parses protocol-specific information from a packet and saves name resolution data (IP→name, MAC→name) to the repository.

func GetEthernetMACs(pkt gopacket.Packet) (srcMAC, dstMAC net.HardwareAddr)

GetEthernetMACs extracts source and destination MAC addresses from the Ethernet layer.

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

func NewDNSTracker() *DNSTracker

func (t *DNSTracker) Expire(now time.Time) []*model.DNSLog

func (t *DNSTracker) Flush() []*model.DNSLog

func (t *DNSTracker) Input(pkt gopacket.Packet, now time.Time) []*model.DNSLog

func (t *DNSTracker) PendingCount() int

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

func NewEngine(opts ...Option) *Engine

func (x *Engine) FlowCount() int

func (x *Engine) Flush(ctx context.Context) *model.Record

func (x *Engine) InputPacket(ctx context.Context, pkt gopacket.Packet) (*model.Record, error)

func (x *Engine) Tick(ctx context.Context, now time.Time) (*model.Record, error)

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

func NewFlowMap() *FlowMap

func (x *FlowMap) Expire(at time.Time) []*model.Flow

func (x *FlowMap) Flush() []*model.Flow

func (x *FlowMap) Get(key model.FlowKey) *model.Flow

func (x *FlowMap) Len() int

func (x *FlowMap) Put(flow *model.Flow) bool

func (x *FlowMap) SetNames(key model.FlowKey, addr net.IP, names []string)

type Option func(*Engine)

func WithRepository(repo interfaces.Repository) Option

func WithTimeout(d time.Duration) Option