ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
6e4b4ad064564d5fe2e166d04d113d603ddab3f9
rippled/classripple_1_1ETLSource.html
manojsdoshi 3ded95240d deploy: 4ec11e692b
2021-12-17 19:04:33 +00:00

1423 lines
77 KiB
HTML
Raw Blame History

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "https://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/>
<meta http-equiv="X-UA-Compatible" content="IE=9"/>
<meta name="generator" content="Doxygen 1.8.17"/>
<meta name="viewport" content="width=device-width, initial-scale=1"/>
<title>rippled: ripple::ETLSource Class Reference</title>
<link href="tabs.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="jquery.js"></script>
<script type="text/javascript" src="dynsections.js"></script>
<link href="search/search.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="search/searchdata.js"></script>
<script type="text/javascript" src="search/search.js"></script>
<link href="doxygen.css" rel="stylesheet" type="text/css" />
</head>
<body>
<div id="top"><!-- do not remove this div, it is closed by doxygen! -->
<div id="titlearea">
<table cellspacing="0" cellpadding="0">
<tbody>
<tr style="height: 56px;">
<td id="projectalign" style="padding-left: 0.5em;">
<div id="projectname">rippled
</div>
</td>
</tr>
</tbody>
</table>
</div>
<!-- end header part -->
<!-- Generated by Doxygen 1.8.17 -->
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&amp;dn=gpl-2.0.txt GPL-v2 */
var searchBox = new SearchBox("searchBox", "search",false,'Search');
/* @license-end */
</script>
<script type="text/javascript" src="menudata.js"></script>
<script type="text/javascript" src="menu.js"></script>
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:cf05388f2679ee054f2beb29a391d25f4e673ac3&amp;dn=gpl-2.0.txt GPL-v2 */
$(function() {
initMenu('',true,false,'search.php','Search');
$(document).ready(function() { init_search(); });
});
/* @license-end */</script>
<div id="main-nav"></div>
<!-- window showing the filter options -->
<div id="MSearchSelectWindow"
onmouseover="return searchBox.OnSearchSelectShow()"
onmouseout="return searchBox.OnSearchSelectHide()"
onkeydown="return searchBox.OnSearchSelectKey(event)">
</div>
<!-- iframe showing the search results (closed by default) -->
<div id="MSearchResultsWindow">
<iframe src="javascript:void(0)" frameborder="0"
name="MSearchResults" id="MSearchResults">
</iframe>
</div>
<div id="nav-path" class="navpath">
<ul>
<li class="navelem"><a class="el" href="namespaceripple.html">ripple</a></li><li class="navelem"><a class="el" href="classripple_1_1ETLSource.html">ETLSource</a></li> </ul>
</div>
</div><!-- top -->
<div class="header">
<div class="summary">
<a href="#pub-methods">Public Member Functions</a> &#124;
<a href="#pri-attribs">Private Attributes</a> &#124;
<a href="classripple_1_1ETLSource-members.html">List of all members</a> </div>
<div class="headertitle">
<div class="title">ripple::ETLSource Class Reference</div> </div>
</div><!--header-->
<div class="contents">
<p>This class manages a connection to a single ETL source.
<a href="classripple_1_1ETLSource.html#details">More...</a></p>
<div class="dynheader">
Collaboration diagram for ripple::ETLSource:</div>
<div class="dyncontent">
<div class="center"><img src="classripple_1_1ETLSource__coll__graph.png" border="0" usemap="#ripple_1_1ETLSource_coll__map" alt="Collaboration graph"/></div>
<map name="ripple_1_1ETLSource_coll__map" id="ripple_1_1ETLSource_coll__map">
<area shape="rect" title="This class manages a connection to a single ETL source." alt="" coords="1723,559,1857,586"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html" title=" " alt="" coords="1928,615,2099,656"/>
<area shape="rect" href="classripple_1_1Application.html" title=" " alt="" coords="1300,161,1440,187"/>
<area shape="rect" href="classripple_1_1ReportingETL.html" title="This class is responsible for continuously extracting data from a p2p node, and writing that data to ..." alt="" coords="2961,594,3113,621"/>
<area shape="rect" href="classbeast_1_1PropertyStream_1_1Source.html" title="Subclasses can be called to write to a stream and have children." alt="" coords="869,132,1037,173"/>
<area shape="rect" href="classbeast_1_1PropertyStream_1_1Item.html" title=" " alt="" coords="1286,69,1454,111"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/thread/recursive_mutex.html" title="STL class." alt="" coords="576,162,735,189"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/string/basic_string.html" title="STL class." alt="" coords="612,390,699,417"/>
<area shape="rect" href="classbeast_1_1List.html" title=" " alt="" coords="563,96,748,137"/>
<area shape="rect" href="classbeast_1_1detail_1_1ListNode.html" title=" " alt="" coords="275,51,457,107"/>
<area shape="rect" href="classbeast_1_1detail_1_1ListNode.html" title=" " alt="" coords="5,59,173,100"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/types/size_t.html" title=" " alt="" coords="322,131,410,158"/>
<area shape="rect" title=" " alt="" coords="880,42,1027,69"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/thread/mutex.html" title="STL class." alt="" coords="907,377,999,403"/>
<area shape="rect" href="classripple_1_1NetworkValidatedLedgers.html" title="This datastructure is used to keep track of the sequence of the most recent ledger validated by the n..." alt="" coords="1279,264,1461,305"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/atomic/atomic.html" title=" " alt="" coords="1305,739,1435,766"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html" title=" " alt="" coords="1256,461,1484,517"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/container/vector.html" title=" " alt="" coords="1279,669,1461,711"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/utility/pair.html" title=" " alt="" coords="880,669,1027,711"/>
<area shape="rect" title=" " alt="" coords="636,677,675,703"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html" title=" " alt="" coords="1243,381,1497,437"/>
<area shape="rect" href="classbeast_1_1Journal.html" title="A generic endpoint for log messages." alt="" coords="1315,822,1425,849"/>
<area shape="rect" href="classripple_1_1ETLLoadBalancer.html" title="This class is used to manage connections to transaction processing processes This class spawns a list..." alt="" coords="2637,637,2816,663"/>
<area shape="rect" href="classbeast_1_1Journal_1_1Sink.html" title="Abstraction for the underlying message destination." alt="" coords="880,822,1027,849"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/thread/condition_variable.html" title=" " alt="" coords="868,287,1039,314"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/utility/optional.html" title=" " alt="" coords="860,222,1047,249"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/container/vector.html" title=" " alt="" coords="2324,623,2528,664"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/chrono/time_point.html" title=" " alt="" coords="2641,907,2813,963"/>
<area shape="rect" href="http://en.cppreference.com/w/cpp/thread/thread.html" title="STL class." alt="" coords="2681,987,2773,1014"/>
</map>
<center><span class="legend">[<a href="graph_legend.html">legend</a>]</span></center></div>
<table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-methods"></a>
Public Member Functions</h2></td></tr>
<tr class="memitem:a03795cc29af78921ecb3ddcd78ffd7d6"><td class="memItemLeft" align="right" valign="top">bool&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a03795cc29af78921ecb3ddcd78ffd7d6">isConnected</a> () const</td></tr>
<tr class="separator:a03795cc29af78921ecb3ddcd78ffd7d6"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ac2925e6a666f7447249e4819d85ecde3"><td class="memItemLeft" align="right" valign="top">std::chrono::system_clock::time_point&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#ac2925e6a666f7447249e4819d85ecde3">getLastMsgTime</a> () const</td></tr>
<tr class="separator:ac2925e6a666f7447249e4819d85ecde3"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a7b7bffe16b2046e6e7ab185743cfce23"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a7b7bffe16b2046e6e7ab185743cfce23">setLastMsgTime</a> ()</td></tr>
<tr class="separator:a7b7bffe16b2046e6e7ab185743cfce23"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ab1d5d18e9c9a341618d3fceb3bc2e007"><td class="memItemLeft" align="right" valign="top">&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#ab1d5d18e9c9a341618d3fceb3bc2e007">ETLSource</a> (<a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> ip, <a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> wsPort, <a class="el" href="classripple_1_1ReportingETL.html">ReportingETL</a> &amp;etl)</td></tr>
<tr class="memdesc:ab1d5d18e9c9a341618d3fceb3bc2e007"><td class="mdescLeft">&#160;</td><td class="mdescRight">Create ETL source without gRPC endpoint Fetch ledger and load initial ledger will fail for this source Primarly used in read-only mode, to monitor when ledgers are validated. <a href="classripple_1_1ETLSource.html#ab1d5d18e9c9a341618d3fceb3bc2e007">More...</a><br /></td></tr>
<tr class="separator:ab1d5d18e9c9a341618d3fceb3bc2e007"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a5cce50ac6cd85499569de58d619cda61"><td class="memItemLeft" align="right" valign="top">&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a5cce50ac6cd85499569de58d619cda61">ETLSource</a> (<a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> ip, <a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> wsPort, <a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> grpcPort, <a class="el" href="classripple_1_1ReportingETL.html">ReportingETL</a> &amp;etl)</td></tr>
<tr class="memdesc:a5cce50ac6cd85499569de58d619cda61"><td class="mdescLeft">&#160;</td><td class="mdescRight">Create ETL source with gRPC endpoint. <a href="classripple_1_1ETLSource.html#a5cce50ac6cd85499569de58d619cda61">More...</a><br /></td></tr>
<tr class="separator:a5cce50ac6cd85499569de58d619cda61"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a6d307c73ffadd9d140cc9be89d0e132f"><td class="memItemLeft" align="right" valign="top">bool&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a6d307c73ffadd9d140cc9be89d0e132f">hasLedger</a> (uint32_t sequence) const</td></tr>
<tr class="separator:a6d307c73ffadd9d140cc9be89d0e132f"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a424ba3ef3a05a7b362d009d782c4c401"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a424ba3ef3a05a7b362d009d782c4c401">setValidatedRange</a> (<a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> const &amp;<a class="el" href="namespaceripple.html#a718d6c3cd459b4d24d7bc790905c57f2">range</a>)</td></tr>
<tr class="memdesc:a424ba3ef3a05a7b362d009d782c4c401"><td class="mdescLeft">&#160;</td><td class="mdescRight">process the validated range received on the ledgers stream. <a href="classripple_1_1ETLSource.html#a424ba3ef3a05a7b362d009d782c4c401">More...</a><br /></td></tr>
<tr class="separator:a424ba3ef3a05a7b362d009d782c4c401"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a28220cc0d9a88604a7f09d22d2db31a2"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a28220cc0d9a88604a7f09d22d2db31a2">getValidatedRange</a> () const</td></tr>
<tr class="separator:a28220cc0d9a88604a7f09d22d2db31a2"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aa307e19103297ad9d70fdf94eb70b8f6"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#aa307e19103297ad9d70fdf94eb70b8f6">stop</a> ()</td></tr>
<tr class="memdesc:aa307e19103297ad9d70fdf94eb70b8f6"><td class="mdescLeft">&#160;</td><td class="mdescRight">Close the underlying websocket. <a href="classripple_1_1ETLSource.html#aa307e19103297ad9d70fdf94eb70b8f6">More...</a><br /></td></tr>
<tr class="separator:aa307e19103297ad9d70fdf94eb70b8f6"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a2d123c85def3519d79a361b7bd1fac2c"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/utility/pair.html">std::pair</a>&lt; grpc::Status, org::xrpl::rpc::v1::GetLedgerResponse &gt;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a2d123c85def3519d79a361b7bd1fac2c">fetchLedger</a> (uint32_t ledgerSequence, bool getObjects=true)</td></tr>
<tr class="memdesc:a2d123c85def3519d79a361b7bd1fac2c"><td class="mdescLeft">&#160;</td><td class="mdescRight">Fetch the specified ledger. <a href="classripple_1_1ETLSource.html#a2d123c85def3519d79a361b7bd1fac2c">More...</a><br /></td></tr>
<tr class="separator:a2d123c85def3519d79a361b7bd1fac2c"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:abf5f2105ddf1850622bbb9d386a8075d"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#abf5f2105ddf1850622bbb9d386a8075d">toString</a> () const</td></tr>
<tr class="separator:abf5f2105ddf1850622bbb9d386a8075d"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:acf3ccf53068788d7393696d6e8c54056"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classJson_1_1Value.html">Json::Value</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#acf3ccf53068788d7393696d6e8c54056">toJson</a> () const</td></tr>
<tr class="separator:acf3ccf53068788d7393696d6e8c54056"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ad21a9afeb41497be4d2ae77582ca9f1a"><td class="memItemLeft" align="right" valign="top">bool&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#ad21a9afeb41497be4d2ae77582ca9f1a">loadInitialLedger</a> (uint32_t ledgerSequence, <a class="el" href="classripple_1_1ThreadSafeQueue.html">ThreadSafeQueue</a>&lt; <a class="elRef" href="http://en.cppreference.com/w/cpp/memory/shared_ptr.html">std::shared_ptr</a>&lt; <a class="el" href="namespaceripple.html#abbba3966df1925ac76f6d04c0aa1abe3">SLE</a> &gt;&gt; &amp;writeQueue)</td></tr>
<tr class="memdesc:ad21a9afeb41497be4d2ae77582ca9f1a"><td class="mdescLeft">&#160;</td><td class="mdescRight">Download a ledger in full. <a href="classripple_1_1ETLSource.html#ad21a9afeb41497be4d2ae77582ca9f1a">More...</a><br /></td></tr>
<tr class="separator:ad21a9afeb41497be4d2ae77582ca9f1a"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a64b2f303ab2c62d02c10a8c9a2bee591"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a64b2f303ab2c62d02c10a8c9a2bee591">start</a> ()</td></tr>
<tr class="memdesc:a64b2f303ab2c62d02c10a8c9a2bee591"><td class="mdescLeft">&#160;</td><td class="mdescRight">Begin sequence of operations to connect to the ETL source and subscribe to ledgers and transactions_proposed. <a href="classripple_1_1ETLSource.html#a64b2f303ab2c62d02c10a8c9a2bee591">More...</a><br /></td></tr>
<tr class="separator:a64b2f303ab2c62d02c10a8c9a2bee591"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aa96a2d2ce4143bb7b03c4745faa2f5df"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#aa96a2d2ce4143bb7b03c4745faa2f5df">reconnect</a> (boost::beast::error_code ec)</td></tr>
<tr class="memdesc:aa96a2d2ce4143bb7b03c4745faa2f5df"><td class="mdescLeft">&#160;</td><td class="mdescRight">Attempt to reconnect to the ETL source. <a href="classripple_1_1ETLSource.html#aa96a2d2ce4143bb7b03c4745faa2f5df">More...</a><br /></td></tr>
<tr class="separator:aa96a2d2ce4143bb7b03c4745faa2f5df"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a969d79e2cecc2f3c9e67b7484651a286"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a969d79e2cecc2f3c9e67b7484651a286">onResolve</a> (boost::beast::error_code ec, boost::asio::ip::tcp::resolver::results_type results)</td></tr>
<tr class="memdesc:a969d79e2cecc2f3c9e67b7484651a286"><td class="mdescLeft">&#160;</td><td class="mdescRight">Callback. <a href="classripple_1_1ETLSource.html#a969d79e2cecc2f3c9e67b7484651a286">More...</a><br /></td></tr>
<tr class="separator:a969d79e2cecc2f3c9e67b7484651a286"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a0e5cb59e78b5fbff15dfe9d99d78f171"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a0e5cb59e78b5fbff15dfe9d99d78f171">onConnect</a> (boost::beast::error_code ec, boost::asio::ip::tcp::resolver::results_type::endpoint_type endpoint)</td></tr>
<tr class="memdesc:a0e5cb59e78b5fbff15dfe9d99d78f171"><td class="mdescLeft">&#160;</td><td class="mdescRight">Callback. <a href="classripple_1_1ETLSource.html#a0e5cb59e78b5fbff15dfe9d99d78f171">More...</a><br /></td></tr>
<tr class="separator:a0e5cb59e78b5fbff15dfe9d99d78f171"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:af11b24e2418e645b0fc27b9b7a02431d"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#af11b24e2418e645b0fc27b9b7a02431d">onHandshake</a> (boost::beast::error_code ec)</td></tr>
<tr class="memdesc:af11b24e2418e645b0fc27b9b7a02431d"><td class="mdescLeft">&#160;</td><td class="mdescRight">Callback. <a href="classripple_1_1ETLSource.html#af11b24e2418e645b0fc27b9b7a02431d">More...</a><br /></td></tr>
<tr class="separator:af11b24e2418e645b0fc27b9b7a02431d"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ac910115aedc2a23c42fee581b1431f24"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#ac910115aedc2a23c42fee581b1431f24">onWrite</a> (boost::beast::error_code ec, size_t size)</td></tr>
<tr class="memdesc:ac910115aedc2a23c42fee581b1431f24"><td class="mdescLeft">&#160;</td><td class="mdescRight">Callback. <a href="classripple_1_1ETLSource.html#ac910115aedc2a23c42fee581b1431f24">More...</a><br /></td></tr>
<tr class="separator:ac910115aedc2a23c42fee581b1431f24"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a81b42d9b583c644d981d3d5fc1446a74"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a81b42d9b583c644d981d3d5fc1446a74">onRead</a> (boost::beast::error_code ec, size_t size)</td></tr>
<tr class="memdesc:a81b42d9b583c644d981d3d5fc1446a74"><td class="mdescLeft">&#160;</td><td class="mdescRight">Callback. <a href="classripple_1_1ETLSource.html#a81b42d9b583c644d981d3d5fc1446a74">More...</a><br /></td></tr>
<tr class="separator:a81b42d9b583c644d981d3d5fc1446a74"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a558b110180f15704b284c145aacdd50c"><td class="memItemLeft" align="right" valign="top">bool&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a558b110180f15704b284c145aacdd50c">handleMessage</a> ()</td></tr>
<tr class="memdesc:a558b110180f15704b284c145aacdd50c"><td class="mdescLeft">&#160;</td><td class="mdescRight">Handle the most recently received message. <a href="classripple_1_1ETLSource.html#a558b110180f15704b284c145aacdd50c">More...</a><br /></td></tr>
<tr class="separator:a558b110180f15704b284c145aacdd50c"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aa2a46267da6ac73174215a3a2e9fe5e1"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#aa2a46267da6ac73174215a3a2e9fe5e1">close</a> (bool startAgain)</td></tr>
<tr class="memdesc:aa2a46267da6ac73174215a3a2e9fe5e1"><td class="mdescLeft">&#160;</td><td class="mdescRight">Close the websocket. <a href="classripple_1_1ETLSource.html#aa2a46267da6ac73174215a3a2e9fe5e1">More...</a><br /></td></tr>
<tr class="separator:aa2a46267da6ac73174215a3a2e9fe5e1"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aa8830854039b446a7fbae5ed16db238d"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html">std::unique_ptr</a>&lt; org::xrpl::rpc::v1::XRPLedgerAPIService::Stub &gt;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#aa8830854039b446a7fbae5ed16db238d">getP2pForwardingStub</a> () const</td></tr>
<tr class="memdesc:aa8830854039b446a7fbae5ed16db238d"><td class="mdescLeft">&#160;</td><td class="mdescRight">Get grpc stub to forward requests to p2p node. <a href="classripple_1_1ETLSource.html#aa8830854039b446a7fbae5ed16db238d">More...</a><br /></td></tr>
<tr class="separator:aa8830854039b446a7fbae5ed16db238d"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:adcb2c4b9bde51549a959c576533a1418"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classJson_1_1Value.html">Json::Value</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#adcb2c4b9bde51549a959c576533a1418">forwardToP2p</a> (<a class="el" href="structripple_1_1RPC_1_1JsonContext.html">RPC::JsonContext</a> &amp;context) const</td></tr>
<tr class="memdesc:adcb2c4b9bde51549a959c576533a1418"><td class="mdescLeft">&#160;</td><td class="mdescRight">Forward a JSON <a class="el" href="namespaceripple_1_1RPC.html">RPC</a> request to a p2p node. <a href="classripple_1_1ETLSource.html#adcb2c4b9bde51549a959c576533a1418">More...</a><br /></td></tr>
<tr class="separator:adcb2c4b9bde51549a959c576533a1418"><td class="memSeparator" colspan="2">&#160;</td></tr>
</table><table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pri-attribs"></a>
Private Attributes</h2></td></tr>
<tr class="memitem:ae64030c4845b53a75bf8f9921d38ed92"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#ae64030c4845b53a75bf8f9921d38ed92">ip_</a></td></tr>
<tr class="separator:ae64030c4845b53a75bf8f9921d38ed92"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a53b3ebda1673cadb074f2345098639e0"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a53b3ebda1673cadb074f2345098639e0">wsPort_</a></td></tr>
<tr class="separator:a53b3ebda1673cadb074f2345098639e0"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:af7b53b6e2f95a1fe500fe0fc487a76e6"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#af7b53b6e2f95a1fe500fe0fc487a76e6">grpcPort_</a></td></tr>
<tr class="separator:af7b53b6e2f95a1fe500fe0fc487a76e6"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a73d3c7364a78905eb760de5b9045aec1"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classripple_1_1ReportingETL.html">ReportingETL</a> &amp;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a73d3c7364a78905eb760de5b9045aec1">etl_</a></td></tr>
<tr class="separator:a73d3c7364a78905eb760de5b9045aec1"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aa54b0606a7328fb1efaf415e9c43b8be"><td class="memItemLeft" align="right" valign="top">boost::asio::io_context &amp;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#aa54b0606a7328fb1efaf415e9c43b8be">ioc_</a></td></tr>
<tr class="separator:aa54b0606a7328fb1efaf415e9c43b8be"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ae15dd2e3190676aa238ce5a097cd585a"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html">std::unique_ptr</a>&lt; org::xrpl::rpc::v1::XRPLedgerAPIService::Stub &gt;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#ae15dd2e3190676aa238ce5a097cd585a">stub_</a></td></tr>
<tr class="separator:ae15dd2e3190676aa238ce5a097cd585a"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a9c7824f2491a78cc672187f958f07231"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html">std::unique_ptr</a>&lt; boost::beast::websocket::stream&lt; boost::beast::tcp_stream &gt; &gt;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a9c7824f2491a78cc672187f958f07231">ws_</a></td></tr>
<tr class="separator:a9c7824f2491a78cc672187f958f07231"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a0bd7f579df90324230b7db70d900182f"><td class="memItemLeft" align="right" valign="top">boost::asio::ip::tcp::resolver&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a0bd7f579df90324230b7db70d900182f">resolver_</a></td></tr>
<tr class="separator:a0bd7f579df90324230b7db70d900182f"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ad4c1ef03bbc180d9ac1356adc9240d11"><td class="memItemLeft" align="right" valign="top">boost::beast::flat_buffer&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#ad4c1ef03bbc180d9ac1356adc9240d11">readBuffer_</a></td></tr>
<tr class="separator:ad4c1ef03bbc180d9ac1356adc9240d11"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aa3755579e2ba263f23f54a57db0b3666"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/container/vector.html">std::vector</a>&lt; <a class="elRef" href="http://en.cppreference.com/w/cpp/utility/pair.html">std::pair</a>&lt; uint32_t, uint32_t &gt; &gt;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#aa3755579e2ba263f23f54a57db0b3666">validatedLedgers_</a></td></tr>
<tr class="separator:aa3755579e2ba263f23f54a57db0b3666"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a2b9e864ef6e865e1dbebdbee4442e638"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a2b9e864ef6e865e1dbebdbee4442e638">validatedLedgersRaw_</a></td></tr>
<tr class="separator:a2b9e864ef6e865e1dbebdbee4442e638"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a8c78222865586b628b0ae391effdfe42"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classripple_1_1NetworkValidatedLedgers.html">NetworkValidatedLedgers</a> &amp;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a8c78222865586b628b0ae391effdfe42">networkValidatedLedgers_</a></td></tr>
<tr class="separator:a8c78222865586b628b0ae391effdfe42"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a547632f1053f5368243ea454d0820fb0"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classbeast_1_1Journal.html">beast::Journal</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a547632f1053f5368243ea454d0820fb0">journal_</a></td></tr>
<tr class="separator:a547632f1053f5368243ea454d0820fb0"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a39336445d396d94821915db6ada02898"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classripple_1_1Application.html">Application</a> &amp;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a39336445d396d94821915db6ada02898">app_</a></td></tr>
<tr class="separator:a39336445d396d94821915db6ada02898"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a7e0e79325d9bfe87ca75eba3827d83fc"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/thread/mutex.html">std::mutex</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a7e0e79325d9bfe87ca75eba3827d83fc">mtx_</a></td></tr>
<tr class="separator:a7e0e79325d9bfe87ca75eba3827d83fc"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a1bae8214216046e47a89e1b62bc53f7c"><td class="memItemLeft" align="right" valign="top">size_t&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a1bae8214216046e47a89e1b62bc53f7c">numFailures_</a> = 0</td></tr>
<tr class="separator:a1bae8214216046e47a89e1b62bc53f7c"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a0eb09ff484c8d2f08e8a95df1503d90e"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/atomic/atomic.html">std::atomic_bool</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a0eb09ff484c8d2f08e8a95df1503d90e">closing_</a> = false</td></tr>
<tr class="separator:a0eb09ff484c8d2f08e8a95df1503d90e"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a0c13d997d62673803f96b5b24c67911c"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/atomic/atomic.html">std::atomic_bool</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a0c13d997d62673803f96b5b24c67911c">connected_</a> = false</td></tr>
<tr class="separator:a0c13d997d62673803f96b5b24c67911c"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a9bad0ca9e0868ee21a0dc1d6dc7c8326"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/atomic/atomic.html">std::atomic_bool</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a9bad0ca9e0868ee21a0dc1d6dc7c8326">forwardingStream_</a> = false</td></tr>
<tr class="separator:a9bad0ca9e0868ee21a0dc1d6dc7c8326"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a154e5ba2bc868e7c66fb7f559ee6e460"><td class="memItemLeft" align="right" valign="top">std::chrono::system_clock::time_point&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a154e5ba2bc868e7c66fb7f559ee6e460">lastMsgTime_</a></td></tr>
<tr class="separator:a154e5ba2bc868e7c66fb7f559ee6e460"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a67dfbed5ae9ffa05649bc0c350f8d012"><td class="memItemLeft" align="right" valign="top"><a class="elRef" href="http://en.cppreference.com/w/cpp/thread/mutex.html">std::mutex</a>&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#a67dfbed5ae9ffa05649bc0c350f8d012">lastMsgTimeMtx_</a></td></tr>
<tr class="separator:a67dfbed5ae9ffa05649bc0c350f8d012"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aea155c0ce7f36229af7cb6a58dad2be8"><td class="memItemLeft" align="right" valign="top">boost::asio::steady_timer&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classripple_1_1ETLSource.html#aea155c0ce7f36229af7cb6a58dad2be8">timer_</a></td></tr>
<tr class="separator:aea155c0ce7f36229af7cb6a58dad2be8"><td class="memSeparator" colspan="2">&#160;</td></tr>
</table>
<a name="details" id="details"></a><h2 class="groupheader">Detailed Description</h2>
<div class="textblock"><p>This class manages a connection to a single ETL source. </p>
<p>This is almost always a p2p node, but really could be another reporting node. This class subscribes to the ledgers and transactions_proposed streams of the associated p2p node, and keeps track of which ledgers the p2p node has. This class also has methods for extracting said ledgers. Lastly this class forwards transactions received on the transactions_proposed streams to any subscribers. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00046">46</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div><h2 class="groupheader">Constructor &amp; Destructor Documentation</h2>
<a id="ab1d5d18e9c9a341618d3fceb3bc2e007"></a>
<h2 class="memtitle"><span class="permalink"><a href="#ab1d5d18e9c9a341618d3fceb3bc2e007">&#9670;&nbsp;</a></span>ETLSource() <span class="overload">[1/2]</span></h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">ripple::ETLSource::ETLSource </td>
<td>(</td>
<td class="paramtype"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td>
<td class="paramname"><em>ip</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td>
<td class="paramname"><em>wsPort</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype"><a class="el" href="classripple_1_1ReportingETL.html">ReportingETL</a> &amp;&#160;</td>
<td class="paramname"><em>etl</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Create ETL source without gRPC endpoint Fetch ledger and load initial ledger will fail for this source Primarly used in read-only mode, to monitor when ledgers are validated. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00031">31</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="a5cce50ac6cd85499569de58d619cda61"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a5cce50ac6cd85499569de58d619cda61">&#9670;&nbsp;</a></span>ETLSource() <span class="overload">[2/2]</span></h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">ripple::ETLSource::ETLSource </td>
<td>(</td>
<td class="paramtype"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td>
<td class="paramname"><em>ip</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td>
<td class="paramname"><em>wsPort</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a>&#160;</td>
<td class="paramname"><em>grpcPort</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype"><a class="el" href="classripple_1_1ReportingETL.html">ReportingETL</a> &amp;&#160;</td>
<td class="paramname"><em>etl</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Create ETL source with gRPC endpoint. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00047">47</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<h2 class="groupheader">Member Function Documentation</h2>
<a id="a03795cc29af78921ecb3ddcd78ffd7d6"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a03795cc29af78921ecb3ddcd78ffd7d6">&#9670;&nbsp;</a></span>isConnected()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">bool ripple::ETLSource::isConnected </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00100">100</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="ac2925e6a666f7447249e4819d85ecde3"></a>
<h2 class="memtitle"><span class="permalink"><a href="#ac2925e6a666f7447249e4819d85ecde3">&#9670;&nbsp;</a></span>getLastMsgTime()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">std::chrono::system_clock::time_point ripple::ETLSource::getLastMsgTime </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00106">106</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a7b7bffe16b2046e6e7ab185743cfce23"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a7b7bffe16b2046e6e7ab185743cfce23">&#9670;&nbsp;</a></span>setLastMsgTime()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::setLastMsgTime </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00113">113</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a6d307c73ffadd9d140cc9be89d0e132f"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a6d307c73ffadd9d140cc9be89d0e132f">&#9670;&nbsp;</a></span>hasLedger()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">bool ripple::ETLSource::hasLedger </td>
<td>(</td>
<td class="paramtype">uint32_t&#160;</td>
<td class="paramname"><em>sequence</em></td><td>)</td>
<td> const</td>
</tr>
</table>
</div><div class="memdoc">
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">sequence</td><td>ledger sequence to check for </td></tr>
</table>
</dd>
</dl>
<dl class="section return"><dt>Returns</dt><dd>true if this source has the desired ledger </dd></dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00134">134</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a424ba3ef3a05a7b362d009d782c4c401"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a424ba3ef3a05a7b362d009d782c4c401">&#9670;&nbsp;</a></span>setValidatedRange()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::setValidatedRange </td>
<td>(</td>
<td class="paramtype"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> const &amp;&#160;</td>
<td class="paramname"><em>range</em></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p>process the validated range received on the ledgers stream. </p>
<p>set the appropriate member variable </p><dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">range</td><td>validated range received on ledgers stream </td></tr>
</table>
</dd>
</dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00158">158</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a28220cc0d9a88604a7f09d22d2db31a2"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a28220cc0d9a88604a7f09d22d2db31a2">&#9670;&nbsp;</a></span>getValidatedRange()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> ripple::ETLSource::getValidatedRange </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</div><div class="memdoc">
<dl class="section return"><dt>Returns</dt><dd>the validated range of this source </dd></dl>
<dl class="section note"><dt>Note</dt><dd>this is only used by server_info </dd></dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00195">195</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="aa307e19103297ad9d70fdf94eb70b8f6"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aa307e19103297ad9d70fdf94eb70b8f6">&#9670;&nbsp;</a></span>stop()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::stop </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Close the underlying websocket. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00204">204</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a2d123c85def3519d79a361b7bd1fac2c"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a2d123c85def3519d79a361b7bd1fac2c">&#9670;&nbsp;</a></span>fetchLedger()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/utility/pair.html">std::pair</a>&lt; grpc::Status, org::xrpl::rpc::v1::GetLedgerResponse &gt; ripple::ETLSource::fetchLedger </td>
<td>(</td>
<td class="paramtype">uint32_t&#160;</td>
<td class="paramname"><em>ledgerSequence</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">bool&#160;</td>
<td class="paramname"><em>getObjects</em> = <code>true</code>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Fetch the specified ledger. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">ledgerSequence</td><td>sequence of the ledger to fetch @getObjects whether to get the account state diff between this ledger and the prior one </td></tr>
</table>
</dd>
</dl>
<dl class="section return"><dt>Returns</dt><dd>the extracted data and the result status </dd></dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00624">624</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="abf5f2105ddf1850622bbb9d386a8075d"></a>
<h2 class="memtitle"><span class="permalink"><a href="#abf5f2105ddf1850622bbb9d386a8075d">&#9670;&nbsp;</a></span>toString()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> ripple::ETLSource::toString </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00222">222</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="acf3ccf53068788d7393696d6e8c54056"></a>
<h2 class="memtitle"><span class="permalink"><a href="#acf3ccf53068788d7393696d6e8c54056">&#9670;&nbsp;</a></span>toJson()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classJson_1_1Value.html">Json::Value</a> ripple::ETLSource::toJson </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00230">230</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="ad21a9afeb41497be4d2ae77582ca9f1a"></a>
<h2 class="memtitle"><span class="permalink"><a href="#ad21a9afeb41497be4d2ae77582ca9f1a">&#9670;&nbsp;</a></span>loadInitialLedger()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">bool ripple::ETLSource::loadInitialLedger </td>
<td>(</td>
<td class="paramtype">uint32_t&#160;</td>
<td class="paramname"><em>ledgerSequence</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype"><a class="el" href="classripple_1_1ThreadSafeQueue.html">ThreadSafeQueue</a>&lt; <a class="elRef" href="http://en.cppreference.com/w/cpp/memory/shared_ptr.html">std::shared_ptr</a>&lt; <a class="el" href="namespaceripple.html#abbba3966df1925ac76f6d04c0aa1abe3">SLE</a> &gt;&gt; &amp;&#160;</td>
<td class="paramname"><em>writeQueue</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Download a ledger in full. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">ledgerSequence</td><td>sequence of the ledger to download </td></tr>
<tr><td class="paramname">writeQueue</td><td>queue to push downloaded ledger objects </td></tr>
</table>
</dd>
</dl>
<dl class="section return"><dt>Returns</dt><dd>true if the download was successful </dd></dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00557">557</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="a64b2f303ab2c62d02c10a8c9a2bee591"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a64b2f303ab2c62d02c10a8c9a2bee591">&#9670;&nbsp;</a></span>start()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::start </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Begin sequence of operations to connect to the ETL source and subscribe to ledgers and transactions_proposed. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00170">170</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="aa96a2d2ce4143bb7b03c4745faa2f5df"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aa96a2d2ce4143bb7b03c4745faa2f5df">&#9670;&nbsp;</a></span>reconnect()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::reconnect </td>
<td>(</td>
<td class="paramtype">boost::beast::error_code&#160;</td>
<td class="paramname"><em>ec</em></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Attempt to reconnect to the ETL source. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00098">98</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="a969d79e2cecc2f3c9e67b7484651a286"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a969d79e2cecc2f3c9e67b7484651a286">&#9670;&nbsp;</a></span>onResolve()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::onResolve </td>
<td>(</td>
<td class="paramtype">boost::beast::error_code&#160;</td>
<td class="paramname"><em>ec</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">boost::asio::ip::tcp::resolver::results_type&#160;</td>
<td class="paramname"><em>results</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Callback. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00182">182</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="a0e5cb59e78b5fbff15dfe9d99d78f171"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a0e5cb59e78b5fbff15dfe9d99d78f171">&#9670;&nbsp;</a></span>onConnect()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::onConnect </td>
<td>(</td>
<td class="paramtype">boost::beast::error_code&#160;</td>
<td class="paramname"><em>ec</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">boost::asio::ip::tcp::resolver::results_type::endpoint_type&#160;</td>
<td class="paramname"><em>endpoint</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Callback. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00203">203</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="af11b24e2418e645b0fc27b9b7a02431d"></a>
<h2 class="memtitle"><span class="permalink"><a href="#af11b24e2418e645b0fc27b9b7a02431d">&#9670;&nbsp;</a></span>onHandshake()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::onHandshake </td>
<td>(</td>
<td class="paramtype">boost::beast::error_code&#160;</td>
<td class="paramname"><em>ec</em></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Callback. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00245">245</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="ac910115aedc2a23c42fee581b1431f24"></a>
<h2 class="memtitle"><span class="permalink"><a href="#ac910115aedc2a23c42fee581b1431f24">&#9670;&nbsp;</a></span>onWrite()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::onWrite </td>
<td>(</td>
<td class="paramtype">boost::beast::error_code&#160;</td>
<td class="paramname"><em>ec</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">size_t&#160;</td>
<td class="paramname"><em>size</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Callback. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00279">279</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="a81b42d9b583c644d981d3d5fc1446a74"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a81b42d9b583c644d981d3d5fc1446a74">&#9670;&nbsp;</a></span>onRead()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::onRead </td>
<td>(</td>
<td class="paramtype">boost::beast::error_code&#160;</td>
<td class="paramname"><em>ec</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">size_t&#160;</td>
<td class="paramname"><em>size</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Callback. </p>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00296">296</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="a558b110180f15704b284c145aacdd50c"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a558b110180f15704b284c145aacdd50c">&#9670;&nbsp;</a></span>handleMessage()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">bool ripple::ETLSource::handleMessage </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Handle the most recently received message. </p>
<dl class="section return"><dt>Returns</dt><dd>true if the message was handled successfully. false on error </dd></dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00319">319</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="aa2a46267da6ac73174215a3a2e9fe5e1"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aa2a46267da6ac73174215a3a2e9fe5e1">&#9670;&nbsp;</a></span>close()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname">void ripple::ETLSource::close </td>
<td>(</td>
<td class="paramtype">bool&#160;</td>
<td class="paramname"><em>startAgain</em></td><td>)</td>
<td></td>
</tr>
</table>
</div><div class="memdoc">
<p>Close the websocket. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">startAgain</td><td>whether to reconnect </td></tr>
</table>
</dd>
</dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00135">135</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="aa8830854039b446a7fbae5ed16db238d"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aa8830854039b446a7fbae5ed16db238d">&#9670;&nbsp;</a></span>getP2pForwardingStub()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html">std::unique_ptr</a>&lt; org::xrpl::rpc::v1::XRPLedgerAPIService::Stub &gt; ripple::ETLSource::getP2pForwardingStub </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</div><div class="memdoc">
<p>Get grpc stub to forward requests to p2p node. </p>
<dl class="section return"><dt>Returns</dt><dd>stub to send requests to ETL source </dd></dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00791">791</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<a id="adcb2c4b9bde51549a959c576533a1418"></a>
<h2 class="memtitle"><span class="permalink"><a href="#adcb2c4b9bde51549a959c576533a1418">&#9670;&nbsp;</a></span>forwardToP2p()</h2>
<div class="memitem">
<div class="memproto">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classJson_1_1Value.html">Json::Value</a> ripple::ETLSource::forwardToP2p </td>
<td>(</td>
<td class="paramtype"><a class="el" href="structripple_1_1RPC_1_1JsonContext.html">RPC::JsonContext</a> &amp;&#160;</td>
<td class="paramname"><em>context</em></td><td>)</td>
<td> const</td>
</tr>
</table>
</div><div class="memdoc">
<p>Forward a JSON <a class="el" href="namespaceripple_1_1RPC.html">RPC</a> request to a p2p node. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">context</td><td>context of <a class="el" href="namespaceripple_1_1RPC.html">RPC</a> request </td></tr>
</table>
</dd>
</dl>
<dl class="section return"><dt>Returns</dt><dd>response received from ETL source </dd></dl>
<p class="definition">Definition at line <a class="el" href="ETLSource_8cpp_source.html#l00812">812</a> of file <a class="el" href="ETLSource_8cpp_source.html">ETLSource.cpp</a>.</p>
</div>
</div>
<h2 class="groupheader">Member Data Documentation</h2>
<a id="ae64030c4845b53a75bf8f9921d38ed92"></a>
<h2 class="memtitle"><span class="permalink"><a href="#ae64030c4845b53a75bf8f9921d38ed92">&#9670;&nbsp;</a></span>ip_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> ripple::ETLSource::ip_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00048">48</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a53b3ebda1673cadb074f2345098639e0"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a53b3ebda1673cadb074f2345098639e0">&#9670;&nbsp;</a></span>wsPort_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> ripple::ETLSource::wsPort_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00050">50</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="af7b53b6e2f95a1fe500fe0fc487a76e6"></a>
<h2 class="memtitle"><span class="permalink"><a href="#af7b53b6e2f95a1fe500fe0fc487a76e6">&#9670;&nbsp;</a></span>grpcPort_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> ripple::ETLSource::grpcPort_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00052">52</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a73d3c7364a78905eb760de5b9045aec1"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a73d3c7364a78905eb760de5b9045aec1">&#9670;&nbsp;</a></span>etl_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classripple_1_1ReportingETL.html">ReportingETL</a>&amp; ripple::ETLSource::etl_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00054">54</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="aa54b0606a7328fb1efaf415e9c43b8be"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aa54b0606a7328fb1efaf415e9c43b8be">&#9670;&nbsp;</a></span>ioc_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">boost::asio::io_context&amp; ripple::ETLSource::ioc_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00057">57</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="ae15dd2e3190676aa238ce5a097cd585a"></a>
<h2 class="memtitle"><span class="permalink"><a href="#ae15dd2e3190676aa238ce5a097cd585a">&#9670;&nbsp;</a></span>stub_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html">std::unique_ptr</a>&lt;org::xrpl::rpc::v1::XRPLedgerAPIService::Stub&gt; ripple::ETLSource::stub_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00059">59</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a9c7824f2491a78cc672187f958f07231"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a9c7824f2491a78cc672187f958f07231">&#9670;&nbsp;</a></span>ws_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/memory/unique_ptr.html">std::unique_ptr</a>&lt;boost::beast::websocket::stream&lt;boost::beast::tcp_stream&gt; &gt; ripple::ETLSource::ws_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00062">62</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a0bd7f579df90324230b7db70d900182f"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a0bd7f579df90324230b7db70d900182f">&#9670;&nbsp;</a></span>resolver_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">boost::asio::ip::tcp::resolver ripple::ETLSource::resolver_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00063">63</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="ad4c1ef03bbc180d9ac1356adc9240d11"></a>
<h2 class="memtitle"><span class="permalink"><a href="#ad4c1ef03bbc180d9ac1356adc9240d11">&#9670;&nbsp;</a></span>readBuffer_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">boost::beast::flat_buffer ripple::ETLSource::readBuffer_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00065">65</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="aa3755579e2ba263f23f54a57db0b3666"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aa3755579e2ba263f23f54a57db0b3666">&#9670;&nbsp;</a></span>validatedLedgers_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/container/vector.html">std::vector</a>&lt;<a class="elRef" href="http://en.cppreference.com/w/cpp/utility/pair.html">std::pair</a>&lt;uint32_t, uint32_t&gt; &gt; ripple::ETLSource::validatedLedgers_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00067">67</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a2b9e864ef6e865e1dbebdbee4442e638"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a2b9e864ef6e865e1dbebdbee4442e638">&#9670;&nbsp;</a></span>validatedLedgersRaw_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/string/basic_string.html">std::string</a> ripple::ETLSource::validatedLedgersRaw_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00069">69</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a8c78222865586b628b0ae391effdfe42"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a8c78222865586b628b0ae391effdfe42">&#9670;&nbsp;</a></span>networkValidatedLedgers_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classripple_1_1NetworkValidatedLedgers.html">NetworkValidatedLedgers</a>&amp; ripple::ETLSource::networkValidatedLedgers_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00071">71</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a547632f1053f5368243ea454d0820fb0"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a547632f1053f5368243ea454d0820fb0">&#9670;&nbsp;</a></span>journal_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classbeast_1_1Journal.html">beast::Journal</a> ripple::ETLSource::journal_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00073">73</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a39336445d396d94821915db6ada02898"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a39336445d396d94821915db6ada02898">&#9670;&nbsp;</a></span>app_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classripple_1_1Application.html">Application</a>&amp; ripple::ETLSource::app_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00075">75</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a7e0e79325d9bfe87ca75eba3827d83fc"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a7e0e79325d9bfe87ca75eba3827d83fc">&#9670;&nbsp;</a></span>mtx_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/thread/mutex.html">std::mutex</a> ripple::ETLSource::mtx_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">mutable</span><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00077">77</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a1bae8214216046e47a89e1b62bc53f7c"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a1bae8214216046e47a89e1b62bc53f7c">&#9670;&nbsp;</a></span>numFailures_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">size_t ripple::ETLSource::numFailures_ = 0</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00079">79</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a0eb09ff484c8d2f08e8a95df1503d90e"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a0eb09ff484c8d2f08e8a95df1503d90e">&#9670;&nbsp;</a></span>closing_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/atomic/atomic.html">std::atomic_bool</a> ripple::ETLSource::closing_ = false</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00081">81</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a0c13d997d62673803f96b5b24c67911c"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a0c13d997d62673803f96b5b24c67911c">&#9670;&nbsp;</a></span>connected_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/atomic/atomic.html">std::atomic_bool</a> ripple::ETLSource::connected_ = false</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00083">83</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a9bad0ca9e0868ee21a0dc1d6dc7c8326"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a9bad0ca9e0868ee21a0dc1d6dc7c8326">&#9670;&nbsp;</a></span>forwardingStream_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/atomic/atomic.html">std::atomic_bool</a> ripple::ETLSource::forwardingStream_ = false</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00089">89</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a154e5ba2bc868e7c66fb7f559ee6e460"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a154e5ba2bc868e7c66fb7f559ee6e460">&#9670;&nbsp;</a></span>lastMsgTime_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">std::chrono::system_clock::time_point ripple::ETLSource::lastMsgTime_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00092">92</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="a67dfbed5ae9ffa05649bc0c350f8d012"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a67dfbed5ae9ffa05649bc0c350f8d012">&#9670;&nbsp;</a></span>lastMsgTimeMtx_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="elRef" href="http://en.cppreference.com/w/cpp/thread/mutex.html">std::mutex</a> ripple::ETLSource::lastMsgTimeMtx_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">mutable</span><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00093">93</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
<a id="aea155c0ce7f36229af7cb6a58dad2be8"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aea155c0ce7f36229af7cb6a58dad2be8">&#9670;&nbsp;</a></span>timer_</h2>
<div class="memitem">
<div class="memproto">
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">boost::asio::steady_timer ripple::ETLSource::timer_</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">private</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p class="definition">Definition at line <a class="el" href="ETLSource_8h_source.html#l00096">96</a> of file <a class="el" href="ETLSource_8h_source.html">ETLSource.h</a>.</p>
</div>
</div>
</div><!-- contents -->
<!-- start footer part -->
<hr class="footer"/><address class="footer"><small>
Generated by &#160;<a href="http://www.doxygen.org/index.html">
<img class="footer" src="doxygen.png" alt="doxygen"/>
</a> 1.8.17
</small></address>
</body>
</html>
Reference in New Issue View Git Blame Copy Permalink