client-cpp
0.7.0
|
#include <ConfigurationProcessor.hpp>
Public Types | |
typedef avro::ValidSchema | Schema |
Public Member Functions | |
ConfigurationProcessor () | |
~ConfigurationProcessor () | |
void | processConfigurationData (const std::uint8_t *data, std::size_t dataLength, bool fullResync) |
void | subscribeForUpdates (IGenericDeltaReceiver &receiver) |
void | unsubscribeFromUpdates (IGenericDeltaReceiver &receiver) |
void | addOnProcessedObserver (IConfigurationProcessedObserver &observer) |
void | removeOnProcessedObserver (IConfigurationProcessedObserver &observer) |
Public Member Functions inherited from kaa::IConfigurationProcessor | |
virtual | ~IConfigurationProcessor () |
Public Member Functions inherited from kaa::IDecodedDeltaObservable | |
virtual | ~IDecodedDeltaObservable () |
Public Member Functions inherited from kaa::IConfigurationProcessedObservable | |
virtual | ~IConfigurationProcessedObservable () |
This class is responsible for processing binary configuration updates received from IUpdateListener
. This decodes bytes into a delta list and notifies subscribers (IGenericDeltaReceiver
) with each separate delta. After delta list is processed it notifies subscribers (IConfigurationProcessedObserver
) about processing is finished. This class receives data schema updates from ISchemaProcessor
.
Definition at line 41 of file ConfigurationProcessor.hpp.
typedef avro::ValidSchema kaa::ConfigurationProcessor::Schema |
Definition at line 45 of file ConfigurationProcessor.hpp.
|
inline |
Definition at line 47 of file ConfigurationProcessor.hpp.
|
inline |
Definition at line 48 of file ConfigurationProcessor.hpp.
|
virtual |
IConfigurationProcessedObservable
implementation
Implements kaa::IConfigurationProcessedObservable.
|
virtual |
IConfigurationProcessor
implementation
Implements kaa::IConfigurationProcessor.
|
virtual |
Unsubscribes observer of configuration processing finished.
observer | Receiver to be unsubscribed. |
Implements kaa::IConfigurationProcessedObservable.
|
virtual |
IDecodedDeltaObservable
implementation
Implements kaa::IDecodedDeltaObservable.
|
virtual |
Unsubscribes receiver from decoded data updates
receiver | receiver which is going to be unsubscribed from configuration updates |
Implements kaa::IDecodedDeltaObservable.