decoder

Documentation

Index

• Constants
• type Counter
• type Decoder
  • func NewDecoder(index int, inQueue queue.QueueReader, pcapWriter *dbwriter.PcapWriter, ...) *Decoder
  • func (d *Decoder) GetCounter() interface{}
  • func (d *Decoder) Run()
• type PcapHeader
  • func (p *PcapHeader) Encode(encoder *codec.SimpleEncoder)

Constants

const (
	BUFFER_SIZE = 1024
)

Types

type Counter

type Counter struct {
	InCount    int64 `statsd:"in-count"`
	OutCount   int64 `statsd:"out-count"`
	ErrorCount int64 `statsd:"err-count"`
}

type Decoder

type Decoder struct {
	utils.Closable
	// contains filtered or unexported fields
}

func NewDecoder

func NewDecoder(
	index int,
	inQueue queue.QueueReader,
	pcapWriter *dbwriter.PcapWriter,
	config *config.Config,
) *Decoder

func (*Decoder) GetCounter

func (d *Decoder) GetCounter() interface{}

func (*Decoder) Run

func (d *Decoder) Run()

type PcapHeader

type PcapHeader struct {
	Magic        uint32
	Major        uint16
	Minor        uint16
	ThisZone     uint32
	SigFigs      uint32
	SnapLen      uint32
	LinkType     uint32
	EncoderMagic uint32
}

func (*PcapHeader) Encode

func (p *PcapHeader) Encode(encoder *codec.SimpleEncoder)