base

package

Go to main page

Versions in this module

v0

v0.7.0

Oct 10, 2024

v0.6.0

Mar 19, 2024

v0.5.0

Jun 14, 2023

Changes in this version

+ var ErrNotComplete = errors.New("socket: not complete event")

+ type Buffer struct

+ func CombineSlices(validated bool, buffers ...*Buffer) *Buffer

+ func (r *Buffer) Details() *list.List

+ func (r *Buffer) DetectNotSendingLastPosition() *BufferPosition

+ func (r *Buffer) FindFirstDataBuffer(dataID uint64) SocketDataBuffer

+ func (r *Buffer) FirstSocketBuffer() SocketDataBuffer

+ func (r *Buffer) IsCurrentPacketReadFinished() bool

+ func (r *Buffer) LastSocketBuffer() SocketDataBuffer

+ func (r *Buffer) Len() int

+ func (r *Buffer) OffsetPosition(offset int) *BufferPosition

+ func (r *Buffer) Peek(p []byte) (n int, err error)

+ func (r *Buffer) Position() *BufferPosition

+ func (r *Buffer) Read(p []byte) (n int, err error)

+ func (r *Buffer) Slice(validated bool, start, end *BufferPosition) *Buffer

+ type BufferPosition struct

+ func (p *BufferPosition) Clone() *BufferPosition

+ func (p *BufferPosition) String() string

+ type ParseResult int

+ const ParseResultSkipPackage

+ const ParseResultSuccess

type Protocol

+ PackageMaxExpireDuration func() time.Duration

+ ParseProtocol func(connectionID uint64, metrics Metrics, reader *Buffer) ParseResult

+ Protocol func() base.ConnectionProtocol

+ type ProtocolAnalyzer struct

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

+ func (a *ProtocolAnalyzer) ReceiveSocketCloseEvent(event *base.SocketCloseEvent)

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

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

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

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

type SocketDataBuffer

+ BufferLen func() int

+ BufferStartPosition func() int

+ DataID func() uint64

+ DataSequence func() int

+ GenerateConnectionID func() string

+ HaveReduceDataAfterChunk func() bool

+ IsFinished func() bool

+ IsStart func() bool

+ type SocketDataEventLimited struct

+ func (s *SocketDataEventLimited) BufferData() []byte

+ func (s *SocketDataEventLimited) BufferLen() int

+ func (s *SocketDataEventLimited) BufferStartPosition() int

type SocketDataUploadEvent

+ DataID0 uint64

+ HaveReduce uint8

+ Sequence0 uint16

+ func (s *SocketDataUploadEvent) BufferLen() int

+ func (s *SocketDataUploadEvent) BufferStartPosition() int

+ func (s *SocketDataUploadEvent) DataSequence() int

+ func (s *SocketDataUploadEvent) HaveReduceDataAfterChunk() bool

+ type SocketDetailEvent struct

+ ConnectionID uint64

+ DataID uint64

+ FuncName base.SocketFunctionName

+ IfIndex uint32

+ PackageCount uint8

+ Protocol base.ConnectionProtocol

+ RTTCount uint8

+ RTTTime uint32

+ RandomID uint64

+ TotalPackageSize uint64

+ func (s *SocketDetailEvent) GenerateConnectionID() string

v0.4.0

Dec 9, 2022

Changes in this version

+ type Context interface

+ QueryConnection func(connectionID, randomID uint64) *base.ConnectionContext

+ QueryProtocolMetrics func(conMetrics *base.ConnectionMetricsContext, protocolName string) Metrics

+ type Metrics interface

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

+ type Protocol interface

+ GenerateMetrics func() Metrics

+ Init func(config *profiling.TaskConfig)

+ Name func() string

+ ReceiveData func(context Context, event *SocketDataUploadEvent) bool

+ UpdateExtensionConfig func(config *profiling.ExtensionConfig)

+ type SkyWalkingTracingContext struct

+ AddressUsedAtClient string

+ ParentEndpoint string

+ ParentService string

+ ParentServiceInstance string

+ SegmentID0 string

+ SpanID0 string

+ TraceID0 string

+ func (w *SkyWalkingTracingContext) Provider() *TraceContextProvider

+ func (w *SkyWalkingTracingContext) SpanID() string

+ func (w *SkyWalkingTracingContext) TraceID() string

+ func (w *SkyWalkingTracingContext) TraceSegmentID() string

+ type SocketDataBuffer interface

+ BufferData func() []byte

+ Combine func(buffered SocketDataBuffer) SocketDataBuffer

+ Direction func() base.SocketDataDirection

+ EndTime func() uint64

+ FirstEvent func() *SocketDataUploadEvent

+ MaxDataID func() int

+ MinDataID func() int

+ StartTime func() uint64

+ TotalSize func() uint64

+ type SocketDataUploadCombinedEvent struct

+ func (s *SocketDataUploadCombinedEvent) BufferData() []byte

+ func (s *SocketDataUploadCombinedEvent) Combine(other SocketDataBuffer) SocketDataBuffer

+ func (s *SocketDataUploadCombinedEvent) Direction() base.SocketDataDirection

+ func (s *SocketDataUploadCombinedEvent) EndTime() uint64

+ func (s *SocketDataUploadCombinedEvent) FirstEvent() *SocketDataUploadEvent

+ func (s *SocketDataUploadCombinedEvent) MaxDataID() int

+ func (s *SocketDataUploadCombinedEvent) MinDataID() int

+ func (s *SocketDataUploadCombinedEvent) StartTime() uint64

+ func (s *SocketDataUploadCombinedEvent) TotalSize() uint64

+ type SocketDataUploadEvent struct

+ Buffer [2048]byte

+ ConnectionID uint64

+ DataID uint64

+ DataLen uint16

+ Direction0 base.SocketDataDirection

+ EndTime0 uint64

+ Finished uint8

+ MsgType base.SocketMessageType

+ Protocol base.ConnectionProtocol

+ RandomID uint64

+ Sequence uint16

+ StartTime0 uint64

+ TotalSize0 uint64

+ func (s *SocketDataUploadEvent) BufferData() []byte

+ func (s *SocketDataUploadEvent) Combine(other SocketDataBuffer) SocketDataBuffer

+ func (s *SocketDataUploadEvent) Direction() base.SocketDataDirection

+ func (s *SocketDataUploadEvent) EndTime() uint64

+ func (s *SocketDataUploadEvent) FirstEvent() *SocketDataUploadEvent

+ func (s *SocketDataUploadEvent) GenerateConnectionID() string

+ func (s *SocketDataUploadEvent) IsFinished() bool

+ func (s *SocketDataUploadEvent) IsStart() bool

+ func (s *SocketDataUploadEvent) MaxDataID() int

+ func (s *SocketDataUploadEvent) MinDataID() int

+ func (s *SocketDataUploadEvent) StartTime() uint64

+ func (s *SocketDataUploadEvent) TotalSize() uint64

+ type TraceContextProvider struct

+ Name string

+ Type v3.SpanAttachedEvent_SpanReferenceType

+ type TracingContext interface

+ Provider func() *TraceContextProvider

+ SpanID func() string

+ TraceID func() string

+ TraceSegmentID func() string

+ func AnalyzeTracingContext(fetcher func(key string) string) (TracingContext, error)

+ type ZipkinTracingContext struct

+ SpanID0 string

+ TraceID0 string

+ func (w *ZipkinTracingContext) Provider() *TraceContextProvider

+ func (w *ZipkinTracingContext) SpanID() string

+ func (w *ZipkinTracingContext) TraceID() string

+ func (w *ZipkinTracingContext) TraceSegmentID() string

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