dcn::loader Namespace Reference

Classes
struct	LoaderBatchConfig

Functions
bool	ensurePTBuildVersion (const std::filesystem::path &storage_path)
asio::awaitable< std::expected< chain::Address, pt::PTDeployError > >	deployConnector (evm::EVM &evm, storage::Registry &registry, ConnectorRecord connector, const std::filesystem::path &storage_path, bool register_in_registry=true, bool persist_json=true)
asio::awaitable< std::expected< chain::Address, pt::PTDeployError > >	deployTransformation (evm::EVM &evm, storage::Registry &registry, TransformationRecord transformation, const std::filesystem::path &storage_path, bool register_in_registry=true, bool persist_json=true)
asio::awaitable< std::expected< chain::Address, pt::PTDeployError > >	deployCondition (evm::EVM &evm, storage::Registry &registry, ConditionRecord condition, const std::filesystem::path &storage_path, bool register_in_registry=true, bool persist_json=true)
asio::awaitable< bool >	importJsonStorageToDatabase (evm::EVM &evm, storage::Registry &registry, const std::filesystem::path &storage_path, LoaderBatchConfig batch_config={})
asio::awaitable< bool >	ensureTransformationDeployed (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path)
asio::awaitable< bool >	ensureConditionDeployed (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path)
asio::awaitable< bool >	ensureConnectorDeployed (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path)
asio::awaitable< bool >	loadStoredConnectors (evm::EVM &evm, storage::Registry &registry, const std::filesystem::path &storage_path, std::size_t registry_batch_size=1000)
asio::awaitable< bool >	loadStoredConditions (evm::EVM &evm, storage::Registry &registry, const std::filesystem::path &storage_path, std::size_t registry_batch_size=5000)
asio::awaitable< bool >	loadStoredTransformations (evm::EVM &evm, storage::Registry &registry, const std::filesystem::path &storage_path, std::size_t registry_batch_size=5000)
asio::awaitable< bool >	ensureTransformationImported (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path, JsonImportContext &context)
asio::awaitable< bool >	ensureConditionImported (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path, JsonImportContext &context)
asio::awaitable< bool >	ensureConnectorImported (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path, JsonImportContext &context)
asio::awaitable< bool >	ensureConnectorDeployedImpl (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path, ConnectorEnsureContext &context)

Function Documentation

deployCondition()

asio::awaitable< std::expected< chain::Address, pt::PTDeployError > > dcn::loader::deployCondition	(	evm::EVM &	evm,
		storage::Registry &	registry,
		ConditionRecord	condition,
		const std::filesystem::path &	storage_path,
		bool	register_in_registry = true,
		bool	persist_json = true
	)

deployConnector()

asio::awaitable< std::expected< chain::Address, pt::PTDeployError > > dcn::loader::deployConnector	(	evm::EVM &	evm,
		storage::Registry &	registry,
		ConnectorRecord	connector,
		const std::filesystem::path &	storage_path,
		bool	register_in_registry = true,
		bool	persist_json = true
	)

deployTransformation()

asio::awaitable< std::expected< chain::Address, pt::PTDeployError > > dcn::loader::deployTransformation	(	evm::EVM &	evm,
		storage::Registry &	registry,
		TransformationRecord	transformation,
		const std::filesystem::path &	storage_path,
		bool	register_in_registry = true,
		bool	persist_json = true
	)

ensureConditionDeployed()

asio::awaitable< bool > dcn::loader::ensureConditionDeployed	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::string &	name,
		const std::filesystem::path &	storage_path
	)

ensureConditionImported()

asio::awaitable< bool > dcn::loader::ensureConditionImported	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::string &	name,
		const std::filesystem::path &	storage_path,
		JsonImportContext &	context
	)

ensureConnectorDeployed()

asio::awaitable< bool > dcn::loader::ensureConnectorDeployed	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::string &	name,
		const std::filesystem::path &	storage_path
	)

ensureConnectorDeployedImpl()

asio::awaitable< bool > dcn::loader::ensureConnectorDeployedImpl	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::string &	name,
		const std::filesystem::path &	storage_path,
		ConnectorEnsureContext &	context
	)

ensureConnectorImported()

asio::awaitable< bool > dcn::loader::ensureConnectorImported	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::string &	name,
		const std::filesystem::path &	storage_path,
		JsonImportContext &	context
	)

ensurePTBuildVersion()

bool dcn::loader::ensurePTBuildVersion

(

const std::filesystem::path &

storage_path

)

ensureTransformationDeployed()

asio::awaitable< bool > dcn::loader::ensureTransformationDeployed	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::string &	name,
		const std::filesystem::path &	storage_path
	)

ensureTransformationImported()

asio::awaitable< bool > dcn::loader::ensureTransformationImported	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::string &	name,
		const std::filesystem::path &	storage_path,
		JsonImportContext &	context
	)

importJsonStorageToDatabase()

asio::awaitable< bool > dcn::loader::importJsonStorageToDatabase	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::filesystem::path &	storage_path,
		LoaderBatchConfig	batch_config = {}
	)

loadStoredConditions()

asio::awaitable< bool > dcn::loader::loadStoredConditions	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::filesystem::path &	storage_path,
		std::size_t	registry_batch_size = 5000
	)

loadStoredConnectors()

asio::awaitable< bool > dcn::loader::loadStoredConnectors	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::filesystem::path &	storage_path,
		std::size_t	registry_batch_size = 1000
	)

loadStoredTransformations()

asio::awaitable< bool > dcn::loader::loadStoredTransformations	(	evm::EVM &	evm,
		storage::Registry &	registry,
		const std::filesystem::path &	storage_path,
		std::size_t	registry_batch_size = 5000
	)