Versions in this module Expand all Collapse all v1 v1.5.0 Jan 23, 2020 Changes in this version + const IntFields + type ClientStream Consumer + func (cs *ClientStream) Reassembled(rs []tcpassembly.Reassembly) + func (cs *ClientStream) ReassemblyComplete() type Consumer + Fsm Fsm + func New(handler EventHandler, fsm Fsm) *Consumer + func (c *Consumer) ClientStream() tcpassembly.Stream + func (c *Consumer) Close() + func (c *Consumer) ServerStream() tcpassembly.Stream + type DummySource struct + func (s *DummySource) Close() error + func (s *DummySource) Discard(n int) (discarded int, err error) + func (s *DummySource) IndexAny(chars string) (int, error) + func (s *DummySource) PeekN(n int) ([]byte, error) + func (s *DummySource) Read(p []byte) (int, error) + func (s *DummySource) ReadLine() ([]byte, error) + func (s *DummySource) ReadN(n int) ([]byte, error) + func (s *DummySource) Reassembled(rs []tcpassembly.Reassembly) + func (s *DummySource) ReassemblyComplete() + func (s *DummySource) Reset() + func (s *DummySource) Truncate() + type EventFieldMask int + const FieldEndOfFields + const FieldKey + const FieldNone + const FieldSize + type Fsm interface + Run func() + SetConsumer func(consumer *Consumer) + type ProtocolType uint8 + const ProtocolInfer + const ProtocolMemcacheText + const ProtocolRedis + const ProtocolUnknown + func GetProtocolType(protocol string) ProtocolType type Reader + IndexAny func(chars string) (int, error) + PeekN func(n int) ([]byte, error) + Reset func() + Truncate func() + type ServerStream Consumer + func (ss *ServerStream) Reassembled(rs []tcpassembly.Reassembly) + func (ss *ServerStream) ReassemblyComplete() v1.4.0 Oct 20, 2017 Changes in this version + type Consumer struct + ClientReader ConsumerSource + Handler EventHandler + Logger log.Logger + ServerReader ConsumerSource + func (c *Consumer) AddEvent(evt Event) + func (c *Consumer) FlushEvents() + type ConsumerSource interface + type Event struct + Key string + Size int + Type EventType + type EventHandler func(evts []Event) + type EventType int + const EventGetHit + const EventGetMiss + const EventUnknown + type Reader interface + Discard func(n int) (discarded int, err error) + ReadLine func() ([]byte, error) + ReadN func(n int) ([]byte, error)
Go to main page