protocols

Documentation

Index

• type AnalyzeHelper
• type AnalyzeQueue
  • func NewAnalyzeQueue(ctx *common.AccessLogContext) (*AnalyzeQueue, error)
  • func (q *AnalyzeQueue) Start(ctx context.Context)
• type HTTP1Metrics
• type HTTP1Protocol
  • func (p *HTTP1Protocol) Analyze(metrics ProtocolMetrics, buf *buffer.Buffer, _ *AnalyzeHelper) error
  • func (p *HTTP1Protocol) GenerateConnection(connectionID, randomID uint64) ProtocolMetrics
• type HTTP2Metrics
• type HTTP2Protocol
  • func (r *HTTP2Protocol) Analyze(metrics ProtocolMetrics, buf *buffer.Buffer, helper *AnalyzeHelper) error
  • func (r *HTTP2Protocol) GenerateConnection(connectionID, randomID uint64) ProtocolMetrics
• type HTTP2Streaming
• type PartitionConnection
• type PartitionContext
  • 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
• type ProtocolManager
  • func NewProtocolManager(ctx *common.AccessLogContext) *ProtocolManager
  • func (a *ProtocolManager) GetProtocol(protocol enums.ConnectionProtocol) Protocol
• type ProtocolMetrics

Types

type AnalyzeHelper

type AnalyzeHelper struct {
	ProtocolBreak bool
}

type AnalyzeQueue

type AnalyzeQueue struct {
	// contains filtered or unexported fields
}

func NewAnalyzeQueue

func NewAnalyzeQueue(ctx *common.AccessLogContext) (*AnalyzeQueue, error)

func (*AnalyzeQueue) Start

func (q *AnalyzeQueue) Start(ctx context.Context)

type HTTP1Metrics

type HTTP1Metrics struct {
	// contains filtered or unexported fields
}

type HTTP1Protocol

type HTTP1Protocol struct {
	// contains filtered or unexported fields
}

func (*HTTP1Protocol) Analyze

func (p *HTTP1Protocol) Analyze(metrics ProtocolMetrics, buf *buffer.Buffer, _ *AnalyzeHelper) error

func (*HTTP1Protocol) GenerateConnection

func (p *HTTP1Protocol) GenerateConnection(connectionID, randomID uint64) ProtocolMetrics

type HTTP2Metrics

type HTTP2Metrics struct {
	// contains filtered or unexported fields
}

type HTTP2Protocol

type HTTP2Protocol struct {
	// contains filtered or unexported fields
}

func (*HTTP2Protocol) Analyze

func (r *HTTP2Protocol) Analyze(metrics ProtocolMetrics, buf *buffer.Buffer, helper *AnalyzeHelper) error

func (*HTTP2Protocol) GenerateConnection

func (r *HTTP2Protocol) GenerateConnection(connectionID, randomID uint64) ProtocolMetrics

type HTTP2Streaming

type HTTP2Streaming struct {
	// contains filtered or unexported fields
}

type PartitionConnection

type PartitionConnection struct {
	// contains filtered or unexported fields
}

type PartitionContext

type PartitionContext struct {
	// contains filtered or unexported fields
}

func NewPartitionContext

func NewPartitionContext(ctx *common.AccessLogContext) *PartitionContext

func (*PartitionContext) Consume

func (p *PartitionContext) Consume(data interface{})

func (*PartitionContext) OnConnectionClose

func (p *PartitionContext) OnConnectionClose(event *events.SocketCloseEvent, closeCallback common.ConnectionProcessFinishCallback)

func (*PartitionContext) Start

func (p *PartitionContext) Start(ctx context.Context)

type Protocol

type Protocol interface {
	GenerateConnection(connectionID, randomID uint64) ProtocolMetrics
	Analyze(metrics ProtocolMetrics, buffer *buffer.Buffer, helper *AnalyzeHelper) error
}

type ProtocolManager

type ProtocolManager struct {
	// contains filtered or unexported fields
}

func NewProtocolManager

func NewProtocolManager(ctx *common.AccessLogContext) *ProtocolManager

func (*ProtocolManager) GetProtocol

func (a *ProtocolManager) GetProtocol(protocol enums.ConnectionProtocol) Protocol

type ProtocolMetrics

type ProtocolMetrics interface {
}