tcpconnectanalyzer

Documentation

Index

• Constants
• func New(cfg interface{}, telemetry *component.TelemetryTools, ...) analyzer.Analyzer
• type Config
  • func NewDefaultConfig() *Config
• type TcpConnectAnalyzer
  • func (a *TcpConnectAnalyzer) ConsumableEvents() []string
  • func (a *TcpConnectAnalyzer) ConsumeEvent(event *model.KindlingEvent) error
  • func (a *TcpConnectAnalyzer) Shutdown() error
  • func (a *TcpConnectAnalyzer) Start() error
  • func (a *TcpConnectAnalyzer) Type() analyzer.Type

Constants

const Type analyzer.Type = "tcpconnectanalyzer"

Functions

func New

func New(cfg interface{}, telemetry *component.TelemetryTools, consumers []consumer.Consumer) analyzer.Analyzer

Types

type Config

type Config struct {
	ChannelSize     int  `mapstructure:"channel_size"`
	WaitEventSecond int  `mapstructure:"wait_event_second"`
	NeedProcessInfo bool `mapstructure:"need_process_info"`
}

func NewDefaultConfig

func NewDefaultConfig() *Config

type TcpConnectAnalyzer

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

func (*TcpConnectAnalyzer) ConsumableEvents

func (a *TcpConnectAnalyzer) ConsumableEvents() []string

func (*TcpConnectAnalyzer) ConsumeEvent

func (a *TcpConnectAnalyzer) ConsumeEvent(event *model.KindlingEvent) error

ConsumeEvent gets the event from the previous component

func (*TcpConnectAnalyzer) Shutdown

func (a *TcpConnectAnalyzer) Shutdown() error

Shutdown cleans all the resources used by the analyzer

func (*TcpConnectAnalyzer) Start

func (a *TcpConnectAnalyzer) Start() error

Start initializes the analyzer

func (*TcpConnectAnalyzer) Type

func (a *TcpConnectAnalyzer) Type() analyzer.Type

Type returns the type of the analyzer