kaa::ConfigurationProcessor Class Reference

#include <ConfigurationProcessor.hpp>

Inheritance diagram for kaa::ConfigurationProcessor:

Collaboration diagram for kaa::ConfigurationProcessor:

Public Types
typedef avro::ValidSchema	Schema
Public Types inherited from kaa::ISchemaUpdatesReceiver
typedef avro::ValidSchema	Schema

Public Member Functions
	ConfigurationProcessor ()
	ConfigurationProcessor (boost::shared_ptr< avro::ValidSchema > schema)
	~ConfigurationProcessor ()
void	processConfigurationData (const boost::uint8_t *data, size_t data_length, bool full_resync)
void	subscribeForUpdates (IGenericDeltaReceiver &receiver)
void	unsubscribeFromUpdates (IGenericDeltaReceiver &receiver)
void	addOnProcessedObserver (IConfigurationProcessedObserver &observer)
void	removeOnProcessedObserver (IConfigurationProcessedObserver &observer)
void	onSchemaUpdated (boost::shared_ptr< avro::ValidSchema > schema)
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 ()
Public Member Functions inherited from kaa::ISchemaUpdatesReceiver
virtual	~ISchemaUpdatesReceiver ()

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 40 of file ConfigurationProcessor.hpp.

Member Typedef Documentation

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

Definition at line 42 of file ConfigurationProcessor.hpp.

Constructor & Destructor Documentation

kaa::ConfigurationProcessor::ConfigurationProcessor ( )

inline

Definition at line 44 of file ConfigurationProcessor.hpp.

kaa::ConfigurationProcessor::ConfigurationProcessor ( boost::shared_ptr< avro::ValidSchema >  schema )

inline

Definition at line 45 of file ConfigurationProcessor.hpp.

kaa::ConfigurationProcessor::~ConfigurationProcessor ( )

inline

Definition at line 46 of file ConfigurationProcessor.hpp.

Member Function Documentation

void kaa::ConfigurationProcessor::addOnProcessedObserver ( IConfigurationProcessedObserver &  observer )

virtual

IConfigurationProcessedObservable implementation

Implements kaa::IConfigurationProcessedObservable.

void kaa::ConfigurationProcessor::onSchemaUpdated ( boost::shared_ptr< avro::ValidSchema >  schema )

virtual

ISchemaUpdatesReceiver implementation

Implements kaa::ISchemaUpdatesReceiver.

void kaa::ConfigurationProcessor::processConfigurationData ( const boost::uint8_t *  data, size_t  data_length, bool  full_resync  )

virtual

IConfigurationProcessor implementation

Implements kaa::IConfigurationProcessor.

void kaa::ConfigurationProcessor::removeOnProcessedObserver ( IConfigurationProcessedObserver &  observer )

virtual

Unsubscribes observer of configuration processing finished.

Parameters

observer

Receiver to be unsubscribed.

See also

IConfigurationProcessedObserver

Implements kaa::IConfigurationProcessedObservable.

void kaa::ConfigurationProcessor::subscribeForUpdates ( IGenericDeltaReceiver &  receiver )

virtual

IDecodedDeltaObservable implementation

Implements kaa::IDecodedDeltaObservable.

void kaa::ConfigurationProcessor::unsubscribeFromUpdates ( IGenericDeltaReceiver &  receiver )

virtual

Unsubscribes receiver from decoded data updates

Parameters

receiver

receiver 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:

• /var/lib/jenkins/workspace/kaa/client/client-multi/client-cpp/kaa/configuration/ConfigurationProcessor.hpp