protocols

Documentation

Index

• type Analyzer
  • func NewAnalyzer(ctx protocol.Context, config *profiling.TaskConfig) *Analyzer
  • func (a *Analyzer) ReceiveSocketClose(event *events.SocketCloseEvent)
  • func (a *Analyzer) ReceiveSocketDataEvent(event *events.SocketDataUploadEvent)
  • func (a *Analyzer) ReceiveSocketDetail(event *events.SocketDetailEvent)
  • func (a *Analyzer) Start(ctx context.Context)
  • func (a *Analyzer) UpdateExtensionConfig(config *profiling.ExtensionConfig)
• type ProtocolMetrics
  • func NewProtocolMetrics() *ProtocolMetrics
  • func (m *ProtocolMetrics) FlushMetrics(traffic *base.ProcessTraffic, metricsBuilder *base.MetricsBuilder)
  • func (m *ProtocolMetrics) GetProtocolMetrics(p enums.ConnectionProtocol) protocol.Metrics
  • func (m *ProtocolMetrics) MergeMetricsFromConnection(connection *base.ConnectionContext, data base.ConnectionMetrics)

Types

type Analyzer

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

func NewAnalyzer

func NewAnalyzer(ctx protocol.Context, config *profiling.TaskConfig) *Analyzer

func (*Analyzer) ReceiveSocketClose

func (a *Analyzer) ReceiveSocketClose(event *events.SocketCloseEvent)

func (*Analyzer) ReceiveSocketDataEvent

func (a *Analyzer) ReceiveSocketDataEvent(event *events.SocketDataUploadEvent)

func (*Analyzer) ReceiveSocketDetail

func (a *Analyzer) ReceiveSocketDetail(event *events.SocketDetailEvent)

func (*Analyzer) Start

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

func (*Analyzer) UpdateExtensionConfig

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

type ProtocolMetrics

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

func NewProtocolMetrics

func NewProtocolMetrics() *ProtocolMetrics

func (*ProtocolMetrics) FlushMetrics

func (m *ProtocolMetrics) FlushMetrics(traffic *base.ProcessTraffic, metricsBuilder *base.MetricsBuilder)

func (*ProtocolMetrics) GetProtocolMetrics

func (m *ProtocolMetrics) GetProtocolMetrics(p enums.ConnectionProtocol) protocol.Metrics

func (*ProtocolMetrics) MergeMetricsFromConnection

func (m *ProtocolMetrics) MergeMetricsFromConnection(connection *base.ConnectionContext, data base.ConnectionMetrics)