Documentation
¶
Index ¶
- func UpdateSinkManagerConfig(manager *sink.SinkManager, conf []SinkSourceConfig)
- func UpdateSourceManagerConfig(manager *source.SourceManager, conf []SinkSourceConfig)
- func ValidateSinkConfigs(conf []SinkSourceConfig) error
- func ValidateSourceConfigs(conf []SinkSourceConfig) error
- type Config
- type SinkSourceConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func UpdateSinkManagerConfig ¶
func UpdateSinkManagerConfig(manager *sink.SinkManager, conf []SinkSourceConfig)
func UpdateSourceManagerConfig ¶
func UpdateSourceManagerConfig(manager *source.SourceManager, conf []SinkSourceConfig)
func ValidateSinkConfigs ¶
func ValidateSinkConfigs(conf []SinkSourceConfig) error
func ValidateSourceConfigs ¶
func ValidateSourceConfigs(conf []SinkSourceConfig) error
Types ¶
type Config ¶
type Config struct {
QueueSize int `yaml:"queue-size" validate:"required"`
SinkQueueSize int `yaml:"sink-queue-size" validate:"required"`
LogLevel string `yaml:"log-level"` // TODO: build validator
LogFormat string `yaml:"log-format" validate:"in:console,json"`
Interface string `yaml:"interface" validate:"required|ip"`
Port int `yaml:"port" validate:"required"`
Sources []SinkSourceConfig `yaml:"sources"`
Sinks []SinkSourceConfig `yaml:"sinks"`
}
func LoadConfig ¶
Click to show internal directories.
Click to hide internal directories.