encoder

Sep 16, 2021

Changes in this version

+ func GetIndex(arr []string, val string) float64

+ func LoadValueEncoders()

+ func MinMax(value float64, sum *ColumnSummary) (result string)

+ func MinMaxIntArr(array []float64) (float64, float64)

+ func SetConfig(c *Config)

+ func StoreValueEncoders()

+ func ZScore(value float64, sum *ColumnSummary) (result string)

+ type ColumnSummary struct

+ Col string

+ Index float64

+ Max float64

+ Mean float64

+ Min float64

+ Std float64

+ Typ ColumnType

+ UniqueStrings map[string]float64

+ Version string

+ type ColumnType int

+ const TypeNumeric

+ const TypeString

+ func (c ColumnType) String() string

type Config

+ MinMax bool

+ NormalizeCategoricals bool

+ ZScore bool

+ type ValueEncoder struct

+ func NewValueEncoder() *ValueEncoder

+ func (m *ValueEncoder) Bool(b bool) string

+ func (m *ValueEncoder) Float64(field string, val float64) string

+ func (m *ValueEncoder) GetSummary(colType ColumnType, field string) *ColumnSummary

+ func (m *ValueEncoder) Int(field string, val int) string

+ func (m *ValueEncoder) Int32(field string, val int32) string

+ func (m *ValueEncoder) Int64(field string, val int64) string

+ func (m *ValueEncoder) String(field string, val string) string

+ func (m *ValueEncoder) Uint32(field string, val uint32) string

+ func (m *ValueEncoder) Uint64(field string, val uint64) string

Feb 24, 2020

Changes in this version

type Config

+ MemBufferSize int

Nov 12, 2019

Changes in this version

+ var AddContext bool

type Config

+ AddContext bool

May 8, 2019

Changes in this version

+ func MarkdownOverview()

type Config

+ Export bool

type CustomEncoder

+ func (e *CustomEncoder) NumRecords() int64

Jan 17, 2019

Changes in this version

+ var CapturePayload = false

type Config

+ IncludePayloads bool

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