forwarder

Jan 17, 2024

Changes in this version

type Base

+ func (b *Base) Config() Config

+ func (b *Base) ReceiveChannel() <-chan *snmp.Message

type Forwarder

+ Config func() Config

+ ReceiveChannel func() <-chan *snmp.Message

Dec 21, 2023

Changes in this version

type Config

+ HTTP *HTTPConfig

type Forwarder

+ func NewHTTP(c Config, idx int) Forwarder

+ type HTTP struct

+ func (h *HTTP) Run()

+ type HTTPBasicAuth struct

+ Password string

+ Username string

+ type HTTPConfig struct

+ BasicAuth *HTTPBasicAuth

+ Headers map[string][]string

+ Method HTTPMethod

+ Proxy string

+ Timeout Duration

+ Tls *Tls

+ URL string

+ type HTTPMethod int

+ const HTTPMethodGet

+ const HTTPMethodPost

+ const HTTPMethodPut

+ func (h *HTTPMethod) String() string

+ func (h *HTTPMethod) UnmarshalText(text []byte) error

+ type Tls struct

+ CaCert string

+ ClientCert string

+ ClientKey string

+ InsecureSkipVerify bool

Dec 15, 2023

Changes in this version

type KafkaConfig

+ BatchSize int

+ BatchTimeout Duration

+ Sasl *KafkaSasl

+ Tls *KafkaTls

+ type KafkaSasl struct

+ Mechanism KafkaSaslMechanism

+ Password string

+ Username string

+ type KafkaSaslMechanism int

+ const KafkaSaslPlain

+ const KafkaSaslSha256

+ const KafkaSaslSha512

+ func (k *KafkaSaslMechanism) String() string

+ func (k *KafkaSaslMechanism) UnmarshalText(text []byte) error

+ type KafkaTls struct

+ CaCert string

+ ClientCert string

+ ClientKey string

+ InsecureSkipVerify bool

Jul 12, 2023

Changes in this version

+ type AutoRetry struct

+ Enable bool

+ MaxDelay Duration

+ MaxRetries int

+ MinDelay Duration

type Base

+ CompilerConf snmp.MessageCompiler

+ func (b *Base) Get() (*snmp.Message, error)

+ func (b *Base) Retry(message *snmp.Message, err error)

+ type Cmd struct

+ Commands []string

+ Message *snmp.Message

type Config

+ AutoRetry AutoRetry

+ Mock *MockConfig

+ ShutdownWaitTime Duration

type Forwarder

+ func NewMock(c Config, idx int) Forwarder

+ type Mock struct

+ func (m *Mock) Run()

+ type MockConfig struct

+ OutChannel chan *snmp.Message

+ Timeout Duration

Jul 7, 2023

Changes in this version

+ func StartForwarders(wg *sync.WaitGroup, c []Config, messageChan <-chan snmp.Message)

+ type Base struct

+ func NewBase(c Config, idx int) Base

+ func (b *Base) Close()

+ func (b *Base) Done() <-chan struct{}

+ func (b *Base) Send(message snmp.Message)

+ type Config struct

+ AgentAddressObjectPrefix string

+ File *FileConfig

+ Filter string

+ ID string

+ JSONFormat string

+ Kafka *KafkaConfig

+ MQTT *MQTTConfig

+ QueueSize uint

+ TimeAsTimezone string

+ TimeFormat string

+ Trap *SNMPTrapConfig

+ ValueJSONFormat string

+ ValueJSONIsFlat bool

+ ZabbixTrapper *ZabbixTrapperConfig

+ func (c *Config) Type() string

+ type Duration struct

+ func (d *Duration) UnmarshalText(b []byte) error

+ func (d Duration) MarshalJSON() ([]byte, error)

+ type File struct

+ func (f *File) Run()

+ type FileConfig struct

+ Path string

+ type Forwarder interface

+ Close func()

+ Done func() <-chan struct{}

+ Send func(message snmp.Message)

+ func NewFile(c Config, idx int) Forwarder

+ func NewKafka(c Config, idx int) Forwarder

+ func NewMQTT(c Config, idx int) Forwarder

+ func NewSNMPTrap(c Config, idx int) Forwarder

+ func NewZabbixTrapper(c Config, idx int) Forwarder

+ type Kafka struct

+ func (k *Kafka) Run()

+ type KafkaConfig struct

+ Hosts []string

+ KeyField string

+ RequiredAcks kafka.RequiredAcks

+ Topic string

+ type LookupResult struct

+ Hostname string

+ Server *ProxyConf

+ type LookupStrategy int8

+ const LookupFromAgentAddress

+ const LookupFromOID

+ const LookupFromSourceAddress

+ func (l *LookupStrategy) String() string

+ func (l *LookupStrategy) UnmarshalText(text []byte) error

+ type MQTT struct

+ func (m *MQTT) Run()

+ type MQTTConfig struct

+ ClientID string

+ Hosts []string

+ Ordered *bool

+ Password string

+ Qos uint8

+ TLS *TlsConfig

+ Topic string

+ Username string

+ type ProxyConf struct

+ Address string

+ Hostname string

+ Port int

+ type QueryResult struct

+ Hostname string

+ IPOrDNS string

+ ProxyHostname sql.NullString

+ type SNMPTrap struct

+ func (s *SNMPTrap) Run()

+ type SNMPTrapConfig struct

+ Community string

+ Context string

+ EnableInform bool

+ Host string

+ User snmp.User

+ Version string

+ Workers int

+ type TlsConfig struct

+ InsecureSkipVerify bool

+ type ZSAdvancedConfig struct

+ DBQueryTimeout Duration

+ DBRefreshInterval Duration

+ DBUrl string

+ Proxies []ProxyConf

+ func (z *ZSAdvancedConfig) GetDSN() (string, string, error)

+ type ZabbixLookup struct

+ func NewZabbixLookup(c *ZabbixTrapperConfig, logger zerolog.Logger, ctx context.Context) *ZabbixLookup

+ func (z *ZabbixLookup) Lookup(m snmp.Message, strategy LookupStrategy) (LookupResult, error)

+ func (z *ZabbixLookup) Refresh()

+ type ZabbixTrapper struct

+ func (z *ZabbixTrapper) Run()

+ type ZabbixTrapperConfig struct

+ Advanced *ZSAdvancedConfig

+ DefaultAddress string

+ DefaultHostname string

+ DefaultPort int

+ HostnameLookupStrategy LookupStrategy

+ ItemKey string

+ OIDLookup string