Struct moonramp_wallet_rpc::WalletRpcService

pub struct WalletRpcService { /* private fields */ }

Implementations

impl WalletRpcService

pub fn new(
    node_id: NodeId,
    kek_custodian: Arc<KeyEncryptionKeyCustodian>,
    database: DatabaseConnection,
    _bitcoin_rpc_endpoint: String,
    _bitcoin_rpc_auth: String,
    network: Network
) -> Result<(NetworkTunnelSender, Arc<Self>)>

Trait Implementations

impl RpcService<WalletRpcImpl> for WalletRpcService

fn log_target(&self) -> String

fn node_id(&self) -> NodeId

fn service_name(&self) -> TunnelName

fn rx(&self) -> Arc<RwLock<NetworkTunnelReceiver>>

fn rpc(&self) -> RpcModule<WalletRpcImpl>

fn boot_initialize<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn metrics_behavior<'life0, 'async_trait>(
    &'life0 self,
    state: RpcServiceState<R>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn housekeeping_behavior<'life0, 'async_trait>(
    &'life0 self,
    state: RpcServiceState<R>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn stats_behavior<'life0, 'async_trait>(
    &'life0 self,
    state: RpcServiceState<R>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn listen<'async_trait>(
    self: Arc<Self>,
    shutdown_rx: Receiver<bool>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>> where
    Self: 'async_trait, 

fn handle_public_network_rx<'async_trait>(
    state: RpcServiceState<R>,
    response_tx: NetworkTunnelChannel,
    msg: NetworkTunnel
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>

fn handle_response<'async_trait>(
    state: RpcServiceState<R>,
    msg: NetworkTunnel,
    tunnel_msg: RpcTunnel
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>