Documentation
¶
Index ¶
- Constants
- Variables
- type EventQueue
- type Listener
- func (l *Listener) FlushMetrics(traffics []*base.ProcessTraffic, builder *base.MetricsBuilder)
- func (l *Listener) GenerateMetrics() base.ConnectionMetrics
- func (l *Listener) Init(config *profiling.TaskConfig, moduleManager *module.Manager) error
- func (l *Listener) Name() string
- func (l *Listener) PostFlushConnectionMetrics(ccs []*base.ConnectionContext)
- func (l *Listener) PreFlushConnectionMetrics(ccs []*base.ConnectionWithBPF, bpfLoader *bpf.Loader) error
- func (l *Listener) QueryConnection(conID, randomID uint64) *base.ConnectionContext
- func (l *Listener) QueryProtocolMetrics(conMetrics *base.ConnectionMetricsContext, p base.ConnectionProtocol) protocol.Metrics
- func (l *Listener) ReceiveCloseConnection(ctx *base.ConnectionContext, event *base.SocketCloseEvent)
- func (l *Listener) ReceiveNewConnection(ctx *base.ConnectionContext, event *base.SocketConnectEvent)
- func (l *Listener) RegisterBPFEvents(ctx context.Context, bpfLoader *bpf.Loader)
- func (l *Listener) UpdateExtensionConfig(config *profiling.ExtensionConfig)
- type PartitionContext
- type SocketDataPartitionContext
Constants ¶
View Source
const ( ConnectionCachedTTL = time.Minute ConnectionCacheFlushTime = time.Second * 20 )
Variables ¶
View Source
var ListenerName = "layer7"
Functions ¶
This section is empty.
Types ¶
type EventQueue ¶
type EventQueue struct {
// contains filtered or unexported fields
}
func NewEventQueue ¶
func NewEventQueue(partitionCount, sizePerPartition int, contextGenerator func() PartitionContext) *EventQueue
func (*EventQueue) Push ¶
func (e *EventQueue) Push(key string, data interface{})
func (*EventQueue) RegisterReceiver ¶ added in v0.5.0
func (e *EventQueue) RegisterReceiver(emap *ebpf.Map, perCPUBufferSize int, dataSupplier func() interface{}, routeGenerator func(data interface{}) string)
type Listener ¶
type Listener struct {
// contains filtered or unexported fields
}
func NewListener ¶
func NewListener(analyzer *base.AnalyzerContext) *Listener
func (*Listener) FlushMetrics ¶
func (l *Listener) FlushMetrics(traffics []*base.ProcessTraffic, builder *base.MetricsBuilder)
func (*Listener) GenerateMetrics ¶
func (l *Listener) GenerateMetrics() base.ConnectionMetrics
func (*Listener) PostFlushConnectionMetrics ¶
func (l *Listener) PostFlushConnectionMetrics(ccs []*base.ConnectionContext)
func (*Listener) PreFlushConnectionMetrics ¶
func (*Listener) QueryConnection ¶
func (l *Listener) QueryConnection(conID, randomID uint64) *base.ConnectionContext
func (*Listener) QueryProtocolMetrics ¶
func (l *Listener) QueryProtocolMetrics(conMetrics *base.ConnectionMetricsContext, p base.ConnectionProtocol) protocol.Metrics
func (*Listener) ReceiveCloseConnection ¶
func (l *Listener) ReceiveCloseConnection(ctx *base.ConnectionContext, event *base.SocketCloseEvent)
func (*Listener) ReceiveNewConnection ¶
func (l *Listener) ReceiveNewConnection(ctx *base.ConnectionContext, event *base.SocketConnectEvent)
func (*Listener) RegisterBPFEvents ¶
func (*Listener) UpdateExtensionConfig ¶
func (l *Listener) UpdateExtensionConfig(config *profiling.ExtensionConfig)
type PartitionContext ¶
type SocketDataPartitionContext ¶
type SocketDataPartitionContext struct {
// contains filtered or unexported fields
}
func NewSocketDataPartitionContext ¶
func NewSocketDataPartitionContext(l base.Context, config *profiling.TaskConfig) *SocketDataPartitionContext
func (*SocketDataPartitionContext) Consume ¶
func (p *SocketDataPartitionContext) Consume(data interface{})
func (*SocketDataPartitionContext) Start ¶ added in v0.5.0
func (p *SocketDataPartitionContext) Start(ctx context.Context)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.