remote< rmt::Loopback >

Description

Vars

std::map< key_t, ptr < i_data_server < rmt::Loopback > > >

registered_data_servers_

std::map< key_t, ptr < i_rpc_server < rmt::Loopback > > >

registered_rpc_servers_

Methods

error_or < void >

find_data_servers_ele ( typename rpc_server < Iface, Encoding, rmt::Loopback >::DataServers &, ref < remote_address < rmt::Loopback > > )

error_or < typename rpc_server < Iface, Encoding, rmt::Loopback >::DataServers >

find_data_servers ( ref < remote_address < rmt::Loopback > > )

error_or < own< remote_address < rmt::Loopback > > >

parse_address ( data < schema::UInt64 > )

conveyor < rpc_client < Iface, Encode, rmt::Loopback > >

rpc_connect ( const remote_address < rmt::Loopback > & )

error_or < own< rpc_server < Iface, Encode, rmt::Loopback > > >

rpc_listen ( remote_address < rmt::Loopback > &, typename rpc_server < Iface, Encode, rmt::Loopback >::InterfaceT )

error_or < own< data_server < Schema, Encode, rmt::Loopback > > >

data_listen ( const remote_address < rmt::Loopback > & )

conveyor < data_client < Schema, Encode, rmt::Loopback > >

data_connect ( const remote_address < rmt::Loopback > & )

error_or < void >

register_data_server ( const remote_address < rmt::Loopback > &, i_data_server < rmt::Loopback > & )

error_or < void >

deregister_data_server ( const remote_address < rmt::Loopback > &, i_data_server < rmt::Loopback > & )


Vars Description

std::map< key_t, ptr < i_data_server < rmt::Loopback > > > registered_data_servers_


std::map< key_t, ptr < i_rpc_server < rmt::Loopback > > > registered_rpc_servers_


Methods Description

error_or < void > find_data_servers_ele ( typename rpc_server < Iface, Encoding, rmt::Loopback >::DataServers &, ref < remote_address < rmt::Loopback > > )


error_or < typename rpc_server < Iface, Encoding, rmt::Loopback >::DataServers > find_data_servers ( ref < remote_address < rmt::Loopback > > )


error_or < own< remote_address < rmt::Loopback > > > parse_address ( data < schema::UInt64 > )

Resolves an address for the remote

conveyor < rpc_client < Iface, Encode, rmt::Loopback > > rpc_connect ( const remote_address < rmt::Loopback > & )

Connect to a remote

error_or < own< rpc_server < Iface, Encode, rmt::Loopback > > > rpc_listen ( remote_address < rmt::Loopback > &, typename rpc_server < Iface, Encode, rmt::Loopback >::InterfaceT )

Start listening

error_or < own< data_server < Schema, Encode, rmt::Loopback > > > data_listen ( const remote_address < rmt::Loopback > & )

Start data server

conveyor < data_client < Schema, Encode, rmt::Loopback > > data_connect ( const remote_address < rmt::Loopback > & )

Connect to a data server

error_or < void > register_data_server ( const remote_address < rmt::Loopback > &, i_data_server < rmt::Loopback > & )

Internal function

error_or < void > deregister_data_server ( const remote_address < rmt::Loopback > &, i_data_server < rmt::Loopback > & )