Class AlivenessMonitor
- java.lang.Object
-
- org.opendaylight.serviceutils.tools.listener.AbstractClusteredSyncDataTreeChangeListener<MonitoringState>
-
- org.opendaylight.genius.alivenessmonitor.internal.AlivenessMonitor
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,java.util.EventListener
,org.opendaylight.mdsal.binding.api.ClusteredDataTreeChangeListener<MonitoringState>
,org.opendaylight.mdsal.binding.api.DataTreeChangeListener<MonitoringState>
,org.opendaylight.serviceutils.tools.listener.ChainableDataTreeChangeListener<MonitoringState>
,AlivenessMonitorService
,org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingListener
,org.opendaylight.yangtools.yang.binding.NotificationListener
,org.opendaylight.yangtools.yang.binding.RpcService
@Singleton public class AlivenessMonitor extends org.opendaylight.serviceutils.tools.listener.AbstractClusteredSyncDataTreeChangeListener<MonitoringState> implements AlivenessMonitorService, org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingListener
-
-
Constructor Summary
Constructors Constructor Description AlivenessMonitor(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, IdManagerService idManager, org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService, AlivenessProtocolHandlerRegistry alivenessProtocolHandlerRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Default Methods Deprecated Methods Modifier and Type Method Description default void
add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> arg0, T arg1)
void
add(T arg0)
Deprecated.void
addAfterListener(org.opendaylight.mdsal.binding.api.DataTreeChangeListener<T> arg0)
void
addBeforeListener(org.opendaylight.mdsal.binding.api.DataTreeChangeListener<T> arg0)
void
close()
protected org.opendaylight.mdsal.binding.api.DataBroker
getDataBroker()
protected org.opendaylight.serviceutils.tools.listener.DataStoreMetrics
getDataStoreMetrics()
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorPauseOutput>>
monitorPause(MonitorPauseInput input)
Invokemonitor-pause
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileCreateOutput>>
monitorProfileCreate(MonitorProfileCreateInput input)
Invokemonitor-profile-create
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileDeleteOutput>>
monitorProfileDelete(MonitorProfileDeleteInput input)
Invokemonitor-profile-delete
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileGetOutput>>
monitorProfileGet(MonitorProfileGetInput input)
Invokemonitor-profile-get
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorStartOutput>>
monitorStart(MonitorStartInput input)
Invokemonitor-start
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorStopOutput>>
monitorStop(MonitorStopInput input)
Invokemonitor-stop
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorUnpauseOutput>>
monitorUnpause(MonitorUnpauseInput input)
Invokemonitor-unpause
RPC.default void
onDataTreeChanged(java.util.Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<T>> arg0, org.opendaylight.serviceutils.tools.listener.DataStoreMetrics arg1)
void
onInterfaceStateDown(java.lang.String interfaceName)
void
onInterfaceStateUp(java.lang.String interfaceName)
void
onPacketReceived(org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived packetReceived)
void
register()
void
remove(@NonNull org.opendaylight.yangtools.yang.binding.InstanceIdentifier<MonitoringState> instanceIdentifier, @NonNull MonitoringState removedDataObject)
void
remove(T arg0)
Deprecated.void
update(@NonNull org.opendaylight.yangtools.yang.binding.InstanceIdentifier<MonitoringState> instanceIdentifier, @NonNull MonitoringState originalDataObject, @NonNull MonitoringState updatedDataObject)
void
update(T arg0, T arg1)
Deprecated.-
Methods inherited from class org.opendaylight.serviceutils.tools.listener.AbstractClusteredSyncDataTreeChangeListener
onDataTreeChanged
-
-
-
-
Constructor Detail
-
AlivenessMonitor
@Inject public AlivenessMonitor(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, IdManagerService idManager, org.opendaylight.mdsal.binding.api.NotificationPublishService notificationPublishService, AlivenessProtocolHandlerRegistry alivenessProtocolHandlerRegistry)
-
-
Method Detail
-
close
@PreDestroy public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
-
onPacketReceived
public void onPacketReceived(org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived packetReceived)
- Specified by:
onPacketReceived
in interfaceorg.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingListener
-
monitorStart
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorStartOutput>> monitorStart(MonitorStartInput input)
Description copied from interface:AlivenessMonitorService
Invokemonitor-start
RPC.- Specified by:
monitorStart
in interfaceAlivenessMonitorService
- Parameters:
input
- ofmonitor-start
- Returns:
- output of
monitor-start
-
monitorPause
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorPauseOutput>> monitorPause(MonitorPauseInput input)
Description copied from interface:AlivenessMonitorService
Invokemonitor-pause
RPC.- Specified by:
monitorPause
in interfaceAlivenessMonitorService
- Parameters:
input
- ofmonitor-pause
- Returns:
- output of
monitor-pause
-
monitorUnpause
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorUnpauseOutput>> monitorUnpause(MonitorUnpauseInput input)
Description copied from interface:AlivenessMonitorService
Invokemonitor-unpause
RPC.- Specified by:
monitorUnpause
in interfaceAlivenessMonitorService
- Parameters:
input
- ofmonitor-unpause
- Returns:
- output of
monitor-unpause
-
monitorProfileCreate
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileCreateOutput>> monitorProfileCreate(MonitorProfileCreateInput input)
Description copied from interface:AlivenessMonitorService
Invokemonitor-profile-create
RPC.- Specified by:
monitorProfileCreate
in interfaceAlivenessMonitorService
- Parameters:
input
- ofmonitor-profile-create
- Returns:
- output of
monitor-profile-create
-
monitorProfileGet
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileGetOutput>> monitorProfileGet(MonitorProfileGetInput input)
Description copied from interface:AlivenessMonitorService
Invokemonitor-profile-get
RPC.- Specified by:
monitorProfileGet
in interfaceAlivenessMonitorService
- Parameters:
input
- ofmonitor-profile-get
- Returns:
- output of
monitor-profile-get
-
monitorProfileDelete
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorProfileDeleteOutput>> monitorProfileDelete(MonitorProfileDeleteInput input)
Description copied from interface:AlivenessMonitorService
Invokemonitor-profile-delete
RPC.- Specified by:
monitorProfileDelete
in interfaceAlivenessMonitorService
- Parameters:
input
- ofmonitor-profile-delete
- Returns:
- output of
monitor-profile-delete
-
monitorStop
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MonitorStopOutput>> monitorStop(MonitorStopInput input)
Description copied from interface:AlivenessMonitorService
Invokemonitor-stop
RPC.- Specified by:
monitorStop
in interfaceAlivenessMonitorService
- Parameters:
input
- ofmonitor-stop
- Returns:
- output of
monitor-stop
-
onInterfaceStateUp
public void onInterfaceStateUp(java.lang.String interfaceName)
-
onInterfaceStateDown
public void onInterfaceStateDown(java.lang.String interfaceName)
-
remove
public void remove(@NonNull org.opendaylight.yangtools.yang.binding.InstanceIdentifier<MonitoringState> instanceIdentifier, @NonNull MonitoringState removedDataObject)
-
update
public void update(@NonNull org.opendaylight.yangtools.yang.binding.InstanceIdentifier<MonitoringState> instanceIdentifier, @NonNull MonitoringState originalDataObject, @NonNull MonitoringState updatedDataObject)
-
addBeforeListener
public void addBeforeListener(org.opendaylight.mdsal.binding.api.DataTreeChangeListener<T> arg0)
- Specified by:
addBeforeListener
in interfaceorg.opendaylight.serviceutils.tools.listener.ChainableDataTreeChangeListener<T extends org.opendaylight.yangtools.yang.binding.DataObject>
-
addAfterListener
public void addAfterListener(org.opendaylight.mdsal.binding.api.DataTreeChangeListener<T> arg0)
- Specified by:
addAfterListener
in interfaceorg.opendaylight.serviceutils.tools.listener.ChainableDataTreeChangeListener<T extends org.opendaylight.yangtools.yang.binding.DataObject>
-
register
@PostConstruct public void register()
-
getDataBroker
protected org.opendaylight.mdsal.binding.api.DataBroker getDataBroker()
-
getDataStoreMetrics
protected org.opendaylight.serviceutils.tools.listener.DataStoreMetrics getDataStoreMetrics()
-
add
@Deprecated public void add(T arg0)
Deprecated.
-
remove
@Deprecated public void remove(T arg0)
Deprecated.
-
update
@Deprecated public void update(T arg0, T arg1)
Deprecated.
-
onDataTreeChanged
public default void onDataTreeChanged(java.util.Collection<org.opendaylight.mdsal.binding.api.DataTreeModification<T>> arg0, org.opendaylight.serviceutils.tools.listener.DataStoreMetrics arg1)
-
add
public default void add(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> arg0, T arg1)
-
-