graphql client

.gitignore

@@ -1,3 +1,4 @@
 /target
 /node_modules
 .env
+.idea

Cargo.toml

@@ -7,6 +7,8 @@ edition = "2021"
 crate-type = ["cdylib"]
 
 [dependencies]
+graphql_client = "0.14.0"
+serde = "1.0.200"
 worker = "0.2.0"
 
 [profile.release]

gql/queries.graphql

@@ -0,0 +1,26 @@
+query GetWorkersAnalytics($accountTag: string, $datetimeStart: string, $datetimeEnd: string, $scriptName: string) {
+    viewer {
+      accounts(filter: {accountTag: $accountTag}) {
+        workersInvocationsAdaptive(limit: 100, filter: {
+          scriptName: $scriptName,
+          datetime_geq: $datetimeStart,
+          datetime_leq: $datetimeEnd
+        }) {
+          sum {
+            subrequests
+            requests
+            errors
+          }
+          quantiles {
+            cpuTimeP50
+            cpuTimeP99
+          }
+          dimensions{
+            datetime
+            scriptName
+            status
+          }
+        }
+      }
+    }
+  }

src/gql.rs

@@ -0,0 +1,22 @@
+use graphql_client::GraphQLQuery;
+
+// The paths are relative to the directory where your `Cargo.toml` is located.
+// Both json and the GraphQL schema language are supported as sources for the schema
+#[derive(GraphQLQuery)]
+#[graphql(
+schema_path = "gql/schema.graphql",
+query_path = "gql/queries.graphql",
+)]
+pub struct GetWorkersAnalytics;
+
+#[allow(non_camel_case_types)]
+type float32 = f32;
+
+#[allow(non_camel_case_types)]
+type string = String;
+
+#[allow(non_camel_case_types)]
+type Time = String;
+
+#[allow(non_camel_case_types)]
+type uint64 = u64;

src/lib.rs

@@ -1,6 +1,8 @@
+mod gql;
+
 use worker::*;
 
 #[event(fetch)]
-async fn main(req: Request, env: Env, ctx: Context) -> Result<Response> {
+async fn main(_req: Request, _env: Env, _ctx: Context) -> Result<Response> {
     Response::ok("Hello, World!")
 }