protocols

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 {
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL