packet

Documentation

Index

• Variables
• type PacketData
• type PacketSource
  • func NewPlainPacketSource(dataDir string) (PacketSource, error)
  • func NewTLSPacketSource(dataDir string) (PacketSource, error)
• type PacketSourceImpl
  • func (p *PacketSourceImpl) NextPacket() (gopacket.Packet, error)
  • func (p *PacketSourceImpl) Start() error
  • func (p *PacketSourceImpl) Stats() (packetsGot, packetsLost uint64)
  • func (p *PacketSourceImpl) Stop() error
  • func (p *PacketSourceImpl) WritePacket(pkt gopacket.Packet) error
• type PacketsPoller

Variables

var (
	ErrNotSupported = errors.New("source is not supported")
)

Types

type PacketData

type PacketData struct {
	Timestamp uint64
	Data      []byte
}

type PacketSource

type PacketSource interface {
	NextPacket() (gopacket.Packet, error)
	Start() error
	Stop() error
	Stats() (packetsGot, packetsLost uint64)
}

func NewPlainPacketSource

func NewPlainPacketSource(dataDir string) (PacketSource, error)

func NewTLSPacketSource

func NewTLSPacketSource(dataDir string) (PacketSource, error)

type PacketSourceImpl

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

func (*PacketSourceImpl) NextPacket

func (p *PacketSourceImpl) NextPacket() (gopacket.Packet, error)

func (*PacketSourceImpl) Start

func (p *PacketSourceImpl) Start() error

func (*PacketSourceImpl) Stats

func (p *PacketSourceImpl) Stats() (packetsGot, packetsLost uint64)

func (*PacketSourceImpl) Stop

func (p *PacketSourceImpl) Stop() error

func (*PacketSourceImpl) WritePacket

func (p *PacketSourceImpl) WritePacket(pkt gopacket.Packet) error

type PacketsPoller

type PacketsPoller interface {
	Start()
	Stop() error
	GetReceivedPackets() uint64
	GetLostChunks() uint64
}