| 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 © 2022. All rights reserved.