@@ -12,45 +12,35 @@ use worker::console_log;
12
12
#[ derive( GraphQLQuery ) ]
13
13
#[ graphql(
14
14
schema_path = "gql/schema.graphql" ,
15
- query_path = "gql/workers_query.graphql" ,
16
- variables_derives = "Debug" ,
17
- response_derives = "Debug,Clone"
15
+ query_path = "gql/workers_query.graphql"
18
16
) ]
19
17
pub struct GetWorkersAnalyticsQuery ;
20
18
21
19
#[ derive( GraphQLQuery ) ]
22
20
#[ graphql(
23
21
schema_path = "gql/schema.graphql" ,
24
- query_path = "gql/d1_query.graphql" ,
25
- variables_derives = "Debug" ,
26
- response_derives = "Debug,Clone"
22
+ query_path = "gql/d1_query.graphql"
27
23
) ]
28
24
pub struct GetD1AnalyticsQuery ;
29
25
30
26
#[ derive( GraphQLQuery ) ]
31
27
#[ graphql(
32
28
schema_path = "gql/schema.graphql" ,
33
- query_path = "gql/durableobjects_query.graphql" ,
34
- variables_derives = "Debug" ,
35
- response_derives = "Debug,Clone"
29
+ query_path = "gql/durableobjects_query.graphql"
36
30
) ]
37
31
pub struct GetDurableObjectsAnalyticsQuery ;
38
32
39
33
#[ derive( GraphQLQuery ) ]
40
34
#[ graphql(
41
35
schema_path = "gql/schema.graphql" ,
42
- query_path = "gql/queue_backlog_query.graphql" ,
43
- variables_derives = "Debug" ,
44
- response_derives = "Debug,Clone"
36
+ query_path = "gql/queue_backlog_query.graphql"
45
37
) ]
46
38
pub struct GetQueueBacklogAnalyticsQuery ;
47
39
48
40
#[ derive( GraphQLQuery ) ]
49
41
#[ graphql(
50
42
schema_path = "gql/schema.graphql" ,
51
- query_path = "gql/queue_operations_query.graphql" ,
52
- variables_derives = "Debug" ,
53
- response_derives = "Debug,Clone"
43
+ query_path = "gql/queue_operations_query.graphql"
54
44
) ]
55
45
pub struct GetQueueOperationsAnalyticsQuery ;
56
46
@@ -110,7 +100,7 @@ pub async fn do_get_workers_analytics_query(cloudflare_api_url: &String, cloudfl
110
100
registry. register ( Box :: new ( worker_duration. clone ( ) ) ) . unwrap ( ) ;
111
101
112
102
let mut last_datetime: Option < Time > = None ;
113
- for account in response_data. clone ( ) . viewer . unwrap ( ) . accounts . iter ( ) {
103
+ for account in response_data. viewer . unwrap ( ) . accounts . iter ( ) {
114
104
for worker in account. workers_invocations_adaptive . iter ( ) {
115
105
let dimensions = worker. dimensions . as_ref ( ) . unwrap ( ) ;
116
106
last_datetime = Some ( dimensions. datetime . clone ( ) ) ;
@@ -187,7 +177,7 @@ pub async fn do_get_d1_analytics_query(cloudflare_api_url: &String, cloudflare_a
187
177
registry. register ( Box :: new ( d1_query_batch_time_ms. clone ( ) ) ) . unwrap ( ) ;
188
178
189
179
let mut last_datetime: Option < Time > = None ;
190
- for account in response_data. clone ( ) . viewer . unwrap ( ) . accounts . iter ( ) {
180
+ for account in response_data. viewer . unwrap ( ) . accounts . iter ( ) {
191
181
for group in account. d1_analytics_adaptive_groups . iter ( ) {
192
182
let dimensions = group. dimensions . as_ref ( ) . unwrap ( ) ;
193
183
last_datetime = Some ( dimensions. datetime_minute . clone ( ) ) ;
@@ -255,7 +245,7 @@ pub async fn do_get_durableobjects_analytics_query(cloudflare_api_url: &String,
255
245
registry. register ( Box :: new ( do_wall_time_microseconds. clone ( ) ) ) . unwrap ( ) ;
256
246
257
247
let mut last_datetime: Option < Time > = None ;
258
- for account in response_data. clone ( ) . viewer . unwrap ( ) . accounts . iter ( ) {
248
+ for account in response_data. viewer . unwrap ( ) . accounts . iter ( ) {
259
249
for group in account. durable_objects_invocations_adaptive_groups . iter ( ) {
260
250
let dimensions = group. dimensions . as_ref ( ) . unwrap ( ) ;
261
251
last_datetime = Some ( dimensions. datetime_minute . clone ( ) ) ;
@@ -326,7 +316,7 @@ pub async fn do_get_queue_backlog_analytics_query(cloudflare_api_url: &String, c
326
316
registry. register ( Box :: new ( queue_backlog_sample_interval. clone ( ) ) ) . unwrap ( ) ;
327
317
328
318
let mut last_datetime: Option < Time > = None ;
329
- for account in response_data. clone ( ) . viewer . unwrap ( ) . accounts . iter ( ) {
319
+ for account in response_data. viewer . unwrap ( ) . accounts . iter ( ) {
330
320
for group in account. queue_backlog_adaptive_groups . iter ( ) {
331
321
let dimensions = group. dimensions . as_ref ( ) . unwrap ( ) ;
332
322
last_datetime = Some ( dimensions. datetime_minute . clone ( ) ) ;
@@ -387,7 +377,7 @@ pub async fn do_get_queue_operations_analytics_query(cloudflare_api_url: &String
387
377
registry. register ( Box :: new ( queue_sample_interval. clone ( ) ) ) . unwrap ( ) ;
388
378
389
379
let mut last_datetime: Option < Time > = None ;
390
- for account in response_data. clone ( ) . viewer . unwrap ( ) . accounts . iter ( ) {
380
+ for account in response_data. viewer . unwrap ( ) . accounts . iter ( ) {
391
381
for group in account. queue_message_operations_adaptive_groups . iter ( ) {
392
382
let dimensions = group. dimensions . as_ref ( ) . unwrap ( ) ;
393
383
last_datetime = Some ( dimensions. datetime . clone ( ) ) ;
0 commit comments