etl::impl::Transformer< DataPipeType, LedgerLoaderType, LedgerPublisherType, AmendmentBlockHandlerType > Class Template Reference

Transformer thread that prepares new ledger out of raw data from GRPC. More...

#include <Transformer.hpp>

Public Member Functions
	Transformer (DataPipeType &pipe, std::shared_ptr< BackendInterface > backend, LedgerLoaderType &loader, LedgerPublisherType &publisher, AmendmentBlockHandlerType &amendmentBlockHandler, uint32_t startSequence, SystemState &state)
	Create an instance of the transformer.
	~Transformer ()
	Joins the transformer thread.
void	waitTillFinished ()
	Block calling thread until transformer thread exits.

Detailed Description

template<typename DataPipeType, typename LedgerLoaderType, typename LedgerPublisherType, typename AmendmentBlockHandlerType>
class etl::impl::Transformer< DataPipeType, LedgerLoaderType, LedgerPublisherType, AmendmentBlockHandlerType >

Transformer thread that prepares new ledger out of raw data from GRPC.

Constructor & Destructor Documentation

Transformer()

template<typename DataPipeType , typename LedgerLoaderType , typename LedgerPublisherType , typename AmendmentBlockHandlerType >

etl::impl::Transformer< DataPipeType, LedgerLoaderType, LedgerPublisherType, AmendmentBlockHandlerType >::Transformer ( DataPipeType & pipe, std::shared_ptr< BackendInterface > backend, LedgerLoaderType & loader, LedgerPublisherType & publisher, AmendmentBlockHandlerType & amendmentBlockHandler, uint32_t startSequence, SystemState & state )

inline

Create an instance of the transformer.

This spawns a new thread that reads from the data pipe and writes ledgers to the DB using LedgerLoader and LedgerPublisher.

---

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

• /__w/clio/clio/src/etl/impl/Transformer.hpp