pub struct ViewServer { /* private fields */ }Expand description
A service that synchronizes private chain state and responds to queries about it.
The ViewServer implements the Tonic-derived ViewService trait,
so it can be used as a gRPC server, or called directly. It spawns a task
internally that performs synchronization and scanning. The
ViewServer can be cloned; each clone will read from the same shared
state, but there will only be a single scanning task.
Implementations§
Source§impl ViewServer
impl ViewServer
Sourcepub async fn load_or_initialize(
storage_path: Option<impl AsRef<Utf8Path>>,
registry_path: Option<impl AsRef<Utf8Path>>,
fvk: &FullViewingKey,
node: Url,
) -> Result<Self>
pub async fn load_or_initialize( storage_path: Option<impl AsRef<Utf8Path>>, registry_path: Option<impl AsRef<Utf8Path>>, fvk: &FullViewingKey, node: Url, ) -> Result<Self>
Convenience method that calls Storage::load_or_initialize and then Self::new.
Sourcepub async fn new(storage: Storage, node: Url) -> Result<Self>
pub async fn new(storage: Storage, node: Url) -> Result<Self>
Constructs a new ViewService, spawning a sync task internally.
The sync task uses the provided client to sync with the chain.
To create multiple ViewServices, clone the ViewService returned
by this method, rather than calling it multiple times. That way, each clone
will be backed by the same scanning task, rather than each spawning its own.
Sourcepub async fn get_pd_channel(node: Url) -> Result<Channel>
pub async fn get_pd_channel(node: Url) -> Result<Channel>
Sourcepub async fn latest_known_block_height(&self) -> Result<(u64, bool)>
pub async fn latest_known_block_height(&self) -> Result<(u64, bool)>
Return the latest block height known by the fullnode or its peers, as well as whether the fullnode is caught up with that height.
pub async fn status(&self) -> Result<StatusResponse>
Trait Implementations§
Source§impl Clone for ViewServer
impl Clone for ViewServer
Source§fn clone(&self) -> ViewServer
fn clone(&self) -> ViewServer
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl ViewService for ViewServer
impl ViewService for ViewServer
Source§type NotesStream = Pin<Box<dyn Stream<Item = Result<NotesResponse, Status>> + Send>>
type NotesStream = Pin<Box<dyn Stream<Item = Result<NotesResponse, Status>> + Send>>
Server streaming response type for the Notes method.
Source§type NotesForVotingStream = Pin<Box<dyn Stream<Item = Result<NotesForVotingResponse, Status>> + Send>>
type NotesForVotingStream = Pin<Box<dyn Stream<Item = Result<NotesForVotingResponse, Status>> + Send>>
Server streaming response type for the NotesForVoting method.
Source§type AssetsStream = Pin<Box<dyn Stream<Item = Result<AssetsResponse, Status>> + Send>>
type AssetsStream = Pin<Box<dyn Stream<Item = Result<AssetsResponse, Status>> + Send>>
Server streaming response type for the Assets method.
Source§type StatusStreamStream = Pin<Box<dyn Stream<Item = Result<StatusStreamResponse, Status>> + Send>>
type StatusStreamStream = Pin<Box<dyn Stream<Item = Result<StatusStreamResponse, Status>> + Send>>
Server streaming response type for the StatusStream method.
Source§type TransactionInfoStream = Pin<Box<dyn Stream<Item = Result<TransactionInfoResponse, Status>> + Send>>
type TransactionInfoStream = Pin<Box<dyn Stream<Item = Result<TransactionInfoResponse, Status>> + Send>>
Server streaming response type for the TransactionInfo method.
Source§type BalancesStream = Pin<Box<dyn Stream<Item = Result<BalancesResponse, Status>> + Send>>
type BalancesStream = Pin<Box<dyn Stream<Item = Result<BalancesResponse, Status>> + Send>>
Server streaming response type for the Balances method.
Source§type OwnedPositionIdsStream = Pin<Box<dyn Stream<Item = Result<OwnedPositionIdsResponse, Status>> + Send>>
type OwnedPositionIdsStream = Pin<Box<dyn Stream<Item = Result<OwnedPositionIdsResponse, Status>> + Send>>
Server streaming response type for the OwnedPositionIds method.
Source§type UnclaimedSwapsStream = Pin<Box<dyn Stream<Item = Result<UnclaimedSwapsResponse, Status>> + Send>>
type UnclaimedSwapsStream = Pin<Box<dyn Stream<Item = Result<UnclaimedSwapsResponse, Status>> + Send>>
Server streaming response type for the UnclaimedSwaps method.
Source§type BroadcastTransactionStream = Pin<Box<dyn Stream<Item = Result<BroadcastTransactionResponse, Status>> + Send>>
type BroadcastTransactionStream = Pin<Box<dyn Stream<Item = Result<BroadcastTransactionResponse, Status>> + Send>>
Server streaming response type for the BroadcastTransaction method.
Source§type WitnessAndBuildStream = Pin<Box<dyn Stream<Item = Result<WitnessAndBuildResponse, Status>> + Send>>
type WitnessAndBuildStream = Pin<Box<dyn Stream<Item = Result<WitnessAndBuildResponse, Status>> + Send>>
Server streaming response type for the WitnessAndBuild method.
Source§type AuthorizeAndBuildStream = Pin<Box<dyn Stream<Item = Result<AuthorizeAndBuildResponse, Status>> + Send>>
type AuthorizeAndBuildStream = Pin<Box<dyn Stream<Item = Result<AuthorizeAndBuildResponse, Status>> + Send>>
Server streaming response type for the AuthorizeAndBuild method.
Source§type DelegationsByAddressIndexStream = Pin<Box<dyn Stream<Item = Result<DelegationsByAddressIndexResponse, Status>> + Send>>
type DelegationsByAddressIndexStream = Pin<Box<dyn Stream<Item = Result<DelegationsByAddressIndexResponse, Status>> + Send>>
Server streaming response type for the DelegationsByAddressIndex method.
Source§type UnbondingTokensByAddressIndexStream = Pin<Box<dyn Stream<Item = Result<UnbondingTokensByAddressIndexResponse, Status>> + Send>>
type UnbondingTokensByAddressIndexStream = Pin<Box<dyn Stream<Item = Result<UnbondingTokensByAddressIndexResponse, Status>> + Send>>
Server streaming response type for the UnbondingTokensByAddressIndex method.
Source§type AuctionsStream = Pin<Box<dyn Stream<Item = Result<AuctionsResponse, Status>> + Send>>
type AuctionsStream = Pin<Box<dyn Stream<Item = Result<AuctionsResponse, Status>> + Send>>
Server streaming response type for the Auctions method.
Source§type LatestSwapsStream = Pin<Box<dyn Stream<Item = Result<LatestSwapsResponse, Status>> + Send>>
type LatestSwapsStream = Pin<Box<dyn Stream<Item = Result<LatestSwapsResponse, Status>> + Send>>
Server streaming response type for the LatestSwaps method.
Source§type LqtVotingNotesStream = Pin<Box<dyn Stream<Item = Result<LqtVotingNotesResponse, Status>> + Send>>
type LqtVotingNotesStream = Pin<Box<dyn Stream<Item = Result<LqtVotingNotesResponse, Status>> + Send>>
Server streaming response type for the LqtVotingNotes method.
Source§type TournamentVotesStream = Pin<Box<dyn Stream<Item = Result<TournamentVotesResponse, Status>> + Send>>
type TournamentVotesStream = Pin<Box<dyn Stream<Item = Result<TournamentVotesResponse, Status>> + Send>>
Server streaming response type for the TournamentVotes method.
Source§type LpPositionBundleStream = Pin<Box<dyn Stream<Item = Result<LpPositionBundleResponse, Status>> + Send>>
type LpPositionBundleStream = Pin<Box<dyn Stream<Item = Result<LpPositionBundleResponse, Status>> + Send>>
Server streaming response type for the LpPositionBundle method.
Source§type LpStrategyCatalogStream = Pin<Box<dyn Stream<Item = Result<LpStrategyCatalogResponse, Status>> + Send>>
type LpStrategyCatalogStream = Pin<Box<dyn Stream<Item = Result<LpStrategyCatalogResponse, Status>> + Send>>
Server streaming response type for the LpStrategyCatalog method.
Source§fn auctions<'life0, 'async_trait>(
&'life0 self,
request: Request<AuctionsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::AuctionsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn auctions<'life0, 'async_trait>(
&'life0 self,
request: Request<AuctionsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::AuctionsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Gets the auctions controlled by the user’s wallet.
Source§fn broadcast_transaction<'life0, 'async_trait>(
&'life0 self,
request: Request<BroadcastTransactionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::BroadcastTransactionStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn broadcast_transaction<'life0, 'async_trait>(
&'life0 self,
request: Request<BroadcastTransactionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::BroadcastTransactionStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Broadcast a transaction to the network, optionally waiting for full confirmation. Read more
Source§fn transaction_planner<'life0, 'async_trait>(
&'life0 self,
request: Request<TransactionPlannerRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TransactionPlannerResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn transaction_planner<'life0, 'async_trait>(
&'life0 self,
request: Request<TransactionPlannerRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TransactionPlannerResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Translates a high-level intent (“send X funds to Y address”) into a complete transaction plan.
Source§fn address_by_index<'life0, 'async_trait>(
&'life0 self,
request: Request<AddressByIndexRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AddressByIndexResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn address_by_index<'life0, 'async_trait>(
&'life0 self,
request: Request<AddressByIndexRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AddressByIndexResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for an address given an address index
Source§fn index_by_address<'life0, 'async_trait>(
&'life0 self,
request: Request<IndexByAddressRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<IndexByAddressResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn index_by_address<'life0, 'async_trait>(
&'life0 self,
request: Request<IndexByAddressRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<IndexByAddressResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for an address given an address index
Source§fn transparent_address<'life0, 'async_trait>(
&'life0 self,
_request: Request<TransparentAddressRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TransparentAddressResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn transparent_address<'life0, 'async_trait>(
&'life0 self,
_request: Request<TransparentAddressRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TransparentAddressResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns the transparent address for the user’s wallet.
Source§fn ephemeral_address<'life0, 'async_trait>(
&'life0 self,
request: Request<EphemeralAddressRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<EphemeralAddressResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn ephemeral_address<'life0, 'async_trait>(
&'life0 self,
request: Request<EphemeralAddressRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<EphemeralAddressResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for an ephemeral address
Source§fn transaction_info_by_hash<'life0, 'async_trait>(
&'life0 self,
request: Request<TransactionInfoByHashRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TransactionInfoByHashResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn transaction_info_by_hash<'life0, 'async_trait>(
&'life0 self,
request: Request<TransactionInfoByHashRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TransactionInfoByHashResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for a given transaction by its hash.
Source§fn swap_by_commitment<'life0, 'async_trait>(
&'life0 self,
request: Request<SwapByCommitmentRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SwapByCommitmentResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn swap_by_commitment<'life0, 'async_trait>(
&'life0 self,
request: Request<SwapByCommitmentRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SwapByCommitmentResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for a swap by its swap commitment, optionally waiting until the swap is detected.
Source§fn balances<'life0, 'async_trait>(
&'life0 self,
request: Request<BalancesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::BalancesStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn balances<'life0, 'async_trait>(
&'life0 self,
request: Request<BalancesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::BalancesStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for balance of a given address.
Returns a stream of
BalancesResponses.Source§fn note_by_commitment<'life0, 'async_trait>(
&'life0 self,
request: Request<NoteByCommitmentRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<NoteByCommitmentResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn note_by_commitment<'life0, 'async_trait>(
&'life0 self,
request: Request<NoteByCommitmentRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<NoteByCommitmentResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for a note by its note commitment, optionally waiting until the note is detected.
Source§fn nullifier_status<'life0, 'async_trait>(
&'life0 self,
request: Request<NullifierStatusRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<NullifierStatusResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn nullifier_status<'life0, 'async_trait>(
&'life0 self,
request: Request<NullifierStatusRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<NullifierStatusResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for whether a nullifier has been spent, optionally waiting until it is spent.
Source§fn status<'life0, 'async_trait>(
&'life0 self,
__arg1: Request<StatusRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<StatusResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn status<'life0, 'async_trait>(
&'life0 self,
__arg1: Request<StatusRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<StatusResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get current status of chain sync
Source§fn status_stream<'life0, 'async_trait>(
&'life0 self,
__arg1: Request<StatusStreamRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StatusStreamStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn status_stream<'life0, 'async_trait>(
&'life0 self,
__arg1: Request<StatusStreamRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StatusStreamStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Stream sync status updates until the view service has caught up with the chain.
Returns a stream of
StatusStreamResponses.Source§fn notes<'life0, 'async_trait>(
&'life0 self,
request: Request<NotesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::NotesStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn notes<'life0, 'async_trait>(
&'life0 self,
request: Request<NotesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::NotesStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Queries for notes that have been accepted by the chain.
Returns a stream of
NotesResponses.Source§fn notes_for_voting<'life0, 'async_trait>(
&'life0 self,
request: Request<NotesForVotingRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::NotesForVotingStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn notes_for_voting<'life0, 'async_trait>(
&'life0 self,
request: Request<NotesForVotingRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::NotesForVotingStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns a stream of
NotesForVotingResponses.Source§fn assets<'life0, 'async_trait>(
&'life0 self,
request: Request<AssetsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::AssetsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn assets<'life0, 'async_trait>(
&'life0 self,
request: Request<AssetsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::AssetsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Queries for metadata about known assets.
Returns a stream of
AssetsResponses.Source§fn transaction_info<'life0, 'async_trait>(
&'life0 self,
request: Request<TransactionInfoRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::TransactionInfoStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn transaction_info<'life0, 'async_trait>(
&'life0 self,
request: Request<TransactionInfoRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::TransactionInfoStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for the full transactions in the given range of blocks.
Returns a stream of
TransactionInfoResponses.Source§fn witness<'life0, 'async_trait>(
&'life0 self,
request: Request<WitnessRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<WitnessResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn witness<'life0, 'async_trait>(
&'life0 self,
request: Request<WitnessRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<WitnessResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Returns authentication data for the given transaction plan. Read more
Source§fn witness_and_build<'life0, 'async_trait>(
&'life0 self,
request: Request<WitnessAndBuildRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::WitnessAndBuildStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn witness_and_build<'life0, 'async_trait>(
&'life0 self,
request: Request<WitnessAndBuildRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::WitnessAndBuildStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Like
Witness, but immediately uses the witness data to build (prove) the transaction. Read moreSource§fn app_parameters<'life0, 'async_trait>(
&'life0 self,
_request: Request<AppParametersRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AppParametersResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn app_parameters<'life0, 'async_trait>(
&'life0 self,
_request: Request<AppParametersRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AppParametersResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for the current app parameters.
Source§fn gas_prices<'life0, 'async_trait>(
&'life0 self,
_request: Request<GasPricesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GasPricesResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn gas_prices<'life0, 'async_trait>(
&'life0 self,
_request: Request<GasPricesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GasPricesResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for the current gas prices.
Source§fn fmd_parameters<'life0, 'async_trait>(
&'life0 self,
_request: Request<FmdParametersRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<FmdParametersResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn fmd_parameters<'life0, 'async_trait>(
&'life0 self,
_request: Request<FmdParametersRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<FmdParametersResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for the current FMD parameters.
Source§fn owned_position_ids<'life0, 'async_trait>(
&'life0 self,
request: Request<OwnedPositionIdsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::OwnedPositionIdsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn owned_position_ids<'life0, 'async_trait>(
&'life0 self,
request: Request<OwnedPositionIdsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::OwnedPositionIdsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for owned position IDs for the given trading pair and in the given position state.
Authorize a transaction plan and build the transaction. Read more
Source§fn unclaimed_swaps<'life0, 'async_trait>(
&'life0 self,
__arg1: Request<UnclaimedSwapsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::UnclaimedSwapsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn unclaimed_swaps<'life0, 'async_trait>(
&'life0 self,
__arg1: Request<UnclaimedSwapsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::UnclaimedSwapsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for all unclaimed swaps.
Source§fn wallet_id<'life0, 'async_trait>(
&'life0 self,
__arg1: Request<WalletIdRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<WalletIdResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn wallet_id<'life0, 'async_trait>(
&'life0 self,
__arg1: Request<WalletIdRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<WalletIdResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for wallet id
Source§fn asset_metadata_by_id<'life0, 'async_trait>(
&'life0 self,
request: Request<AssetMetadataByIdRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AssetMetadataByIdResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn asset_metadata_by_id<'life0, 'async_trait>(
&'life0 self,
request: Request<AssetMetadataByIdRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AssetMetadataByIdResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Query for metadata about a specific asset, by asset ID. Read more
Source§fn delegations_by_address_index<'life0, 'async_trait>(
&'life0 self,
_request: Request<DelegationsByAddressIndexRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::DelegationsByAddressIndexStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn delegations_by_address_index<'life0, 'async_trait>(
&'life0 self,
_request: Request<DelegationsByAddressIndexRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::DelegationsByAddressIndexStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get delegation tokens for a given address index. Each delegation token will
be represented by a
ValueView with the given address index’s balance of
that token. Each ValueView’s extended_metadata field will contain the
ValidatorInfo of the delegated validator.Source§fn unbonding_tokens_by_address_index<'life0, 'async_trait>(
&'life0 self,
_request: Request<UnbondingTokensByAddressIndexRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::UnbondingTokensByAddressIndexStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn unbonding_tokens_by_address_index<'life0, 'async_trait>(
&'life0 self,
_request: Request<UnbondingTokensByAddressIndexRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::UnbondingTokensByAddressIndexStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get unbonding tokens for the given address index, optionally filtered by
whether the tokens are currently claimable.
Source§fn latest_swaps<'life0, 'async_trait>(
&'life0 self,
_request: Request<LatestSwapsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::LatestSwapsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn latest_swaps<'life0, 'async_trait>(
&'life0 self,
_request: Request<LatestSwapsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::LatestSwapsStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Gets the latest swaps controlled by the user’s wallet.
Source§fn tournament_votes<'life0, 'async_trait>(
&'life0 self,
_request: Request<TournamentVotesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::TournamentVotesStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn tournament_votes<'life0, 'async_trait>(
&'life0 self,
_request: Request<TournamentVotesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::TournamentVotesStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Gets a list of votes cast in the liquidity tournament for a specific epoch or up to certain block height.
Source§fn lqt_voting_notes<'life0, 'async_trait>(
&'life0 self,
request: Request<LqtVotingNotesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::LqtVotingNotesStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn lqt_voting_notes<'life0, 'async_trait>(
&'life0 self,
request: Request<LqtVotingNotesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::LqtVotingNotesStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Gets the spendable note records that are eligible for voting in the current epoch.
Source§fn lp_position_bundle<'life0, 'async_trait>(
&'life0 self,
_request: Request<LpPositionBundleRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::LpPositionBundleStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn lp_position_bundle<'life0, 'async_trait>(
&'life0 self,
_request: Request<LpPositionBundleRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::LpPositionBundleStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Request bundles of liquidity positions by trading pair / subaccount / strategy.
Source§fn lp_strategy_catalog<'life0, 'async_trait>(
&'life0 self,
_request: Request<LpStrategyCatalogRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::LpStrategyCatalogStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn lp_strategy_catalog<'life0, 'async_trait>(
&'life0 self,
_request: Request<LpStrategyCatalogRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::LpStrategyCatalogStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Request a list of LP strategies (e.g, for a UI to display a catalogue of strategies).
Auto Trait Implementations§
impl Freeze for ViewServer
impl !RefUnwindSafe for ViewServer
impl Send for ViewServer
impl Sync for ViewServer
impl Unpin for ViewServer
impl !UnwindSafe for ViewServer
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
Formats each item in a sequence. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self, then passes self.as_ref() into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self, then passes self.as_mut() into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self, then passes self.deref() into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B> of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B> of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R> view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R> view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref() only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref() only in debug builds, and is erased in release
builds.