forwarder

type Base struct {
	CompilerConf snmp.MessageCompiler
	// contains filtered or unexported fields
}

type Cmd struct {
	Commands []string
	Message  *snmp.Message
}

type Config struct {
	// ID identifies forwarder name, also used for prometheus labelling
	ID string
	// QueueSize defines the size of queue of each forwarder, when queue is full (might be caused
	// by slow forwarder) the message is dropped
	QueueSize int `mapstructure:"queue_size"`
	// TimeFormat specifies golang time format for casting time related fields to string
	TimeFormat string `mapstructure:"time_format"`
	// TimeAsTimezone will cast any time field to specified timezone
	TimeAsTimezone   string          `mapstructure:"time_as_timezone"`
	ShutdownWaitTime helper.Duration `mapstructure:"shutdown_wait_time"`
	// Filter, JSONFormat utilizes antonmedv/expr expressions
	Filter        string
	JSONFormat    string           `mapstructure:"json_format"`
	AutoRetry     helper.AutoRetry `mapstructure:"auto_retry"`
	Mock          *MockConfig
	File          *FileConfig
	Kafka         *KafkaConfig
	MQTT          *MQTTConfig
	Trap          *SNMPTrapConfig
	HTTP          *HTTPConfig
	ZabbixTrapper *ZabbixTrapperConfig `mapstructure:"zabbix_trapper"`
}

type File struct {
	Base
}

type FileConfig struct {
	// Path for json log. Make sure the user has sufficient permission to write
	Path string
}

type Forwarder interface {
	// Send will send the trap message to its corresponding forwarder.
	// Does nothing if the queue buffer is full or forwarder is already closed
	Send(*snmp.Message)
	// ReceiveChannel is used inside the forwarder to receive data
	// from SendChannel
	ReceiveChannel() <-chan *snmp.Message
	// Close informs the forwarder to stop processing any new messages
	Close()
	// Done informs the caller if forwarder is done processing
	Done() <-chan struct{}
	// Config returns the forwarder config
	Config() Config
}

type HTTP struct {
	Base
	// contains filtered or unexported fields
}

type HTTPBasicAuth struct {
	Username string
	Password string
}

type HTTPConfig struct {
	URL       string `mapstructure:"url"`
	Method    HTTPMethod
	Headers   map[string][]string
	BasicAuth *HTTPBasicAuth `mapstructure:"basic_auth"`
	Tls       *Tls
	Proxy     string
	Timeout   helper.Duration
}

type HTTPMethod int

type Kafka struct {
	Base
	// contains filtered or unexported fields
}

type KafkaConfig struct {
	RequiredAcks kafka.RequiredAcks `mapstructure:"required_acks"`
	KeyField     string             `mapstructure:"key_field"`
	Hosts        []string
	Topic        string
	Tls          *Tls
	Sasl         *KafkaSasl
	BatchSize    int             `mapstructure:"batch_size"`
	BatchTimeout helper.Duration `mapstructure:"batch_timeout"`
}

type KafkaSasl struct {
	Username  string
	Password  string
	Mechanism KafkaSaslMechanism
}

type KafkaSaslMechanism int

type LookupResult struct {
	Server   *ProxyConf
	Hostname string
}

type LookupStrategy int8

type MQTT struct {
	Base
}

type MQTTConfig struct {
	Hosts    []string
	ClientID string `mapstructure:"client_id"`
	Username string
	Password string
	Ordered  *bool
	TLS      *TlsConfig
	Topic    string
	Qos      uint8
}

type Mock struct {
	Base
}

type MockConfig struct {
	OutChannel chan *snmp.Message
	Timeout    helper.Duration
}

type ProxyConf struct {
	Hostname string
	Address  string
	Port     int
}

type QueryResult struct {
	IPOrDNS       string         `db:"ip_or_dns"`
	Hostname      string         `db:"hostname"`
	ProxyHostname sql.NullString `db:"proxy_hostname"`
}

type SNMPTrap struct {
	Base
	// contains filtered or unexported fields
}

type SNMPTrapConfig struct {
	Workers      int
	EnableInform bool `mapstructure:"enable_inform"`
	Host         string
	Version      string
	Community    string
	Context      string
	User         snmp.User
}

type Tls struct {
	InsecureSkipVerify bool   `mapstructure:"insecure_skip_verify"`
	CaCert             string `mapstructure:"ca_cert"`
	ClientCert         string `mapstructure:"client_cert"`
	ClientKey          string `mapstructure:"client_key"`
}

type TlsConfig struct {
	InsecureSkipVerify bool `mapstructure:"insecure_skip_verify"`
}

type ZSAdvancedConfig struct {
	Proxies []ProxyConf

	// for example:
	// - postgres://user:pass@127.0.0.1:5432/dbname?param1=value1&param2=value2
	// - mysql://user:pass@127.0.0.1:3306/dbname?param1=value1&param2=value2
	DBUrl             string          `mapstructure:"db_url"`
	DBRefreshInterval helper.Duration `mapstructure:"db_refresh_interval"`
	DBQueryTimeout    helper.Duration `mapstructure:"db_query_timeout"`
	// contains filtered or unexported fields
}

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

type ZabbixTrapper struct {
	Base
	// contains filtered or unexported fields
}

type ZabbixTrapperConfig struct {
	// default_* is used whenever host lookup fails:
	// - no advanced config defined
	// - proxy is defined in zabbix, but not defined in configuration
	// - can't find monitored hostname
	// - lookup strategy fails
	// DefaultAddress and DefaultPort are also used in case the host
	// is monitored directly with zabbix server and zabbix server
	// is not configured as HA
	DefaultAddress         string         `mapstructure:"default_address"`
	DefaultPort            int            `mapstructure:"default_port"`
	DefaultHostname        string         `mapstructure:"default_hostname"`
	ItemKey                string         `mapstructure:"item_key"`
	HostnameLookupStrategy LookupStrategy `mapstructure:"hostname_lookup_strategy"`
	OIDLookup              string         `mapstructure:"oid_lookup"`
	// Advanced config is for systems with proxies setup
	Advanced *ZSAdvancedConfig
}