Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( RegexspBeats = map[config.DataType]string{ config.DataTypeApacheModule: `"type":"apache"|"module":"apache"`, config.DataTypeLinuxAuditdModule: `"type":"auditd"|"module":"auditd"`, config.DataTypeElasticsearchModule: `"type":"elasticsearch"|"module":"elasticsearch"`, config.DataTypeKafkaModule: `"type":"kafka"|"module":"kafka"`, config.DataTypeKibanaModule: `"type":"kibana"|"module":"kibana"`, config.DataTypeLogstashModule: `"type":"logstash"|"module":"logstash"`, config.DataTypeMongodbModule: `"type":"mongodb"|"module":"mongodb"`, config.DataTypeMysqlModule: `"type":"mysql"|"module":"mysql"`, config.DataTypeNginxModule: `"type":"nginx"|"module":"nginx"`, config.DataTypeOsqueryModule: `"type":"osquery"|"module":"osquery"`, config.DataTypePostgresqlModule: `"type":"postgresql"|"module":"postgresql"`, config.DataTypeRedisModule: `"type":"redis"|"module":"redis"`, config.DataTypeLinuxAgent: `"type":"system"|"module":"system"`, config.DataTypeIisModule: `"type":"iis"|"module":"iis"`, config.DataTypeTraefikModule: `"type":"traefik"|"module":"traefik"`, config.DataTypeNatsModule: `"type":"nats"|"module":"nats"`, config.DataTypeHaproxyModule: `"type":"haproxy"|"module":"haproxy"`, } )
Functions ¶
This section is empty.
Types ¶
type BeatsParser ¶
type BeatsParser struct{}
func GetBeatsParser ¶
func GetBeatsParser() *BeatsParser
func (*BeatsParser) IdentifySource ¶
func (p *BeatsParser) IdentifySource(log string) (config.DataType, error)
func (*BeatsParser) ProcessData ¶
func (p *BeatsParser) ProcessData(logMessage interface{}, datasource string, queue chan *plugins.Log) error
type CiscoParser ¶
type CiscoParser struct{}
func GetCiscoParser ¶
func GetCiscoParser() *CiscoParser
func (*CiscoParser) IdentifySource ¶
func (p *CiscoParser) IdentifySource(log string) (config.DataType, error)
func (*CiscoParser) ProcessData ¶
func (p *CiscoParser) ProcessData(logMessage interface{}, datasource string, queue chan *plugins.Log) error
type NetflowObject ¶
type NetflowParser ¶
type NetflowParser struct {
}
func GetNetflowParser ¶
func GetNetflowParser() *NetflowParser
func (*NetflowParser) ProcessData ¶
func (p *NetflowParser) ProcessData(logMessage interface{}, _ string, queue chan *plugins.Log) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.