Uses of Interface
org.opennms.core.ipc.sink.api.AggregationPolicy
-
-
Uses of AggregationPolicy in org.opennms.core.ipc.sink.aggregation
Classes in org.opennms.core.ipc.sink.aggregation that implement AggregationPolicy Modifier and Type Class Description class
ArrayListAggregationPolicy<S>
An aggregation policy that createsArrayList
aggregates.class
IdentityAggregationPolicy<T extends Message>
An aggregation policy that returns the original unmodified message as the aggregate.class
MappingAggregationPolicy<S,T extends Message>
An aggregation policy that performs a simple map operation on the given message.Constructors in org.opennms.core.ipc.sink.aggregation with parameters of type AggregationPolicy Constructor Description AggregatingMessageProducer(String id, AggregationPolicy<S,T,?> policy)
Aggregator(String id, AggregationPolicy<S,T,?> policy, AggregatingMessageProducer<S,T> messageProducer)
-
Uses of AggregationPolicy in org.opennms.core.ipc.sink.api
Methods in org.opennms.core.ipc.sink.api that return AggregationPolicy Modifier and Type Method Description AggregationPolicy<S,T,?>
SinkModule. getAggregationPolicy()
Defines how messages should be combined, and when they should be "released". -
Uses of AggregationPolicy in org.opennms.core.ipc.sink.mock
Methods in org.opennms.core.ipc.sink.mock that return AggregationPolicy Modifier and Type Method Description AggregationPolicy<S,T,?>
MockSinkModule. getAggregationPolicy()
-
Uses of AggregationPolicy in org.opennms.features.deviceconfig.sink.module
Methods in org.opennms.features.deviceconfig.sink.module that return AggregationPolicy Modifier and Type Method Description AggregationPolicy<DeviceConfigSinkDTO,DeviceConfigSinkDTO,?>
DeviceConfigSinkModuleImpl. getAggregationPolicy()
-
Uses of AggregationPolicy in org.opennms.features.events.sink.module
Methods in org.opennms.features.events.sink.module that return AggregationPolicy Modifier and Type Method Description AggregationPolicy<Event,Log,Log>
EventSinkModule. getAggregationPolicy()
-
Uses of AggregationPolicy in org.opennms.minion.heartbeat.common
Methods in org.opennms.minion.heartbeat.common that return AggregationPolicy Modifier and Type Method Description AggregationPolicy<MinionIdentityDTO,MinionIdentityDTO,MinionIdentityDTO>
HeartbeatModule. getAggregationPolicy()
-
Uses of AggregationPolicy in org.opennms.netmgt.syslogd
Methods in org.opennms.netmgt.syslogd that return AggregationPolicy Modifier and Type Method Description AggregationPolicy<SyslogConnection,SyslogMessageLogDTO,SyslogMessageLogDTO>
SyslogSinkModule. getAggregationPolicy()
-
Uses of AggregationPolicy in org.opennms.netmgt.telemetry.common.ipc
Methods in org.opennms.netmgt.telemetry.common.ipc that return AggregationPolicy Modifier and Type Method Description AggregationPolicy<TelemetryMessage,TelemetryProtos.TelemetryMessageLog,TelemetryProtos.TelemetryMessageLog.Builder>
TelemetrySinkModule. getAggregationPolicy()
-
Uses of AggregationPolicy in org.opennms.netmgt.trapd
Methods in org.opennms.netmgt.trapd that return AggregationPolicy Modifier and Type Method Description AggregationPolicy<TrapInformationWrapper,TrapLogDTO,TrapLogDTO>
TrapSinkModule. getAggregationPolicy()
-