base

Documentation

Index

• type Context
• type Metrics
• type Protocol
• type ProtocolAnalyzer
  • func NewProtocolAnalyzer(protocolContext Context, p Protocol, config *profiling.TaskConfig) *ProtocolAnalyzer
  • func (a *ProtocolAnalyzer) ReceiveSocketCloseEvent(event *events.SocketCloseEvent)
  • func (a *ProtocolAnalyzer) ReceiveSocketData(ctx Context, event *events.SocketDataUploadEvent)
  • func (a *ProtocolAnalyzer) ReceiveSocketDetail(ctx Context, event *events.SocketDetailEvent)
  • func (a *ProtocolAnalyzer) Start(ctx context.Context)
  • func (a *ProtocolAnalyzer) UpdateExtensionConfig(config *profiling.ExtensionConfig)

Types

type Context

type Context interface {
	QueryConnection(connectionID, randomID uint64) *base.ConnectionContext
	QueryProtocolMetrics(conMetrics *base.ConnectionMetricsContext, protocol enums.ConnectionProtocol) Metrics
}

type Metrics

type Metrics interface {
	base.ConnectionMetrics

	// FlushMetrics flush all metrics from traffic to the metricsBuilder
	FlushMetrics(traffic *base.ProcessTraffic, metricsBuilder *base.MetricsBuilder)
}

type Protocol

type Protocol interface {
	Protocol() enums.ConnectionProtocol
	GenerateMetrics() Metrics
	Init(config *profiling.TaskConfig)

	ParseProtocol(connectionID uint64, metrics Metrics, reader *buffer.Buffer) enums.ParseResult
	PackageMaxExpireDuration() time.Duration
	UpdateExtensionConfig(config *profiling.ExtensionConfig)
}

type ProtocolAnalyzer

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

ProtocolAnalyzer handler all socket data for each protocol

func NewProtocolAnalyzer

func NewProtocolAnalyzer(protocolContext Context, p Protocol, config *profiling.TaskConfig) *ProtocolAnalyzer

func (*ProtocolAnalyzer) ReceiveSocketCloseEvent

func (a *ProtocolAnalyzer) ReceiveSocketCloseEvent(event *events.SocketCloseEvent)

func (*ProtocolAnalyzer) ReceiveSocketData

func (a *ProtocolAnalyzer) ReceiveSocketData(ctx Context, event *events.SocketDataUploadEvent)

func (*ProtocolAnalyzer) ReceiveSocketDetail

func (a *ProtocolAnalyzer) ReceiveSocketDetail(ctx Context, event *events.SocketDetailEvent)

func (*ProtocolAnalyzer) Start

func (a *ProtocolAnalyzer) Start(ctx context.Context)

func (*ProtocolAnalyzer) UpdateExtensionConfig

func (a *ProtocolAnalyzer) UpdateExtensionConfig(config *profiling.ExtensionConfig)