layer7

Documentation

Index

• Constants
• Variables
• type Listener
  • func NewListener(analyzer *base.AnalyzerContext) *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 enums.ConnectionProtocol) protocol.Metrics
  • func (l *Listener) ReceiveCloseConnection(ctx *base.ConnectionContext, event *events.SocketCloseEvent)
  • func (l *Listener) ReceiveNewConnection(ctx *base.ConnectionContext, event *events.SocketConnectEvent)
  • func (l *Listener) RegisterBPFEvents(ctx context.Context, bpfLoader *bpf.Loader)
  • func (l *Listener) UpdateExtensionConfig(config *profiling.ExtensionConfig)
• type SocketDataPartitionContext
  • func NewSocketDataPartitionContext(l base.Context, config *profiling.TaskConfig) *SocketDataPartitionContext
  • func (p *SocketDataPartitionContext) Consume(data interface{})
  • func (p *SocketDataPartitionContext) Start(ctx context.Context)

Constants

const (
	ConnectionCachedTTL      = time.Minute
	ConnectionCacheFlushTime = time.Second * 20
)

Variables

var ListenerName = "layer7"

Types

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) Init

func (l *Listener) Init(config *profiling.TaskConfig, moduleManager *module.Manager) error

func (*Listener) Name

func (l *Listener) Name() string

func (*Listener) PostFlushConnectionMetrics

func (l *Listener) PostFlushConnectionMetrics(ccs []*base.ConnectionContext)

func (*Listener) PreFlushConnectionMetrics

func (l *Listener) PreFlushConnectionMetrics(ccs []*base.ConnectionWithBPF, bpfLoader *bpf.Loader) error

func (*Listener) QueryConnection

func (l *Listener) QueryConnection(conID, randomID uint64) *base.ConnectionContext

func (*Listener) QueryProtocolMetrics

func (l *Listener) QueryProtocolMetrics(conMetrics *base.ConnectionMetricsContext, p enums.ConnectionProtocol) protocol.Metrics

func (*Listener) ReceiveCloseConnection

func (l *Listener) ReceiveCloseConnection(ctx *base.ConnectionContext, event *events.SocketCloseEvent)

func (*Listener) ReceiveNewConnection

func (l *Listener) ReceiveNewConnection(ctx *base.ConnectionContext, event *events.SocketConnectEvent)

func (*Listener) RegisterBPFEvents

func (l *Listener) RegisterBPFEvents(ctx context.Context, bpfLoader *bpf.Loader)

func (*Listener) UpdateExtensionConfig

func (l *Listener) UpdateExtensionConfig(config *profiling.ExtensionConfig)

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

func (p *SocketDataPartitionContext) Start(ctx context.Context)