Versions in this module Expand all Collapse all v0 v0.3.8 Jan 5, 2019 v0.3.7 Dec 31, 2018 v0.3.6 Dec 26, 2018 v0.3.5 Dec 25, 2018 Changes in this version + var BlockSize int + var Connections = &AtomicConnMap + var CustomEncoders = []*CustomEncoder + var Flows = &AtomicFlowMap + var HTTPActive bool + var LayerEncoders = map[gopacket.LayerType]*LayerEncoder + var LinkFlows = &AtomicLinkFlowMap + var LiveMode bool + var NetworkFlows = &AtomicNetworkFlowMap + var TransportFlows = &AtomicTransportFlowMap + func CloseFile(outDir string, file *os.File, typ string) (name string, size int64) + func CloseGzipWriters(writers ...*gzip.Writer) + func CreateFile(name, ext string) *os.File + func Debug(s string, a ...interface{}) + func DecodeHTTP(packet gopacket.Packet) + func DumpTop5LinkFlows() + func DumpTop5NetworkFlows() + func DumpTop5TransportFlows() + func Entropy(data []byte) (entropy float64) + func Error(t string, s string, a ...interface{}) + func ExtractTLSHandShake(tcp *layers.TCP) (*tlsx.ClientHello, bool) + func FlushWriters(writers ...flushableWriter) + func Info(s string, a ...interface{}) + func InitCustomEncoders(c Config) + func InitLayerEncoders(c Config) + func NewCSVWriter(w io.Writer) *csvWriter + func NewHeader(t types.Type, c Config) *types.Header + func Overview() + func RemoveEmptyFile(name string) (size int64) + func SetErrorMap(m *AtomicCounterMap) + func ShowEncoders() + type AtomicConnMap struct + Items map[string]*types.Connection + func (a *AtomicConnMap) Size() int + type AtomicCounterMap struct + Items map[string]int64 + func NewAtomicCounterMap() *AtomicCounterMap + func (a *AtomicCounterMap) Inc(val string) + type AtomicDelimitedWriter struct + func NewAtomicDelimitedWriter(w *delimited.Writer) *AtomicDelimitedWriter + func (a *AtomicDelimitedWriter) PutProto(pb proto.Message) error + type AtomicFlowMap struct + Items map[string]*types.Flow + func (a *AtomicFlowMap) Size() int + type AtomicLinkFlowMap struct + Items map[uint64]*types.LinkFlow + type AtomicNetworkFlowMap struct + Items map[uint64]*types.NetworkFlow + type AtomicTransportFlowMap struct + Items map[uint64]*types.TransportFlow + type Config struct + Buffer bool + CSV bool + Compression bool + ExcludeEncoders string + IncludeEncoders string + Out string + Source string + Version string + WriteChan bool + type ConnectionID struct + LinkFlowID uint64 + NetworkFlowID uint64 + TransportFlowID uint64 + func (c ConnectionID) String() string + type Context struct + CaptureInfo gopacket.CaptureInfo + func (c *Context) GetCaptureInfo() gopacket.CaptureInfo + type CustomEncoder struct + Handler CustomEncoderHandler + Name string + Type types.Type + func CreateCustomEncoder(t types.Type, name string, postinit func(*CustomEncoder) error, ...) *CustomEncoder + func (d *CustomEncoder) Destroy() (name string, size int64) + func (d *CustomEncoder) Encode(p gopacket.Packet) error + func (d *CustomEncoder) GetChan() <-chan []byte + func (d *CustomEncoder) Init(buffer, compress, csv bool, out string, writeChan bool) + type CustomEncoderHandler = func(p gopacket.Packet) proto.Message + type LayerEncoder struct + Handler LayerEncoderHandler + Layer gopacket.LayerType + Type types.Type + func CreateLayerEncoder(nt types.Type, lt gopacket.LayerType, handler LayerEncoderHandler) *LayerEncoder + func (d *LayerEncoder) Destroy() (name string, size int64) + func (d *LayerEncoder) Encode(l gopacket.Layer, timestamp time.Time) error + func (d *LayerEncoder) GetChan() <-chan []byte + func (d *LayerEncoder) Init(buffer, compress, csv bool, out string, writeChan bool) + type LayerEncoderHandler = func(layer gopacket.Layer, timestamp string) proto.Message + type Stream struct + func (s Stream) Reverse() Stream + func (s Stream) String() string