async-graphql-extension-apollo-tracing

async-graphql-extension-apollo-tracing is an open-source extension for the crates async_graphql. The purpose of this extension is to provide a simple way to create & send your graphql metrics to Apollo Studio.

• Documentation

Tested at Rust version: rustc 1.56.0 (09c42c458 2021-10-18)

Features

• Runtime agnostic (tokio / async-std)
• Fully support traces & errors
• Batched Protobuf transfer
• Client segmentation
• Additional data to segment your queries by visitors
• Tracing
• Schema export to studio
• Error traces
• Gzip compression

Crate features

This crate offers the following features, all of which are not activated by default:

• compression: Enable the GZIP Compression when sending traces.
• tokio-comp: Enable the Tokio compatibility when you have a tokio-runtime
• async-std-comp: Enable the async-std compatibility when you have a async-std-runtime

Examples

Warp

A litle example to how to use it. If there is something unclear, please write an issue on the repo. Some examples are going to be written soon.

```rust use asyncgraphqlextensionapollotracing::{ApolloTracing, ApolloTracingDataExt, HTTPMethod, register::register};

async fn main() -> anyhow::Result<()> { ...

let schema = Schema::build(Query::default(), Mutation::default(), EmptySubscription) .data(somedataneededforyou) .extension(ApolloTracing::new( "authorizationtoken".into(), "https://yourdomain.ltd".into(), "yourgraph@variant".into(), "v1.0.0".into(), 10, )) .finish();

register("authorization_token", &schema, "my-allocation-id", "variant", "1.0.0", "staging").await?;

...

let clientname = warp::header::optional("apollographql-client-name"); let clientversion = warp::header::optional("apollographql-client-version"); let env = myenvfilter();

let graphqlpost = warp::post() .and(warp::path("graphql")) .and(asyncgraphqlwarp::graphql(schema)) .and(env) .and(clientname) .and(clientversion) .andthen( |(schema, request): ( Schema, asyncgraphql::Request, ), env: Environment, clientname: Option, clientversion: Option| async move { let userid: Option = env.userid().map(|x| x.tostring());

          Ok::<_, std::convert::Infallible>(async_graphql_warp::Response::from(
              schema
                  .execute(
                      request.data(ApolloTracingDataExt {
                          userid,
                          path: Some("/graphql".to_string()),
                          host: Some("https://yourdomain.ltd".to_string()),
                          method: Some(HTTPMethod::POST),
                          secure: Some(true),
                          protocol: Some("HTTP/1.1".to_string()),
                          status_code: Some(200),
                          client_name,
                          client_version,
                      })
                          .data(env),
                  )
                  .await,
          ))
      },
  );

} ```

References

• GraphQL
• Async Graphql Crates
• Apollo Tracing
• Apollo Server