base

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

type Metrics interface {
	base.ConnectionMetrics

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

type Protocol interface {
	Name() string
	GenerateMetrics() Metrics
	Init(config *profiling.TaskConfig)

	ReceiveData(context Context, event *SocketDataUploadEvent) bool
	UpdateExtensionConfig(config *profiling.ExtensionConfig)
}

type SkyWalkingTracingContext struct {
	TraceID0              string
	SegmentID0            string
	SpanID0               string
	ParentService         string
	ParentServiceInstance string
	ParentEndpoint        string
	AddressUsedAtClient   string
}

type SocketDataBuffer interface {
	// Combine from other buffer
	Combine(buffered SocketDataBuffer) SocketDataBuffer
	// BufferData of the buffer
	BufferData() []byte
	// TotalSize of socket data, the data may exceed the size of the BufferData()
	TotalSize() uint64
	// Direction of the data, send or receive
	Direction() base.SocketDataDirection
	FirstEvent() *SocketDataUploadEvent

	StartTime() uint64
	EndTime() uint64

	MinDataID() int
	MaxDataID() int
}

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

type SocketDataUploadEvent struct {
	Protocol     base.ConnectionProtocol
	MsgType      base.SocketMessageType
	Direction0   base.SocketDataDirection
	Finished     uint8
	Sequence     uint16
	DataLen      uint16
	StartTime0   uint64
	EndTime0     uint64
	ConnectionID uint64
	RandomID     uint64
	DataID       uint64
	TotalSize0   uint64
	Buffer       [2048]byte
}

type TraceContextProvider struct {
	Type v3.SpanAttachedEvent_SpanReferenceType
	Name string
}

type TracingContext interface {
	TraceID() string
	TraceSegmentID() string
	SpanID() string
	Provider() *TraceContextProvider
}

type ZipkinTracingContext struct {
	TraceID0 string
	SpanID0  string
}