pcap

Documentation

Index

• Constants
• type PacketProcessor
  • func NewPacketProcessor(metloAPI *metloapi.Metlo, interfaceName string) (*PacketProcessor, error)
  • func (x *PacketProcessor) Put(pkt *packetData) error
  • func (x *PacketProcessor) Setup() error
  • func (x *PacketProcessor) Shutdown() error
  • func (x *PacketProcessor) Tick(now time.Time) error
• type Pcap
  • func New(captureInterface string) *Pcap
  • func (x *Pcap) Start(proc Processor) error
• type Processor

Constants

const (
	// DefaultReceiverQueueSize is default queue size of channel from packet server to packet processor.
	DefaultReceiverQueueSize = 1024
)

Types

type PacketProcessor

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

func NewPacketProcessor

func NewPacketProcessor(metloAPI *metloapi.Metlo, interfaceName string) (*PacketProcessor, error)

func (*PacketProcessor) Put

func (x *PacketProcessor) Put(pkt *packetData) error

func (*PacketProcessor) Setup

func (x *PacketProcessor) Setup() error

func (*PacketProcessor) Shutdown

func (x *PacketProcessor) Shutdown() error

func (*PacketProcessor) Tick

func (x *PacketProcessor) Tick(now time.Time) error

type Pcap

type Pcap struct {
	QueueSize int
	// contains filtered or unexported fields
}

VXCap is one of main components of the package

func New

func New(captureInterface string) *Pcap

New is constructor of VXCap

func (*Pcap) Start

func (x *Pcap) Start(proc Processor) error

Start invokes packet listener and forwards captured packets to processor.

type Processor

type Processor interface {
	Setup() error
	Put(pkt *packetData) error
	Tick(now time.Time) error
	Shutdown() error
}