client-cpp  0.7.0
kaa::ConfigurationProcessor Class Reference

#include <ConfigurationProcessor.hpp>

+ Inheritance diagram for kaa::ConfigurationProcessor:
+ Collaboration diagram for kaa::ConfigurationProcessor:

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 ()
 

Detailed Description

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.

Member Typedef Documentation

typedef avro::ValidSchema kaa::ConfigurationProcessor::Schema

Definition at line 45 of file ConfigurationProcessor.hpp.

Constructor & Destructor Documentation

kaa::ConfigurationProcessor::ConfigurationProcessor ( )
inline

Definition at line 47 of file ConfigurationProcessor.hpp.

kaa::ConfigurationProcessor::~ConfigurationProcessor ( )
inline

Definition at line 48 of file ConfigurationProcessor.hpp.

Member Function Documentation

void kaa::ConfigurationProcessor::addOnProcessedObserver ( IConfigurationProcessedObserver observer)
virtual
void kaa::ConfigurationProcessor::processConfigurationData ( const std::uint8_t *  data,
std::size_t  dataLength,
bool  fullResync 
)
virtual
void kaa::ConfigurationProcessor::removeOnProcessedObserver ( IConfigurationProcessedObserver observer)
virtual

Unsubscribes observer of configuration processing finished.

Parameters
observerReceiver to be unsubscribed.
See also
IConfigurationProcessedObserver

Implements kaa::IConfigurationProcessedObservable.

void kaa::ConfigurationProcessor::subscribeForUpdates ( IGenericDeltaReceiver receiver)
virtual
void kaa::ConfigurationProcessor::unsubscribeFromUpdates ( IGenericDeltaReceiver receiver)
virtual

Unsubscribes receiver from decoded data updates

Parameters
receiverreceiver which is going to be unsubscribed from configuration updates
See also
IGenericDeltaReceiver

Implements kaa::IDecodedDeltaObservable.


The documentation for this class was generated from the following file: