modules

type CollectorConfiguration struct {
	Integrations map[string]Integration `json:"integrations"`
}

type CollectorConfigurationOld struct {
	LogCollectorIsenabled bool                         `json:"log_collector_enabled"`
	Integrations          map[string]ProtocolListenOld `json:"integrations"`
}

type Integration struct {
	TCP Port `json:"tcp_port,omitempty"`
	UDP Port `json:"udp_port,omitempty"`
}

type Module interface {
	GetDataType() string
	IsPortListen(proto string) bool
	SetNewPort(proto string, port string)
	GetPort(proto string) string
	EnablePort(proto string)
	DisablePort(proto string)
}

type NetflowModule struct {
	DataType  string
	Parser    parser.Parser
	Decoders  map[string]*netflow.Decoder
	Listener  *net.UDPConn
	CTX       context.Context
	Cancel    context.CancelFunc
	IsEnabled bool
	// contains filtered or unexported fields
}

type Port struct {
	IsListen bool   `json:"enabled"`
	Port     string `json:"value"`
}

type ProtocolListenOld struct {
	Enabled bool   `json:"enabled"`
	UDP     string `json:"UDP,omitempty"`
	TCP     string `json:"TCP,omitempty"`
	TLS     string `json:"TLS,omitempty"`
}

type SyslogModule struct {
	DataType    string
	TCPListener listenerTCP
	UDPListener listenerUDP
	Parser      parser.Parser
	// contains filtered or unexported fields
}