Versions in this module Expand all Collapse all v0 v0.7.0 Oct 10, 2024 v0.6.0 Mar 19, 2024 Changes in this version + type AnalyzeHelper struct + ProtocolBreak bool + type AnalyzeQueue struct + func NewAnalyzeQueue(ctx *common.AccessLogContext) (*AnalyzeQueue, error) + func (q *AnalyzeQueue) Start(ctx context.Context) + type HTTP1Metrics struct + type HTTP1Protocol struct + func (p *HTTP1Protocol) Analyze(metrics ProtocolMetrics, buf *buffer.Buffer, _ *AnalyzeHelper) error + func (p *HTTP1Protocol) GenerateConnection(connectionID, randomID uint64) ProtocolMetrics + type HTTP2Metrics struct + type HTTP2Protocol struct + func (r *HTTP2Protocol) Analyze(metrics ProtocolMetrics, buf *buffer.Buffer, helper *AnalyzeHelper) error + func (r *HTTP2Protocol) GenerateConnection(connectionID, randomID uint64) ProtocolMetrics + type HTTP2Streaming struct + type PartitionConnection struct + type PartitionContext struct + func NewPartitionContext(ctx *common.AccessLogContext) *PartitionContext + func (p *PartitionContext) Consume(data interface{}) + func (p *PartitionContext) OnConnectionClose(event *events.SocketCloseEvent, ...) + func (p *PartitionContext) Start(ctx context.Context) + type Protocol interface + Analyze func(metrics ProtocolMetrics, buffer *buffer.Buffer, helper *AnalyzeHelper) error + GenerateConnection func(connectionID, randomID uint64) ProtocolMetrics + type ProtocolManager struct + func NewProtocolManager(ctx *common.AccessLogContext) *ProtocolManager + func (a *ProtocolManager) GetProtocol(protocol enums.ConnectionProtocol) Protocol + type ProtocolMetrics interface
Go to main page