event_processor

Oct 12, 2025

Changes in this version

type BaseEvent

+ func (be *BaseEvent) ToProtobufEvent() *pb.Event

Aug 10, 2025

Changes in this version

type BaseEvent

+ func (be *BaseEvent) Base() event.Base

Jun 29, 2025

Changes in this version

type EventProcessor

+ func (ep *EventProcessor) WriteDestroyConn(s uint64)

type IWorker

+ CloseEventWorker func()

+ GetDestroyUUID func() uint64

type LifeCycleState

+ const LifeCycleStateSock

Jun 13, 2025

Changes in this version

+ type LifeCycleState uint8

+ const LifeCycleStateDefault

+ const LifeCycleStateSocket

Dec 29, 2024

Changes in this version

+ const ClientPrefaceLen

Dec 15, 2024

Changes in this version

+ var ErrEventWorkerIncomingFull = errors.New("eventWorker Write failed, incoming chan is full")

+ var ErrEventWorkerOutcomingFull = errors.New("eventWorker Write failed, outComing chan is full")

type EventProcessor

+ func (ep *EventProcessor) ErrorChan() chan error

Aug 18, 2024

Changes in this version

+ const H2Magic

+ const H2MagicLen

+ type HTTP2Request struct

+ func (h2r *HTTP2Request) Display() []byte

+ func (h2r *HTTP2Request) Init()

+ func (h2r *HTTP2Request) IsDone() bool

+ func (h2r *HTTP2Request) Name() string

+ func (h2r *HTTP2Request) PacketType() PacketType

+ func (h2r *HTTP2Request) ParserType() ParserType

+ func (h2r *HTTP2Request) Reset()

+ func (h2r *HTTP2Request) Write(b []byte) (int, error)

+ type HTTP2Response struct

+ func (h2r *HTTP2Response) Display() []byte

+ func (h2r *HTTP2Response) Init()

+ func (h2r *HTTP2Response) IsDone() bool

+ func (h2r *HTTP2Response) Name() string

+ func (h2r *HTTP2Response) PacketType() PacketType

+ func (h2r *HTTP2Response) ParserType() ParserType

+ func (h2r *HTTP2Response) Reset()

+ func (h2r *HTTP2Response) Write(b []byte) (int, error)

May 19, 2024

Changes in this version

type BaseEvent

+ DataLen int32

May 4, 2024

Changes in this version

+ const ChunkSize

+ const ChunkSizeHalf

+ const Dtls12Version

+ const Dtls1Version

+ const HTTP_NEW_LINE_LENGTH

+ const MaxChanLen

+ const MaxDataSize

+ const MaxIncomingChanLen

+ const MaxParserQueueLen

+ const MaxTickerCount

+ const SaDataLen

+ const Ssl2Version

+ const Ssl3Version

+ const Tls11Version

+ const Tls12Version

+ const Tls13Version

+ const Tls1Version

+ func CToGoString(c []byte) string

+ func GetAllModules() map[string]IParser

+ func Register(p IParser)

+ type AttachType int64

+ const ProbeEntry

+ const ProbeRet

+ type BaseEvent struct

+ Comm [16]byte

+ Data [MaxDataSize]byte

+ DataType int64

+ Data_len int32

+ Fd uint32

+ Pid uint32

+ Tid uint32

+ Timestamp uint64

+ Version int32

+ func (this *BaseEvent) Clone() event.IEventStruct

+ func (this *BaseEvent) Decode(payload []byte) (err error)

+ func (this *BaseEvent) EventType() event.EventType

+ func (this *BaseEvent) GetUUID() string

+ func (this *BaseEvent) Payload() []byte

+ func (this *BaseEvent) PayloadLen() int

+ func (this *BaseEvent) String() string

+ func (this *BaseEvent) StringHex() string

+ type DefaultParser struct

+ func (this *DefaultParser) Display() []byte

+ func (this *DefaultParser) Init()

+ func (this *DefaultParser) IsDone() bool

+ func (this *DefaultParser) Name() string

+ func (this *DefaultParser) PacketType() PacketType

+ func (this *DefaultParser) ParserType() ParserType

+ func (this *DefaultParser) Reset()

+ func (this *DefaultParser) Write(b []byte) (int, error)

+ type EventProcessor struct

+ func NewEventProcessor(logger *log.Logger, isHex bool) *EventProcessor

+ func (this *EventProcessor) Close() error

+ func (this *EventProcessor) GetLogger() *log.Logger

+ func (this *EventProcessor) Serve()

+ func (this *EventProcessor) Write(e event.IEventStruct)

+ type HTTPRequest struct

+ func (hr *HTTPRequest) Display() []byte

+ func (hr *HTTPRequest) Init()

+ func (hr *HTTPRequest) IsDone() bool

+ func (hr *HTTPRequest) Name() string

+ func (hr *HTTPRequest) PacketType() PacketType

+ func (hr *HTTPRequest) ParserType() ParserType

+ func (hr *HTTPRequest) Reset()

+ func (hr *HTTPRequest) Write(b []byte) (int, error)

+ type HTTPResponse struct

+ func (hr *HTTPResponse) Display() []byte

+ func (hr *HTTPResponse) Init()

+ func (hr *HTTPResponse) IsDone() bool

+ func (hr *HTTPResponse) Name() string

+ func (hr *HTTPResponse) PacketType() PacketType

+ func (hr *HTTPResponse) ParserType() ParserType

+ func (hr *HTTPResponse) Reset()

+ func (hr *HTTPResponse) Write(b []byte) (int, error)

+ type IParser interface

+ Display func() []byte

+ Init func()

+ IsDone func() bool

+ Name func() string

+ PacketType func() PacketType

+ ParserType func() ParserType

+ Reset func()

+ Write func(b []byte) (int, error)

+ func GetModuleByName(name string) IParser

+ func NewParser(payload []byte) IParser

+ type IWorker interface

+ Get func()

+ GetUUID func() string

+ IfUsed func() bool

+ Put func()

+ Write func(event.IEventStruct) error

+ func NewEventWorker(uuid string, processor *EventProcessor) IWorker

+ type PacketType uint8

+ const PacketTypeGzip

+ const PacketTypeNull

+ const PacketTypeUnknow

+ const PacketTypeWebSocket

+ type ParserType uint8

+ const ParserTypeHttp2Request

+ const ParserTypeHttp2Response

+ const ParserTypeHttpRequest

+ const ParserTypeHttpResponse

+ const ParserTypeNull

+ const ParserTypeWebSocket

+ type ProcessStatus uint8

+ const ProcessStateDone

+ const ProcessStateInit

+ const ProcessStateProcessing