collection

Documentation

Index

• Variables
• func ReleaseFullPacket(fullPkt *def.FullPacket)
• type Collector
• type CollectorMgr
  • func NewCollectorMgr(opt def.CollectorOption) (*CollectorMgr, error)
  • func (t *CollectorMgr) AsyncCollect(detectInfo *def.DetectionInfo) error
  • func (t *CollectorMgr) PopFullPackets(count int) ([]*def.FullPacket, error)
  • func (t *CollectorMgr) Start() error
  • func (t *CollectorMgr) Stop()
  • func (t *CollectorMgr) SyncCollectAndReassembly(detectInfo *def.DetectionInfo) (*def.FullPacket, error)

Variables

var (
	ErrFragGroupMapReachedLenLimit = errors.New("reached the maximum length limit")
)

Functions

func ReleaseFullPacket

func ReleaseFullPacket(fullPkt *def.FullPacket)

Types

type Collector

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

type CollectorMgr

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

func NewCollectorMgr

func NewCollectorMgr(opt def.CollectorOption) (*CollectorMgr, error)

func (*CollectorMgr) AsyncCollect

func (t *CollectorMgr) AsyncCollect(detectInfo *def.DetectionInfo) error

func (*CollectorMgr) PopFullPackets

func (t *CollectorMgr) PopFullPackets(count int) ([]*def.FullPacket, error)

func (*CollectorMgr) Start

func (t *CollectorMgr) Start() error

func (*CollectorMgr) Stop

func (t *CollectorMgr) Stop()

func (*CollectorMgr) SyncCollectAndReassembly

func (t *CollectorMgr) SyncCollectAndReassembly(detectInfo *def.DetectionInfo) (*def.FullPacket, error)