Documentation
¶
Index ¶
Constants ¶
const TCPIpfixParser = "IpfixUdpParser"
TCPIpfixParser represents the TCP IPFIX parser name
const UDPForwardParser = "ForwardParser"
UDPForwardParser represents org.opennms.netmgt.telemetry.protocols.common.parser.ForwardParser
const UDPIpfixParser = "IpfixUdpParser"
UDPIpfixParser represents the UDP IPFIX parser name
const UDPNetflow5Parser = "Netflow5UdpParser"
UDPNetflow5Parser represents the UDP Netflow5 parser name
const UDPNetflow9Parser = "Netflow9UdpParser"
UDPNetflow9Parser represents the UDP Netflow9 parser name
const UDPSFlowParser = "SFlowUdpParser"
UDPSFlowParser represents the UDP SFlow parser name
Variables ¶
This section is empty.
Functions ¶
func CreateSinkRegistry ¶ added in v0.1.2
func CreateSinkRegistry() *api.SinkRegistry
CreateSinkRegistry creates a new Sink registry with all the available implementations
Types ¶
type HeartbeatModule ¶
type HeartbeatModule struct{}
HeartbeatModule represents the heartbeat module
func (*HeartbeatModule) GetID ¶
func (module *HeartbeatModule) GetID() string
GetID gets the ID of the sink module
func (*HeartbeatModule) Start ¶
func (module *HeartbeatModule) Start(config *api.MinionConfig, sink api.Sink) error
Start initiates a blocking loop that sends heartbeats to OpenNMS
type NetflowModule ¶
type NetflowModule struct {
// contains filtered or unexported fields
}
NetflowModule represents a generic UDP forward module It starts a UDP Listener, and forwards the received data to OpenNMS without alteration
func (*NetflowModule) GetID ¶
func (module *NetflowModule) GetID() string
GetID gets the ID of the sink module
func (*NetflowModule) Publish ¶
func (module *NetflowModule) Publish(msgs []*goflowMsg.FlowMessage)
Publish represents the Transport interface implementation used by goflow
func (*NetflowModule) Start ¶
func (module *NetflowModule) Start(config *api.MinionConfig, sink api.Sink) error
Start initiates a Netflow UDP receiver
type NxosGrpcModule ¶
type NxosGrpcModule struct {
mdt_dialout.UnimplementedGRPCMdtDialoutServer
// contains filtered or unexported fields
}
NxosGrpcModule represents the Cisco Nexus NX-OS Telemetry module via gRPC
func (*NxosGrpcModule) GetID ¶
func (module *NxosGrpcModule) GetID() string
GetID gets the ID of the sink module
func (*NxosGrpcModule) MdtDialout ¶
func (module *NxosGrpcModule) MdtDialout(stream mdt_dialout.GRPCMdtDialout_MdtDialoutServer) error
MdtDialout implements Cisco NX-OS streaming telemetry service
func (*NxosGrpcModule) Start ¶
func (module *NxosGrpcModule) Start(config *api.MinionConfig, sink api.Sink) error
Start initiates a gRPC Server for NX-OS telemetry
type SnmpTrapModule ¶
type SnmpTrapModule struct {
// contains filtered or unexported fields
}
SnmpTrapModule represents the SNMP trap receiver module
func (*SnmpTrapModule) GetID ¶
func (module *SnmpTrapModule) GetID() string
GetID gets the ID of the sink module
func (*SnmpTrapModule) Start ¶
func (module *SnmpTrapModule) Start(config *api.MinionConfig, sink api.Sink) error
Start initiates a Syslog UDP and TCP receiver
type SyslogModule ¶
type SyslogModule struct {
// contains filtered or unexported fields
}
SyslogModule represents the heartbeat module
func (*SyslogModule) GetID ¶
func (module *SyslogModule) GetID() string
GetID gets the ID of the sink module
func (*SyslogModule) Start ¶
func (module *SyslogModule) Start(config *api.MinionConfig, sink api.Sink) error
Start initiates a Syslog UDP and TCP receiver
type UDPForwardModule ¶
type UDPForwardModule struct {
// contains filtered or unexported fields
}
UDPForwardModule represents a generic UDP forward module It starts a UDP Listener, and forwards the received data to OpenNMS without alteration
func (*UDPForwardModule) GetID ¶
func (module *UDPForwardModule) GetID() string
GetID gets the ID of the sink module
func (*UDPForwardModule) Start ¶
func (module *UDPForwardModule) Start(config *api.MinionConfig, sink api.Sink) error
Start initiates a generic UDP receiver
func (*UDPForwardModule) Stop ¶
func (module *UDPForwardModule) Stop()
Stop shutdowns the sink module
Source Files