Struct PluginNodeServer

pub struct PluginNodeServer {
    pub tls: ServerTlsConfig,
    pub stage: Arc<Stage>,
    pub rpc: Arc<Mutex<LightningClient>>,
    pub ctx: Context,
    /* private fields */
}

The PluginNodeServer is the interface that is exposed to client devices and is in charge of coordinating the various user-controlled entities. This includes dispatching incoming RPC calls to the JSON-RPC interface, as well as staging requests from the HSM so that they can be streamed and replied to by devices that have access to the signing keys.

Fields

tls: ServerTlsConfig

stage: Arc<Stage>

rpc: Arc<Mutex<LightningClient>>

ctx: Context

Implementations

impl PluginNodeServer

pub async fn new( stage: Arc<Stage>, config: Config, events: Sender<Event>, signer_state_store: Box<dyn StateStore>, ) -> Result<Self, Error>

pub async fn limit(&self)

pub async fn get_rpc(&self) -> LightningClient

impl PluginNodeServer

pub async fn run(self) -> Result<()>

pub async fn reconnect_peers(&self) -> Result<(), Error>

Reconnect all peers with whom we have a channel or previously connected explicitly to.

Trait Implementations

impl Clone for PluginNodeServer

fn clone(&self) -> PluginNodeServer

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Node for PluginNodeServer

type StreamCustommsgStream = ReceiverStream<Result<Custommsg, Status>>

Server streaming response type for the StreamCustommsg method.

type StreamHsmRequestsStream = ReceiverStream<Result<HsmRequest, Status>>

Server streaming response type for the StreamHsmRequests method.

type StreamLogStream = ReceiverStream<Result<LogEntry, Status>>

Server streaming response type for the StreamLog method.

type StreamIncomingStream = ReceiverStream<Result<IncomingPayment, Status>>

Server streaming response type for the StreamIncoming method.

fn stream_custommsg<'life0, 'async_trait>( &'life0 self, __arg1: Request<StreamCustommsgRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamCustommsgStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Listen for incoming custommsg messages from peers.

fn stream_log<'life0, 'async_trait>( &'life0 self, __arg1: Request<StreamLogRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamLogStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stream the logs as they are produced by the node

fn stream_hsm_requests<'life0, 'async_trait>( &'life0 self, _request: Request<Empty>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamHsmRequestsStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

////////////////////////////// HSM Messages ////////////////////////

fn respond_hsm_request<'life0, 'async_trait>( &'life0 self, request: Request<HsmResponse>, ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stream_incoming<'life0, 'async_trait>( &'life0 self, _req: Request<StreamIncomingFilter>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamIncomingStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stream incoming payments

fn configure<'life0, 'async_trait>( &'life0 self, req: Request<GlConfig>, ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn trampoline_pay<'life0, 'async_trait>( &'life0 self, r: Request<TrampolinePayRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TrampolinePayResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,