reader

Documentation

Index

• func NewBPFFilterString(target Target) string
• func ParseProxyProtocolHeader(in []byte) (int, []dumper.DumpValue, error)
• type PacketReader
  • func NewPacketReader(ctx context.Context, cancel context.CancelFunc, ...) PacketReader
  • func (r *PacketReader) ReadAndDump(target Target) error
• type Target
  • func ParseTarget(t string) (Target, error)
  • func (t Target) Match(host string, port uint16) bool
• type TargetHost

Functions

func NewBPFFilterString

func NewBPFFilterString(target Target) string

NewBPFFilterString return string for BPF

func ParseProxyProtocolHeader

func ParseProxyProtocolHeader(in []byte) (int, []dumper.DumpValue, error)

ParseProxyProtocolHeader ...

Types

type PacketReader

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

PacketReader struct

func NewPacketReader

func NewPacketReader(
	ctx context.Context,
	cancel context.CancelFunc,
	packetSource *gopacket.PacketSource,
	dumper dumper.Dumper,
	pValues []dumper.DumpValue,
	logger *zap.Logger,
	internalBufferLength int,
	proxyProtocol bool,
	enableInternal bool,
) PacketReader

NewPacketReader return PacketReader

func (*PacketReader) ReadAndDump

func (r *PacketReader) ReadAndDump(target Target) error

ReadAndDump from gopacket.PacketSource

type Target

type Target struct {
	TargetHosts []TargetHost
}

Target struct

func ParseTarget

func ParseTarget(t string) (Target, error)

ParseTarget parse target to host:port

func (Target) Match

func (t Target) Match(host string, port uint16) bool

Match return true if TargetHost match

type TargetHost

type TargetHost struct {
	Host string
	Port uint16
}

TargetHost struct