| 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 |
|---|
ForwardParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
| Constructor and Description |
|---|
IpfixTcpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
IpfixUdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Netflow5UdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Netflow9UdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
ParserBase(Protocol protocol,
String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
UdpParserBase(Protocol protocol,
String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
| 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) |
Copyright © 2019. All rights reserved.