Skip to content

Commit

Permalink
chore: don't trace requests (#26)
Browse files Browse the repository at this point in the history
  • Loading branch information
gaspb authored Feb 3, 2024
1 parent c204dc1 commit f2b49b6
Show file tree
Hide file tree
Showing 18 changed files with 64 additions and 64 deletions.
4 changes: 2 additions & 2 deletions modules/metering/src/connectors/clickhouse/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ impl ClickhouseConnector {

#[async_trait]
impl Connector for ClickhouseConnector {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn register_meter(&self, meter: Meter) -> Result<(), ConnectorError> {
let mut client = self
.pool
Expand All @@ -96,7 +96,7 @@ impl Connector for ClickhouseConnector {
Ok(())
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn query_meter(&self, params: QueryMeterParams) -> Result<Vec<Usage>, ConnectorError> {
let mut client = self
.pool
Expand Down
4 changes: 2 additions & 2 deletions modules/metering/src/meters/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ impl MetersService {

#[tonic::async_trait]
impl MetersServiceGrpc for MetersService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn register_meter(
&self,
request: Request<RegisterMeterRequest>,
Expand Down Expand Up @@ -59,7 +59,7 @@ impl MetersServiceGrpc for MetersService {
Ok(Response::new(RegisterMeterResponse { metadata: vec![] }))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn unregister_meter(
&self,
_request: Request<UnregisterMeterRequest>,
Expand Down
4 changes: 2 additions & 2 deletions modules/metering/src/query/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ impl UsageQueryService {

#[tonic::async_trait]
impl UsageQueryServiceGrpc for UsageQueryService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn query_meter(
&self,
request: Request<QueryMeterRequest>,
Expand Down Expand Up @@ -94,7 +94,7 @@ impl UsageQueryServiceGrpc for UsageQueryService {
Ok(Response::new(QueryMeterResponse { usage }))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn query_raw_events(
&self,
_request: Request<QueryRawEventsRequest>,
Expand Down
6 changes: 3 additions & 3 deletions modules/meteroid/src/api/services/apitokens/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ use common_grpc::middleware::server::auth::RequestExt;

#[tonic::async_trait]
impl ApiTokensService for DbService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn list_api_tokens(
&self,
request: Request<ListApiTokensRequest>,
Expand All @@ -52,7 +52,7 @@ impl ApiTokensService for DbService {
Ok(Response::new(ListApiTokensResponse { api_tokens: result }))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn create_api_token(
&self,
request: Request<CreateApiTokenRequest>,
Expand Down Expand Up @@ -124,7 +124,7 @@ impl ApiTokensService for DbService {
Ok(Response::new(response))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_api_token_by_id(
&self,
request: Request<GetApiTokenByIdRequest>,
Expand Down
6 changes: 3 additions & 3 deletions modules/meteroid/src/api/services/billablemetrics/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ use tonic::{Request, Response, Status};

#[tonic::async_trait]
impl BillableMetricsService for BillableMetricsComponents {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn create_billable_metric(
&self,
request: Request<CreateBillableMetricRequest>,
Expand Down Expand Up @@ -92,7 +92,7 @@ impl BillableMetricsService for BillableMetricsComponents {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn list_billable_metrics(
&self,
request: Request<ListBillableMetricsRequest>,
Expand Down Expand Up @@ -131,7 +131,7 @@ impl BillableMetricsService for BillableMetricsComponents {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_billable_metric(
&self,
request: Request<GetBillableMetricRequest>,
Expand Down
8 changes: 4 additions & 4 deletions modules/meteroid/src/api/services/customers/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ use super::mapping;

#[tonic::async_trait]
impl CustomersService for DbService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn create_customer(
&self,
request: tonic::Request<CreateCustomerRequest>,
Expand Down Expand Up @@ -68,7 +68,7 @@ impl CustomersService for DbService {
Ok(Response::new(CreateCustomerResponse { customer: Some(rs) }))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn list_customers(
&self,
request: tonic::Request<ListCustomerRequest>,
Expand Down Expand Up @@ -115,7 +115,7 @@ impl CustomersService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_customer(
&self,
request: Request<GetCustomerRequest>,
Expand Down Expand Up @@ -143,7 +143,7 @@ impl CustomersService for DbService {
Ok(Response::new(rs))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_customer_by_alias(
&self,
request: Request<GetCustomerByAliasRequest>,
Expand Down
4 changes: 2 additions & 2 deletions modules/meteroid/src/api/services/instance/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ use meteroid_repository::organizations::CreateOrganizationParams;

#[tonic::async_trait]
impl InstanceService for DbService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_instance(
&self,
_request: Request<GetInstanceRequest>,
Expand All @@ -41,7 +41,7 @@ impl InstanceService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn init_instance(
&self,
request: Request<InitInstanceRequest>,
Expand Down
2 changes: 1 addition & 1 deletion modules/meteroid/src/api/services/internal/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ use tonic::{Request, Response, Status};

#[tonic::async_trait]
impl InternalService for DbService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn resolve_customer_external_ids(
&self,
request: Request<ResolveCustomerExternalIdsRequest>,
Expand Down
4 changes: 2 additions & 2 deletions modules/meteroid/src/api/services/invoices/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ use crate::api::services::utils::PaginationExt;

#[tonic::async_trait]
impl InvoicesService for DbService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn list_invoices(
&self,
request: Request<ListInvoicesRequest>,
Expand Down Expand Up @@ -62,7 +62,7 @@ impl InvoicesService for DbService {
Ok(Response::new(response))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_invoice(
&self,
request: Request<GetInvoiceRequest>,
Expand Down
26 changes: 13 additions & 13 deletions modules/meteroid/src/api/services/plans/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ use tonic::{Request, Response, Status};

#[tonic::async_trait]
impl PlansService for DbService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn create_draft_plan(
&self,
request: Request<CreateDraftPlanRequest>,
Expand Down Expand Up @@ -115,7 +115,7 @@ impl PlansService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_plan_by_external_id(
&self,
request: Request<GetPlanByExternalIdRequest>,
Expand Down Expand Up @@ -157,7 +157,7 @@ impl PlansService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn list_plans(
&self,
request: Request<ListPlansRequest>,
Expand Down Expand Up @@ -205,7 +205,7 @@ impl PlansService for DbService {
Ok(Response::new(response))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_plan_version_by_id(
&self,
request: Request<GetPlanVersionByIdRequest>,
Expand All @@ -232,7 +232,7 @@ impl PlansService for DbService {
Ok(Response::new(response))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn list_plan_version_by_id(
&self,
request: Request<ListPlanVersionByIdRequest>,
Expand Down Expand Up @@ -272,7 +272,7 @@ impl PlansService for DbService {
Ok(Response::new(response))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn copy_version_to_draft(
&self,
request: Request<CopyVersionToDraftRequest>,
Expand Down Expand Up @@ -327,7 +327,7 @@ impl PlansService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn publish_plan_version(
&self,
request: Request<PublishPlanVersionRequest>,
Expand Down Expand Up @@ -364,7 +364,7 @@ impl PlansService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_last_published_plan_version(
&self,
request: Request<GetLastPublishedPlanVersionRequest>,
Expand Down Expand Up @@ -395,7 +395,7 @@ impl PlansService for DbService {
Ok(Response::new(response))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn discard_draft_version(
&self,
request: Request<DiscardDraftVersionRequest>,
Expand Down Expand Up @@ -425,7 +425,7 @@ impl PlansService for DbService {
Ok(Response::new(DiscardDraftVersionResponse {}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn update_draft_plan_overview(
&self,
request: Request<UpdateDraftPlanOverviewRequest>,
Expand Down Expand Up @@ -507,7 +507,7 @@ impl PlansService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn update_published_plan_overview(
&self,
request: Request<UpdatePublishedPlanOverviewRequest>,
Expand Down Expand Up @@ -550,7 +550,7 @@ impl PlansService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_plan_overview_by_external_id(
&self,
request: Request<GetPlanOverviewByExternalIdRequest>,
Expand Down Expand Up @@ -578,7 +578,7 @@ impl PlansService for DbService {
Ok(Response::new(response))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_plan_parameters(
&self,
request: Request<GetPlanParametersRequest>,
Expand Down
8 changes: 4 additions & 4 deletions modules/meteroid/src/api/services/pricecomponents/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ use meteroid_grpc::meteroid::api::components::v1::{

#[tonic::async_trait]
impl PriceComponentsService for DbService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn list_price_components(
&self,
request: Request<ListPriceComponentRequest>,
Expand All @@ -44,7 +44,7 @@ impl PriceComponentsService for DbService {
Ok(Response::new(response))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn create_price_component(
&self,
request: Request<CreatePriceComponentRequest>,
Expand Down Expand Up @@ -129,7 +129,7 @@ impl PriceComponentsService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn edit_price_component(
&self,
request: Request<EditPriceComponentRequest>,
Expand Down Expand Up @@ -213,7 +213,7 @@ impl PriceComponentsService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn remove_price_component(
&self,
request: Request<RemovePriceComponentRequest>,
Expand Down
6 changes: 3 additions & 3 deletions modules/meteroid/src/api/services/productfamilies/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ use super::mapping;

#[tonic::async_trait]
impl ProductFamiliesService for DbService {
#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn list_product_families(
&self,
request: Request<ListProductFamiliesRequest>,
Expand All @@ -43,7 +43,7 @@ impl ProductFamiliesService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn create_product_family(
&self,
request: Request<CreateProductFamilyRequest>,
Expand Down Expand Up @@ -75,7 +75,7 @@ impl ProductFamiliesService for DbService {
}))
}

#[tracing::instrument(skip(self))]
#[tracing::instrument(skip_all)]
async fn get_product_family_by_external_id(
&self,
request: Request<GetProductFamilyByExternalIdRequest>,
Expand Down
Loading

0 comments on commit f2b49b6

Please sign in to comment.