| 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.