NodeClient

gl_client::pb::cln::node_client

Struct NodeClient 

Source 
pub struct NodeClient<T> { /* private fields */ }

Implementations§

Source§

impl NodeClient<Channel>

Source

pub async fn connect<D>(dst: D) -> Result<NodeClient<Channel>, Error>
where D: TryInto<Endpoint>, <D as TryInto<Endpoint>>::Error: Into<Box<dyn Error + Send + Sync>>,

Attempt to create a new client by connecting to a given endpoint.

Source§

impl<T> NodeClient<T>
where T: GrpcService<UnsyncBoxBody<Bytes, Status>>, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::Error: Into<Box<dyn Error + Send + Sync>>, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody: Body<Data = Bytes> + Send + 'static, <<T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Send + Sync>> + Send,

Source

pub fn new(inner: T) -> NodeClient<T>

Source

pub fn with_origin(inner: T, origin: Uri) -> NodeClient<T>

Source

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> NodeClient<InterceptedService<T, F>>
where F: Interceptor, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody: Default, T: Service<Request<UnsyncBoxBody<Bytes, Status>>, Response = Response<<T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody>>, <T as Service<Request<UnsyncBoxBody<Bytes, Status>>>>::Error: Into<Box<dyn Error + Send + Sync>> + Send + Sync,

Source

pub fn send_compressed(self, encoding: CompressionEncoding) -> NodeClient<T>

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

Source

pub fn accept_compressed(self, encoding: CompressionEncoding) -> NodeClient<T>

Enable decompressing responses.

Source

pub fn max_decoding_message_size(self, limit: usize) -> NodeClient<T>

Limits the maximum size of a decoded message.

Default: 4MB

Source

pub fn max_encoding_message_size(self, limit: usize) -> NodeClient<T>

Limits the maximum size of an encoded message.

Default: usize::MAX

Source

pub async fn getinfo( &mut self, request: impl IntoRequest<GetinfoRequest>, ) -> Result<Response<GetinfoResponse>, Status>

Source

pub async fn list_peers( &mut self, request: impl IntoRequest<ListpeersRequest>, ) -> Result<Response<ListpeersResponse>, Status>

Source

pub async fn list_funds( &mut self, request: impl IntoRequest<ListfundsRequest>, ) -> Result<Response<ListfundsResponse>, Status>

Source

pub async fn send_pay( &mut self, request: impl IntoRequest<SendpayRequest>, ) -> Result<Response<SendpayResponse>, Status>

Source

pub async fn list_channels( &mut self, request: impl IntoRequest<ListchannelsRequest>, ) -> Result<Response<ListchannelsResponse>, Status>

Source

pub async fn add_gossip( &mut self, request: impl IntoRequest<AddgossipRequest>, ) -> Result<Response<AddgossipResponse>, Status>

Source

pub async fn add_psbt_output( &mut self, request: impl IntoRequest<AddpsbtoutputRequest>, ) -> Result<Response<AddpsbtoutputResponse>, Status>

Source

pub async fn auto_clean_once( &mut self, request: impl IntoRequest<AutocleanonceRequest>, ) -> Result<Response<AutocleanonceResponse>, Status>

Source

pub async fn auto_clean_status( &mut self, request: impl IntoRequest<AutocleanstatusRequest>, ) -> Result<Response<AutocleanstatusResponse>, Status>

Source

pub async fn check_message( &mut self, request: impl IntoRequest<CheckmessageRequest>, ) -> Result<Response<CheckmessageResponse>, Status>

Source

pub async fn close( &mut self, request: impl IntoRequest<CloseRequest>, ) -> Result<Response<CloseResponse>, Status>

Source

pub async fn connect_peer( &mut self, request: impl IntoRequest<ConnectRequest>, ) -> Result<Response<ConnectResponse>, Status>

Source

pub async fn create_invoice( &mut self, request: impl IntoRequest<CreateinvoiceRequest>, ) -> Result<Response<CreateinvoiceResponse>, Status>

Source

pub async fn datastore( &mut self, request: impl IntoRequest<DatastoreRequest>, ) -> Result<Response<DatastoreResponse>, Status>

Source

pub async fn datastore_usage( &mut self, request: impl IntoRequest<DatastoreusageRequest>, ) -> Result<Response<DatastoreusageResponse>, Status>

Source

pub async fn create_onion( &mut self, request: impl IntoRequest<CreateonionRequest>, ) -> Result<Response<CreateonionResponse>, Status>

Source

pub async fn del_datastore( &mut self, request: impl IntoRequest<DeldatastoreRequest>, ) -> Result<Response<DeldatastoreResponse>, Status>

Source

pub async fn del_invoice( &mut self, request: impl IntoRequest<DelinvoiceRequest>, ) -> Result<Response<DelinvoiceResponse>, Status>

Source

pub async fn dev_forget_channel( &mut self, request: impl IntoRequest<DevforgetchannelRequest>, ) -> Result<Response<DevforgetchannelResponse>, Status>

Source

pub async fn emergency_recover( &mut self, request: impl IntoRequest<EmergencyrecoverRequest>, ) -> Result<Response<EmergencyrecoverResponse>, Status>

Source

pub async fn get_emergency_recover_data( &mut self, request: impl IntoRequest<GetemergencyrecoverdataRequest>, ) -> Result<Response<GetemergencyrecoverdataResponse>, Status>

Source

pub async fn expose_secret( &mut self, request: impl IntoRequest<ExposesecretRequest>, ) -> Result<Response<ExposesecretResponse>, Status>

Source

pub async fn recover( &mut self, request: impl IntoRequest<RecoverRequest>, ) -> Result<Response<RecoverResponse>, Status>

Source

pub async fn recover_channel( &mut self, request: impl IntoRequest<RecoverchannelRequest>, ) -> Result<Response<RecoverchannelResponse>, Status>

Source

pub async fn invoice( &mut self, request: impl IntoRequest<InvoiceRequest>, ) -> Result<Response<InvoiceResponse>, Status>

Source

pub async fn create_invoice_request( &mut self, request: impl IntoRequest<InvoicerequestRequest>, ) -> Result<Response<InvoicerequestResponse>, Status>

Source

pub async fn disable_invoice_request( &mut self, request: impl IntoRequest<DisableinvoicerequestRequest>, ) -> Result<Response<DisableinvoicerequestResponse>, Status>

Source

pub async fn list_invoice_requests( &mut self, request: impl IntoRequest<ListinvoicerequestsRequest>, ) -> Result<Response<ListinvoicerequestsResponse>, Status>

Source

pub async fn list_datastore( &mut self, request: impl IntoRequest<ListdatastoreRequest>, ) -> Result<Response<ListdatastoreResponse>, Status>

Source

pub async fn list_invoices( &mut self, request: impl IntoRequest<ListinvoicesRequest>, ) -> Result<Response<ListinvoicesResponse>, Status>

Source

pub async fn send_onion( &mut self, request: impl IntoRequest<SendonionRequest>, ) -> Result<Response<SendonionResponse>, Status>

Source

pub async fn list_send_pays( &mut self, request: impl IntoRequest<ListsendpaysRequest>, ) -> Result<Response<ListsendpaysResponse>, Status>

Source

pub async fn list_transactions( &mut self, request: impl IntoRequest<ListtransactionsRequest>, ) -> Result<Response<ListtransactionsResponse>, Status>

Source

pub async fn make_secret( &mut self, request: impl IntoRequest<MakesecretRequest>, ) -> Result<Response<MakesecretResponse>, Status>

Source

pub async fn pay( &mut self, request: impl IntoRequest<PayRequest>, ) -> Result<Response<PayResponse>, Status>

Source

pub async fn list_nodes( &mut self, request: impl IntoRequest<ListnodesRequest>, ) -> Result<Response<ListnodesResponse>, Status>

Source

pub async fn wait_any_invoice( &mut self, request: impl IntoRequest<WaitanyinvoiceRequest>, ) -> Result<Response<WaitanyinvoiceResponse>, Status>

Source

pub async fn wait_invoice( &mut self, request: impl IntoRequest<WaitinvoiceRequest>, ) -> Result<Response<WaitinvoiceResponse>, Status>

Source

pub async fn wait_send_pay( &mut self, request: impl IntoRequest<WaitsendpayRequest>, ) -> Result<Response<WaitsendpayResponse>, Status>

Source

pub async fn new_addr( &mut self, request: impl IntoRequest<NewaddrRequest>, ) -> Result<Response<NewaddrResponse>, Status>

Source

pub async fn withdraw( &mut self, request: impl IntoRequest<WithdrawRequest>, ) -> Result<Response<WithdrawResponse>, Status>

Source

pub async fn key_send( &mut self, request: impl IntoRequest<KeysendRequest>, ) -> Result<Response<KeysendResponse>, Status>

Source

pub async fn fund_psbt( &mut self, request: impl IntoRequest<FundpsbtRequest>, ) -> Result<Response<FundpsbtResponse>, Status>

Source

pub async fn send_psbt( &mut self, request: impl IntoRequest<SendpsbtRequest>, ) -> Result<Response<SendpsbtResponse>, Status>

Source

pub async fn sign_psbt( &mut self, request: impl IntoRequest<SignpsbtRequest>, ) -> Result<Response<SignpsbtResponse>, Status>

Source

pub async fn utxo_psbt( &mut self, request: impl IntoRequest<UtxopsbtRequest>, ) -> Result<Response<UtxopsbtResponse>, Status>

Source

pub async fn tx_discard( &mut self, request: impl IntoRequest<TxdiscardRequest>, ) -> Result<Response<TxdiscardResponse>, Status>

Source

pub async fn tx_prepare( &mut self, request: impl IntoRequest<TxprepareRequest>, ) -> Result<Response<TxprepareResponse>, Status>

Source

pub async fn tx_send( &mut self, request: impl IntoRequest<TxsendRequest>, ) -> Result<Response<TxsendResponse>, Status>

Source

pub async fn list_peer_channels( &mut self, request: impl IntoRequest<ListpeerchannelsRequest>, ) -> Result<Response<ListpeerchannelsResponse>, Status>

Source

pub async fn list_closed_channels( &mut self, request: impl IntoRequest<ListclosedchannelsRequest>, ) -> Result<Response<ListclosedchannelsResponse>, Status>

Source

pub async fn decode_pay( &mut self, request: impl IntoRequest<DecodepayRequest>, ) -> Result<Response<DecodepayResponse>, Status>

Source

pub async fn decode( &mut self, request: impl IntoRequest<DecodeRequest>, ) -> Result<Response<DecodeResponse>, Status>

Source

pub async fn del_pay( &mut self, request: impl IntoRequest<DelpayRequest>, ) -> Result<Response<DelpayResponse>, Status>

Source

pub async fn del_forward( &mut self, request: impl IntoRequest<DelforwardRequest>, ) -> Result<Response<DelforwardResponse>, Status>

Source

pub async fn disable_offer( &mut self, request: impl IntoRequest<DisableofferRequest>, ) -> Result<Response<DisableofferResponse>, Status>

Source

pub async fn enable_offer( &mut self, request: impl IntoRequest<EnableofferRequest>, ) -> Result<Response<EnableofferResponse>, Status>

Source

pub async fn disconnect( &mut self, request: impl IntoRequest<DisconnectRequest>, ) -> Result<Response<DisconnectResponse>, Status>

Source

pub async fn feerates( &mut self, request: impl IntoRequest<FeeratesRequest>, ) -> Result<Response<FeeratesResponse>, Status>

Source

pub async fn fetch_invoice( &mut self, request: impl IntoRequest<FetchinvoiceRequest>, ) -> Result<Response<FetchinvoiceResponse>, Status>

Source

pub async fn fund_channel_cancel( &mut self, request: impl IntoRequest<FundchannelCancelRequest>, ) -> Result<Response<FundchannelCancelResponse>, Status>

Source

pub async fn fund_channel_complete( &mut self, request: impl IntoRequest<FundchannelCompleteRequest>, ) -> Result<Response<FundchannelCompleteResponse>, Status>

Source

pub async fn fund_channel( &mut self, request: impl IntoRequest<FundchannelRequest>, ) -> Result<Response<FundchannelResponse>, Status>

Source

pub async fn fund_channel_start( &mut self, request: impl IntoRequest<FundchannelStartRequest>, ) -> Result<Response<FundchannelStartResponse>, Status>

Source

pub async fn get_log( &mut self, request: impl IntoRequest<GetlogRequest>, ) -> Result<Response<GetlogResponse>, Status>

Source

pub async fn funder_update( &mut self, request: impl IntoRequest<FunderupdateRequest>, ) -> Result<Response<FunderupdateResponse>, Status>

Source

pub async fn get_route( &mut self, request: impl IntoRequest<GetrouteRequest>, ) -> Result<Response<GetrouteResponse>, Status>

Source

pub async fn list_addresses( &mut self, request: impl IntoRequest<ListaddressesRequest>, ) -> Result<Response<ListaddressesResponse>, Status>

Source

pub async fn list_forwards( &mut self, request: impl IntoRequest<ListforwardsRequest>, ) -> Result<Response<ListforwardsResponse>, Status>

Source

pub async fn list_offers( &mut self, request: impl IntoRequest<ListoffersRequest>, ) -> Result<Response<ListoffersResponse>, Status>

Source

pub async fn list_pays( &mut self, request: impl IntoRequest<ListpaysRequest>, ) -> Result<Response<ListpaysResponse>, Status>

Source

pub async fn list_htlcs( &mut self, request: impl IntoRequest<ListhtlcsRequest>, ) -> Result<Response<ListhtlcsResponse>, Status>

Source

pub async fn multi_fund_channel( &mut self, request: impl IntoRequest<MultifundchannelRequest>, ) -> Result<Response<MultifundchannelResponse>, Status>

Source

pub async fn multi_withdraw( &mut self, request: impl IntoRequest<MultiwithdrawRequest>, ) -> Result<Response<MultiwithdrawResponse>, Status>

Source

pub async fn offer( &mut self, request: impl IntoRequest<OfferRequest>, ) -> Result<Response<OfferResponse>, Status>

Source

pub async fn open_channel_abort( &mut self, request: impl IntoRequest<OpenchannelAbortRequest>, ) -> Result<Response<OpenchannelAbortResponse>, Status>

Source

pub async fn open_channel_bump( &mut self, request: impl IntoRequest<OpenchannelBumpRequest>, ) -> Result<Response<OpenchannelBumpResponse>, Status>

Source

pub async fn open_channel_init( &mut self, request: impl IntoRequest<OpenchannelInitRequest>, ) -> Result<Response<OpenchannelInitResponse>, Status>

Source

pub async fn open_channel_signed( &mut self, request: impl IntoRequest<OpenchannelSignedRequest>, ) -> Result<Response<OpenchannelSignedResponse>, Status>

Source

pub async fn open_channel_update( &mut self, request: impl IntoRequest<OpenchannelUpdateRequest>, ) -> Result<Response<OpenchannelUpdateResponse>, Status>

Source

pub async fn ping( &mut self, request: impl IntoRequest<PingRequest>, ) -> Result<Response<PingResponse>, Status>

Source

pub async fn plugin( &mut self, request: impl IntoRequest<PluginRequest>, ) -> Result<Response<PluginResponse>, Status>

Source

pub async fn rene_pay_status( &mut self, request: impl IntoRequest<RenepaystatusRequest>, ) -> Result<Response<RenepaystatusResponse>, Status>

Source

pub async fn rene_pay( &mut self, request: impl IntoRequest<RenepayRequest>, ) -> Result<Response<RenepayResponse>, Status>

Source

pub async fn reserve_inputs( &mut self, request: impl IntoRequest<ReserveinputsRequest>, ) -> Result<Response<ReserveinputsResponse>, Status>

Source

pub async fn send_custom_msg( &mut self, request: impl IntoRequest<SendcustommsgRequest>, ) -> Result<Response<SendcustommsgResponse>, Status>

Source

pub async fn send_invoice( &mut self, request: impl IntoRequest<SendinvoiceRequest>, ) -> Result<Response<SendinvoiceResponse>, Status>

Source

pub async fn set_channel( &mut self, request: impl IntoRequest<SetchannelRequest>, ) -> Result<Response<SetchannelResponse>, Status>

Source

pub async fn set_config( &mut self, request: impl IntoRequest<SetconfigRequest>, ) -> Result<Response<SetconfigResponse>, Status>

Source

pub async fn set_psbt_version( &mut self, request: impl IntoRequest<SetpsbtversionRequest>, ) -> Result<Response<SetpsbtversionResponse>, Status>

Source

pub async fn sign_invoice( &mut self, request: impl IntoRequest<SigninvoiceRequest>, ) -> Result<Response<SigninvoiceResponse>, Status>

Source

pub async fn sign_message( &mut self, request: impl IntoRequest<SignmessageRequest>, ) -> Result<Response<SignmessageResponse>, Status>

Source

pub async fn splice_init( &mut self, request: impl IntoRequest<SpliceInitRequest>, ) -> Result<Response<SpliceInitResponse>, Status>

Source

pub async fn splice_signed( &mut self, request: impl IntoRequest<SpliceSignedRequest>, ) -> Result<Response<SpliceSignedResponse>, Status>

Source

pub async fn splice_update( &mut self, request: impl IntoRequest<SpliceUpdateRequest>, ) -> Result<Response<SpliceUpdateResponse>, Status>

Source

pub async fn dev_splice( &mut self, request: impl IntoRequest<DevspliceRequest>, ) -> Result<Response<DevspliceResponse>, Status>

Source

pub async fn unreserve_inputs( &mut self, request: impl IntoRequest<UnreserveinputsRequest>, ) -> Result<Response<UnreserveinputsResponse>, Status>

Source

pub async fn upgrade_wallet( &mut self, request: impl IntoRequest<UpgradewalletRequest>, ) -> Result<Response<UpgradewalletResponse>, Status>

Source

pub async fn wait_block_height( &mut self, request: impl IntoRequest<WaitblockheightRequest>, ) -> Result<Response<WaitblockheightResponse>, Status>

Source

pub async fn wait( &mut self, request: impl IntoRequest<WaitRequest>, ) -> Result<Response<WaitResponse>, Status>

Source

pub async fn list_configs( &mut self, request: impl IntoRequest<ListconfigsRequest>, ) -> Result<Response<ListconfigsResponse>, Status>

Source

pub async fn stop( &mut self, request: impl IntoRequest<StopRequest>, ) -> Result<Response<StopResponse>, Status>

Source

pub async fn help( &mut self, request: impl IntoRequest<HelpRequest>, ) -> Result<Response<HelpResponse>, Status>

Source

pub async fn pre_approve_keysend( &mut self, request: impl IntoRequest<PreapprovekeysendRequest>, ) -> Result<Response<PreapprovekeysendResponse>, Status>

Source

pub async fn pre_approve_invoice( &mut self, request: impl IntoRequest<PreapproveinvoiceRequest>, ) -> Result<Response<PreapproveinvoiceResponse>, Status>

Source

pub async fn static_backup( &mut self, request: impl IntoRequest<StaticbackupRequest>, ) -> Result<Response<StaticbackupResponse>, Status>

Source

pub async fn bkpr_channels_apy( &mut self, request: impl IntoRequest<BkprchannelsapyRequest>, ) -> Result<Response<BkprchannelsapyResponse>, Status>

Source

pub async fn bkpr_dump_income_csv( &mut self, request: impl IntoRequest<BkprdumpincomecsvRequest>, ) -> Result<Response<BkprdumpincomecsvResponse>, Status>

Source

pub async fn bkpr_inspect( &mut self, request: impl IntoRequest<BkprinspectRequest>, ) -> Result<Response<BkprinspectResponse>, Status>

Source

pub async fn bkpr_list_account_events( &mut self, request: impl IntoRequest<BkprlistaccounteventsRequest>, ) -> Result<Response<BkprlistaccounteventsResponse>, Status>

Source

pub async fn bkpr_list_balances( &mut self, request: impl IntoRequest<BkprlistbalancesRequest>, ) -> Result<Response<BkprlistbalancesResponse>, Status>

Source

pub async fn bkpr_list_income( &mut self, request: impl IntoRequest<BkprlistincomeRequest>, ) -> Result<Response<BkprlistincomeResponse>, Status>

Source

pub async fn bkpr_edit_description_by_payment_id( &mut self, request: impl IntoRequest<BkpreditdescriptionbypaymentidRequest>, ) -> Result<Response<BkpreditdescriptionbypaymentidResponse>, Status>

Source

pub async fn bkpr_edit_description_by_outpoint( &mut self, request: impl IntoRequest<BkpreditdescriptionbyoutpointRequest>, ) -> Result<Response<BkpreditdescriptionbyoutpointResponse>, Status>

Source

pub async fn blacklist_rune( &mut self, request: impl IntoRequest<BlacklistruneRequest>, ) -> Result<Response<BlacklistruneResponse>, Status>

Source

pub async fn check_rune( &mut self, request: impl IntoRequest<CheckruneRequest>, ) -> Result<Response<CheckruneResponse>, Status>

Source

pub async fn create_rune( &mut self, request: impl IntoRequest<CreateruneRequest>, ) -> Result<Response<CreateruneResponse>, Status>

Source

pub async fn show_runes( &mut self, request: impl IntoRequest<ShowrunesRequest>, ) -> Result<Response<ShowrunesResponse>, Status>

Source

pub async fn ask_rene_unreserve( &mut self, request: impl IntoRequest<AskreneunreserveRequest>, ) -> Result<Response<AskreneunreserveResponse>, Status>

Source

pub async fn ask_rene_list_layers( &mut self, request: impl IntoRequest<AskrenelistlayersRequest>, ) -> Result<Response<AskrenelistlayersResponse>, Status>

Source

pub async fn ask_rene_create_layer( &mut self, request: impl IntoRequest<AskrenecreatelayerRequest>, ) -> Result<Response<AskrenecreatelayerResponse>, Status>

Source

pub async fn ask_rene_remove_layer( &mut self, request: impl IntoRequest<AskreneremovelayerRequest>, ) -> Result<Response<AskreneremovelayerResponse>, Status>

Source

pub async fn ask_rene_reserve( &mut self, request: impl IntoRequest<AskrenereserveRequest>, ) -> Result<Response<AskrenereserveResponse>, Status>

Source

pub async fn ask_rene_age( &mut self, request: impl IntoRequest<AskreneageRequest>, ) -> Result<Response<AskreneageResponse>, Status>

Source

pub async fn get_routes( &mut self, request: impl IntoRequest<GetroutesRequest>, ) -> Result<Response<GetroutesResponse>, Status>

Source

pub async fn ask_rene_disable_node( &mut self, request: impl IntoRequest<AskrenedisablenodeRequest>, ) -> Result<Response<AskrenedisablenodeResponse>, Status>

Source

pub async fn ask_rene_inform_channel( &mut self, request: impl IntoRequest<AskreneinformchannelRequest>, ) -> Result<Response<AskreneinformchannelResponse>, Status>

Source

pub async fn ask_rene_create_channel( &mut self, request: impl IntoRequest<AskrenecreatechannelRequest>, ) -> Result<Response<AskrenecreatechannelResponse>, Status>

Source

pub async fn ask_rene_update_channel( &mut self, request: impl IntoRequest<AskreneupdatechannelRequest>, ) -> Result<Response<AskreneupdatechannelResponse>, Status>

Source

pub async fn ask_rene_bias_channel( &mut self, request: impl IntoRequest<AskrenebiaschannelRequest>, ) -> Result<Response<AskrenebiaschannelResponse>, Status>

Source

pub async fn ask_rene_list_reservations( &mut self, request: impl IntoRequest<AskrenelistreservationsRequest>, ) -> Result<Response<AskrenelistreservationsResponse>, Status>

Source

pub async fn inject_payment_onion( &mut self, request: impl IntoRequest<InjectpaymentonionRequest>, ) -> Result<Response<InjectpaymentonionResponse>, Status>

Source

pub async fn inject_onion_message( &mut self, request: impl IntoRequest<InjectonionmessageRequest>, ) -> Result<Response<InjectonionmessageResponse>, Status>

Source

pub async fn xpay( &mut self, request: impl IntoRequest<XpayRequest>, ) -> Result<Response<XpayResponse>, Status>

Source

pub async fn subscribe_block_added( &mut self, request: impl IntoRequest<StreamBlockAddedRequest>, ) -> Result<Response<Streaming<BlockAddedNotification>>, Status>

Source

pub async fn subscribe_channel_open_failed( &mut self, request: impl IntoRequest<StreamChannelOpenFailedRequest>, ) -> Result<Response<Streaming<ChannelOpenFailedNotification>>, Status>

Source

pub async fn subscribe_channel_opened( &mut self, request: impl IntoRequest<StreamChannelOpenedRequest>, ) -> Result<Response<Streaming<ChannelOpenedNotification>>, Status>

Source

pub async fn subscribe_connect( &mut self, request: impl IntoRequest<StreamConnectRequest>, ) -> Result<Response<Streaming<PeerConnectNotification>>, Status>

Source

pub async fn subscribe_custom_msg( &mut self, request: impl IntoRequest<StreamCustomMsgRequest>, ) -> Result<Response<Streaming<CustomMsgNotification>>, Status>

Source

pub async fn subscribe_channel_state_changed( &mut self, request: impl IntoRequest<StreamChannelStateChangedRequest>, ) -> Result<Response<Streaming<ChannelStateChangedNotification>>, Status>

Trait Implementations§

Source§

impl<T> Clone for NodeClient<T>
where T: Clone,

Source§

fn clone(&self) -> NodeClient<T>

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl<T> Debug for NodeClient<T>
where T: Debug,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<T> !Freeze for NodeClient<T>

§

impl<T> RefUnwindSafe for NodeClient<T>
where T: RefUnwindSafe,

§

impl<T> Send for NodeClient<T>
where T: Send,

§

impl<T> Sync for NodeClient<T>
where T: Sync,

§

impl<T> Unpin for NodeClient<T>
where T: Unpin,

§

impl<T> UnwindSafe for NodeClient<T>
where T: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Any for T
where T: Any,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Source§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Source§

fn type_name(&self) -> &'static str

Source§

impl<T> AnySync for T
where T: Any + Send + Sync,

Source§

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

Source§

impl<T> AsAny for T
where T: Any,

Source§

fn as_any(&self) -> &(dyn Any + 'static)

Source§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Source§

fn type_name(&self) -> &'static str

Gets the type name of self
Source§

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

Source§

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

Source§

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

Source§

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> Downcast for T
where T: AsAny + ?Sized,

Source§

fn is<T>(&self) -> bool
where T: AsAny,

Returns true if the boxed type is the same as T. Read more
Source§

fn downcast_ref<T>(&self) -> Option<&T>
where T: AsAny,

Forward to the method defined on the type Any.
Source§

fn downcast_mut<T>(&mut self) -> Option<&mut T>
where T: AsAny,

Forward to the method defined on the type Any.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,