Skip to content

view: 🧿 add trace spans to ViewService methods #4435

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
cratelyn merged 1 commit into from
May 22, 2024
Merged

view: 🧿 add trace spans to ViewService methods #4435

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
28 changes: 28 additions & 0 deletions crates/view/src/service.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -408,6 +408,7 @@ impl ViewService for ViewServer {
type AuctionsStream =
Pin<Box<dyn futures::Stream<Item = Result<pb::AuctionsResponse, tonic::Status>> + Send>>;

#[instrument(skip_all, level = "trace")]
async fn auctions(
&self,
request: tonic::Request<pb::AuctionsRequest>,
Expand Down Expand Up @@ -476,6 +477,7 @@ impl ViewService for ViewServer {
Ok(Response::new(stream))
}

#[instrument(skip_all, level = "trace")]
async fn broadcast_transaction(
&self,
request: tonic::Request<pb::BroadcastTransactionRequest>,
Expand All @@ -496,6 +498,7 @@ impl ViewService for ViewServer {
Ok(tonic::Response::new(stream))
}

#[instrument(skip_all, level = "trace")]
async fn transaction_planner(
&self,
request: tonic::Request<pb::TransactionPlannerRequest>,
Expand Down Expand Up @@ -767,6 +770,7 @@ impl ViewService for ViewServer {
}))
}

#[instrument(skip_all, level = "trace")]
async fn address_by_index(
&self,
request: tonic::Request<pb::AddressByIndexRequest>,
Expand All @@ -790,6 +794,7 @@ impl ViewService for ViewServer {
}))
}

#[instrument(skip_all, level = "trace")]
async fn index_by_address(
&self,
request: tonic::Request<pb::IndexByAddressRequest>,
Expand All @@ -813,6 +818,7 @@ impl ViewService for ViewServer {
}))
}

#[instrument(skip_all, level = "trace")]
async fn ephemeral_address(
&self,
request: tonic::Request<pb::EphemeralAddressRequest>,
Expand All @@ -836,6 +842,7 @@ impl ViewService for ViewServer {
}))
}

#[instrument(skip_all, level = "trace")]
async fn transaction_info_by_hash(
&self,
request: tonic::Request<pb::TransactionInfoByHashRequest>,
Expand Down Expand Up @@ -1019,6 +1026,7 @@ impl ViewService for ViewServer {
Ok(tonic::Response::new(response))
}

#[instrument(skip_all, level = "trace")]
async fn swap_by_commitment(
&self,
request: tonic::Request<pb::SwapByCommitmentRequest>,
Expand Down Expand Up @@ -1144,6 +1152,7 @@ impl ViewService for ViewServer {
))
}

#[instrument(skip_all, level = "trace")]
async fn note_by_commitment(
&self,
request: tonic::Request<pb::NoteByCommitmentRequest>,
Expand Down Expand Up @@ -1174,6 +1183,7 @@ impl ViewService for ViewServer {
}))
}

#[instrument(skip_all, level = "trace")]
async fn nullifier_status(
&self,
request: tonic::Request<pb::NullifierStatusRequest>,
Expand All @@ -1197,6 +1207,7 @@ impl ViewService for ViewServer {
}))
}

#[instrument(skip_all, level = "trace")]
async fn status(
&self,
_: tonic::Request<pb::StatusRequest>,
Expand All @@ -1208,6 +1219,7 @@ impl ViewService for ViewServer {
})?))
}

#[instrument(skip_all, level = "trace")]
async fn status_stream(
&self,
_: tonic::Request<pb::StatusStreamRequest>,
Expand Down Expand Up @@ -1240,6 +1252,7 @@ impl ViewService for ViewServer {
Ok(tonic::Response::new(stream.boxed()))
}

#[instrument(skip_all, level = "trace")]
async fn notes(
&self,
request: tonic::Request<pb::NotesRequest>,
Expand Down Expand Up @@ -1291,6 +1304,7 @@ impl ViewService for ViewServer {
))
}

#[instrument(skip_all, level = "trace")]
async fn notes_for_voting(
&self,
request: tonic::Request<pb::NotesForVotingRequest>,
Expand Down Expand Up @@ -1331,6 +1345,7 @@ impl ViewService for ViewServer {
))
}

#[instrument(skip_all, level = "trace")]
async fn assets(
&self,
request: tonic::Request<pb::AssetsRequest>,
Expand Down Expand Up @@ -1399,6 +1414,7 @@ impl ViewService for ViewServer {
))
}

#[instrument(skip_all, level = "trace")]
async fn transaction_info(
&self,
request: tonic::Request<pb::TransactionInfoRequest>,
Expand Down Expand Up @@ -1446,6 +1462,7 @@ impl ViewService for ViewServer {
))
}

#[instrument(skip_all, level = "trace")]
async fn witness(
&self,
request: tonic::Request<pb::WitnessRequest>,
Expand Down Expand Up @@ -1526,6 +1543,7 @@ impl ViewService for ViewServer {
Ok(tonic::Response::new(witness_response))
}

#[instrument(skip_all, level = "trace")]
async fn witness_and_build(
&self,
request: tonic::Request<pb::WitnessAndBuildRequest>,
Expand Down Expand Up @@ -1592,6 +1610,7 @@ impl ViewService for ViewServer {
))
}

#[instrument(skip_all, level = "trace")]
async fn app_parameters(
&self,
_request: tonic::Request<pb::AppParametersRequest>,
Expand All @@ -1610,6 +1629,7 @@ impl ViewService for ViewServer {
Ok(tonic::Response::new(response))
}

#[instrument(skip_all, level = "trace")]
async fn gas_prices(
&self,
_request: tonic::Request<pb::GasPricesRequest>,
Expand All @@ -1629,6 +1649,7 @@ impl ViewService for ViewServer {
Ok(tonic::Response::new(response))
}

#[instrument(skip_all, level = "trace")]
async fn fmd_parameters(
&self,
_request: tonic::Request<pb::FmdParametersRequest>,
Expand All @@ -1647,6 +1668,7 @@ impl ViewService for ViewServer {
Ok(tonic::Response::new(response))
}

#[instrument(skip_all, level = "trace")]
async fn owned_position_ids(
&self,
request: tonic::Request<pb::OwnedPositionIdsRequest>,
Expand Down Expand Up @@ -1693,13 +1715,15 @@ impl ViewService for ViewServer {
))
}

#[instrument(skip_all, level = "trace")]
async fn authorize_and_build(
&self,
_request: tonic::Request<pb::AuthorizeAndBuildRequest>,
) -> Result<tonic::Response<Self::AuthorizeAndBuildStream>, tonic::Status> {
unimplemented!("authorize_and_build")
}

#[instrument(skip_all, level = "trace")]
async fn unclaimed_swaps(
&self,
_: tonic::Request<pb::UnclaimedSwapsRequest>,
Expand Down Expand Up @@ -1727,6 +1751,7 @@ impl ViewService for ViewServer {
))
}

#[instrument(skip_all, level = "trace")]
async fn wallet_id(
&self,
_: Request<WalletIdRequest>,
Expand All @@ -1740,6 +1765,7 @@ impl ViewService for ViewServer {
}))
}

#[instrument(skip_all, level = "trace")]
async fn asset_metadata_by_id(
&self,
request: Request<AssetMetadataByIdRequest>,
Expand All @@ -1762,13 +1788,15 @@ impl ViewService for ViewServer {
}))
}

#[instrument(skip_all, level = "trace")]
async fn delegations_by_address_index(
&self,
_request: tonic::Request<pb::DelegationsByAddressIndexRequest>,
) -> Result<tonic::Response<Self::DelegationsByAddressIndexStream>, tonic::Status> {
unimplemented!("delegations_by_address_index")
}

#[instrument(skip_all, level = "trace")]
async fn unbonding_tokens_by_address_index(
&self,
_request: tonic::Request<pb::UnbondingTokensByAddressIndexRequest>,
Expand Down