NewDecoder constructs a decoder
(raddr net.IP, b []byte)
| 373 | |
| 374 | // NewDecoder constructs a decoder |
| 375 | func NewDecoder(raddr net.IP, b []byte) *Decoder { |
| 376 | return &Decoder{raddr, reader.NewReader(b)} |
| 377 | } |
| 378 | |
| 379 | // Decode decodes the flow records |
| 380 | func (d *Decoder) Decode(mem MemCache) (*Message, error) { |