Modifier and Type | Method and Description |
---|---|
AsyncDispatcher<TelemetryMessage> |
TelemetryRegistry.getDispatcher(String queueName) |
Collection<AsyncDispatcher<TelemetryMessage>> |
TelemetryRegistry.getDispatchers() |
Modifier and Type | Method and Description |
---|---|
void |
TelemetryRegistry.registerDispatcher(String queueName,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Modifier and Type | Method and Description |
---|---|
TelemetryMessage |
TelemetrySinkModule.unmarshalSingleMessage(byte[] message) |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<TelemetryMessage,TelemetryProtos.TelemetryMessageLog,TelemetryProtos.TelemetryMessageLog.Builder> |
TelemetrySinkModule.getAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
byte[] |
TelemetrySinkModule.marshalSingleMessage(TelemetryMessage message) |
Modifier and Type | Method and Description |
---|---|
SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog> |
TelemetryMessageConsumer.getModule() |
Constructor and Description |
---|
BmpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
DnsResolver dnsResolver,
io.github.resilience4j.bulkhead.Bulkhead bulkhead,
com.codahale.metrics.MetricRegistry metricRegistry) |
Constructor and Description |
---|
ForwardParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Constructor and Description |
---|
IpfixTcpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
IpfixUdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
Netflow5UdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
Netflow9UdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
ParserBase(Protocol protocol,
String name,
MessageBuilder messageBuilder,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
UdpParserBase(Protocol protocol,
String name,
MessageBuilder messageBuilder,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
Constructor and Description |
---|
OpenConfigConnector(AsyncDispatcher<TelemetryMessage> dispatcher,
OpenConfigClientFactory clientFactory) |
Modifier and Type | Method and Description |
---|---|
AsyncDispatcher<TelemetryMessage> |
TelemetryRegistryImpl.getDispatcher(String queueName) |
Collection<AsyncDispatcher<TelemetryMessage>> |
TelemetryRegistryImpl.getDispatchers() |
Modifier and Type | Method and Description |
---|---|
void |
TelemetryRegistryImpl.registerDispatcher(String queueName,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Constructor and Description |
---|
SFlowUdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
DnsResolver dnsResolver) |
Copyright © 2021. All rights reserved.