Documentation
¶
Index ¶
- Variables
- func ValidateReceiverConfig(config *Config) error
- func ValidateSensorConfig(config *Config) error
- type AuthConfig
- type Config
- type FileOutputConfig
- type InputConfig
- type KafkaOutputRawConfig
- type KafkaPluginConfig
- type OutputConfig
- type OutputRawConfig
- type PcapMode
- type PluginsConfig
- type PluginsRawConfig
- type RawConfig
- type S3OutputRawConfig
- type S3PluginConfig
- type SamplingRateConfig
- type ServerOutputConfig
- type TLSConfig
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNoInputConfigured = errors.New("no input configured") ErrNoPortConfiguredForInput = errors.New("no port configured for input") )
View Source
var ( ErrNoOutputConfigured = errors.New("no output configured") ErrNoPortConfiguredForServerOutput = errors.New("no port configured for server output") )
Functions ¶
func ValidateReceiverConfig ¶
func ValidateSensorConfig ¶
Types ¶
type AuthConfig ¶
type Config ¶
type Config struct { Input *InputConfig Output OutputConfig TLS TLSConfig Auth AuthConfig InputPacketLen int LogFilename string PcapMode PcapMode CapturePorts []int CaptureInterfacesPorts map[string][]int IgnorePorts []int SamplingRate SamplingRateConfig MaxEncodedLen int MaxGatherLen int MaxPayloadLen int MaxHeaderLen int MaxGatherWait time.Duration }
type FileOutputConfig ¶
type FileOutputConfig struct {
Path string
}
type InputConfig ¶
type KafkaOutputRawConfig ¶
type KafkaOutputRawConfig struct { Brokers string ClientId *string `yaml:"clientId,omitempty"` Topic *string `yaml:"topic,omitempty"` MessageSize *string `yaml:"messageSize,omitempty"` Acks *string `yaml:"acks,omitempty"` FileSize *string `yaml:"fileSize,omitempty"` Timeout time.Duration `yaml:"timeout,omitempty"` }
type KafkaPluginConfig ¶
type KafkaPluginConfig struct { Brokers []string ClientId string `yaml:"clientId,omitempty"` Topic string `yaml:"topic,omitempty"` MessageSize *bytesize.ByteSize `yaml:"messageSize,omitempty"` Acks string `yaml:"acks,omitempty"` FileSize *bytesize.ByteSize `yaml:"fileSize,omitempty"` Timeout time.Duration `yaml:"timeout,omitempty"` }
type OutputConfig ¶
type OutputConfig struct { File *FileOutputConfig Server *ServerOutputConfig Plugins *PluginsConfig }
type OutputRawConfig ¶
type OutputRawConfig struct { File *FileOutputConfig Server *ServerOutputConfig Plugins *PluginsRawConfig }
type PluginsConfig ¶
type PluginsConfig struct { S3 *S3PluginConfig Kafka *KafkaPluginConfig }
type PluginsRawConfig ¶
type PluginsRawConfig struct { S3 *S3OutputRawConfig Kafka *KafkaOutputRawConfig }
type RawConfig ¶
type RawConfig struct { Input *InputConfig Output *OutputRawConfig TLS TLSConfig Auth AuthConfig CompressBlockSize *int `yaml:"compressBlockSize,omitempty"` InputPacketLen *int `yaml:"inputPacketLen,omitempty"` GatherMaxWaitSec *int `yaml:"gatherMaxWaitSec,omitempty"` LogFilename string `yaml:"logFilename,omitempty"` PcapMode string `yaml:"pcapMode,omitempty"` CapturePorts []int `yaml:"capturePorts,omitempty"` CaptureInterfacesPorts map[string][]int `yaml:"captureInterfacesPorts,omitempty"` IgnorePorts []int `yaml:"ignorePorts,omitempty"` }
type S3OutputRawConfig ¶
type S3PluginConfig ¶
type S3PluginConfig struct { Region string Bucket string TotalFileSize *bytesize.ByteSize `yaml:"totalFileSize,omitempty"` UploadChunkSize *bytesize.ByteSize `yaml:"uploadChunkSize,omitempty"` UploadTimeout time.Duration `yaml:"uploadTimeout,omitempty"` CannedACL string `yaml:"cannedACL,omitempty"` }
type SamplingRateConfig ¶
type ServerOutputConfig ¶
Click to show internal directories.
Click to hide internal directories.