@@ -129,7 +129,7 @@ impl key_value::HostStore for KeyValueDispatch {
129
129
. await )
130
130
}
131
131
132
- #[ instrument( name = "spin_key_value.get" , skip ( self , store , key ) , fields( otel. kind = "client" ) ) ]
132
+ #[ instrument( name = "spin_key_value.get" , skip_all , fields( otel. kind = "client" ) ) ]
133
133
async fn get (
134
134
& mut self ,
135
135
store : Resource < key_value:: Store > ,
@@ -139,7 +139,7 @@ impl key_value::HostStore for KeyValueDispatch {
139
139
Ok ( store. get ( & key) . await . map_err ( track_error_on_span) )
140
140
}
141
141
142
- #[ instrument( name = "spin_key_value.set" , skip ( self , store , key , value ) , fields( otel. kind = "client" ) ) ]
142
+ #[ instrument( name = "spin_key_value.set" , skip_all , fields( otel. kind = "client" ) ) ]
143
143
async fn set (
144
144
& mut self ,
145
145
store : Resource < key_value:: Store > ,
@@ -150,7 +150,7 @@ impl key_value::HostStore for KeyValueDispatch {
150
150
Ok ( store. set ( & key, & value) . await . map_err ( track_error_on_span) )
151
151
}
152
152
153
- #[ instrument( name = "spin_key_value.delete" , skip ( self , store , key ) , fields( otel. kind = "client" ) ) ]
153
+ #[ instrument( name = "spin_key_value.delete" , skip_all , fields( otel. kind = "client" ) ) ]
154
154
async fn delete (
155
155
& mut self ,
156
156
store : Resource < key_value:: Store > ,
@@ -160,7 +160,7 @@ impl key_value::HostStore for KeyValueDispatch {
160
160
Ok ( store. delete ( & key) . await . map_err ( track_error_on_span) )
161
161
}
162
162
163
- #[ instrument( name = "spin_key_value.exists" , skip ( self , store , key ) , fields( otel. kind = "client" ) ) ]
163
+ #[ instrument( name = "spin_key_value.exists" , skip_all , fields( otel. kind = "client" ) ) ]
164
164
async fn exists (
165
165
& mut self ,
166
166
store : Resource < key_value:: Store > ,
@@ -170,7 +170,7 @@ impl key_value::HostStore for KeyValueDispatch {
170
170
Ok ( store. exists ( & key) . await . map_err ( track_error_on_span) )
171
171
}
172
172
173
- #[ instrument( name = "spin_key_value.get_keys" , skip ( self , store ) , fields( otel. kind = "client" ) ) ]
173
+ #[ instrument( name = "spin_key_value.get_keys" , skip_all , fields( otel. kind = "client" ) ) ]
174
174
async fn get_keys (
175
175
& mut self ,
176
176
store : Resource < key_value:: Store > ,
@@ -205,7 +205,7 @@ fn to_wasi_err(e: Error) -> wasi_keyvalue::store::Error {
205
205
}
206
206
207
207
impl wasi_keyvalue:: store:: Host for KeyValueDispatch {
208
- #[ instrument( name = "wasi_key_value.open" , skip ( self , identifier ) , fields( otel. kind = "client" ) ) ]
208
+ #[ instrument( name = "wasi_key_value.open" , skip_all , fields( otel. kind = "client" ) ) ]
209
209
async fn open (
210
210
& mut self ,
211
211
identifier : String ,
@@ -233,7 +233,7 @@ impl wasi_keyvalue::store::Host for KeyValueDispatch {
233
233
234
234
use wasi_keyvalue:: store:: Bucket ;
235
235
impl wasi_keyvalue:: store:: HostBucket for KeyValueDispatch {
236
- #[ instrument( name = "wasi_key_value.get" , skip ( self , self_ , key ) , fields( otel. kind = "client" ) ) ]
236
+ #[ instrument( name = "wasi_key_value.get" , skip_all , fields( otel. kind = "client" ) ) ]
237
237
async fn get (
238
238
& mut self ,
239
239
self_ : Resource < Bucket > ,
@@ -243,7 +243,7 @@ impl wasi_keyvalue::store::HostBucket for KeyValueDispatch {
243
243
store. get ( & key) . await . map_err ( to_wasi_err)
244
244
}
245
245
246
- #[ instrument( name = "wasi_key_value.set" , skip ( self , self_ , key , value ) , fields( otel. kind = "client" ) ) ]
246
+ #[ instrument( name = "wasi_key_value.set" , skip_all , fields( otel. kind = "client" ) ) ]
247
247
async fn set (
248
248
& mut self ,
249
249
self_ : Resource < Bucket > ,
@@ -254,7 +254,7 @@ impl wasi_keyvalue::store::HostBucket for KeyValueDispatch {
254
254
store. set ( & key, & value) . await . map_err ( to_wasi_err)
255
255
}
256
256
257
- #[ instrument( name = "wasi_key_value.delete" , skip ( self , self_ , key ) , fields( otel. kind = "client" ) ) ]
257
+ #[ instrument( name = "wasi_key_value.delete" , skip_all , fields( otel. kind = "client" ) ) ]
258
258
async fn delete (
259
259
& mut self ,
260
260
self_ : Resource < Bucket > ,
@@ -264,7 +264,7 @@ impl wasi_keyvalue::store::HostBucket for KeyValueDispatch {
264
264
store. delete ( & key) . await . map_err ( to_wasi_err)
265
265
}
266
266
267
- #[ instrument( name = "wasi_key_value.exists" , skip ( self , self_ , key ) , fields( otel. kind = "client" ) ) ]
267
+ #[ instrument( name = "wasi_key_value.exists" , skip_all , fields( otel. kind = "client" ) ) ]
268
268
async fn exists (
269
269
& mut self ,
270
270
self_ : Resource < Bucket > ,
@@ -274,7 +274,7 @@ impl wasi_keyvalue::store::HostBucket for KeyValueDispatch {
274
274
store. exists ( & key) . await . map_err ( to_wasi_err)
275
275
}
276
276
277
- #[ instrument( name = "wasi_key_value.list_keys" , skip ( self , self_ , cursor ) , fields( otel. kind = "client" ) ) ]
277
+ #[ instrument( name = "wasi_key_value.list_keys" , skip_all , fields( otel. kind = "client" ) ) ]
278
278
async fn list_keys (
279
279
& mut self ,
280
280
self_ : Resource < Bucket > ,
@@ -299,7 +299,7 @@ impl wasi_keyvalue::store::HostBucket for KeyValueDispatch {
299
299
}
300
300
301
301
impl wasi_keyvalue:: batch:: Host for KeyValueDispatch {
302
- #[ instrument( name = "spin_key_value.get_many" , skip ( self , bucket , keys ) , fields( otel. kind = "client" ) ) ]
302
+ #[ instrument( name = "spin_key_value.get_many" , skip_all , fields( otel. kind = "client" ) ) ]
303
303
#[ allow( clippy:: type_complexity) ]
304
304
async fn get_many (
305
305
& mut self ,
@@ -313,7 +313,7 @@ impl wasi_keyvalue::batch::Host for KeyValueDispatch {
313
313
store. get_many ( keys) . await . map_err ( to_wasi_err)
314
314
}
315
315
316
- #[ instrument( name = "spin_key_value.set_many" , skip ( self , bucket , key_values ) , fields( otel. kind = "client" ) ) ]
316
+ #[ instrument( name = "spin_key_value.set_many" , skip_all , fields( otel. kind = "client" ) ) ]
317
317
async fn set_many (
318
318
& mut self ,
319
319
bucket : Resource < wasi_keyvalue:: batch:: Bucket > ,
@@ -326,7 +326,7 @@ impl wasi_keyvalue::batch::Host for KeyValueDispatch {
326
326
store. set_many ( key_values) . await . map_err ( to_wasi_err)
327
327
}
328
328
329
- #[ instrument( name = "spin_key_value.delete_many" , skip ( self , bucket , keys ) , fields( otel. kind = "client" ) ) ]
329
+ #[ instrument( name = "spin_key_value.delete_many" , skip_all , fields( otel. kind = "client" ) ) ]
330
330
async fn delete_many (
331
331
& mut self ,
332
332
bucket : Resource < wasi_keyvalue:: batch:: Bucket > ,
@@ -341,7 +341,7 @@ impl wasi_keyvalue::batch::Host for KeyValueDispatch {
341
341
}
342
342
343
343
impl wasi_keyvalue:: atomics:: HostCas for KeyValueDispatch {
344
- #[ instrument( name = "wasi_key_value_cas.new" , skip ( self , bucket , key ) , fields( otel. kind = "client" ) ) ]
344
+ #[ instrument( name = "wasi_key_value_cas.new" , skip_all , fields( otel. kind = "client" ) ) ]
345
345
async fn new (
346
346
& mut self ,
347
347
bucket : Resource < wasi_keyvalue:: atomics:: Bucket > ,
@@ -364,7 +364,7 @@ impl wasi_keyvalue::atomics::HostCas for KeyValueDispatch {
364
364
. map ( Resource :: new_own)
365
365
}
366
366
367
- #[ instrument( name = "wasi_key_value_cas.current" , skip ( self , cas ) , fields( otel. kind = "client" ) ) ]
367
+ #[ instrument( name = "wasi_key_value_cas.current" , skip_all , fields( otel. kind = "client" ) ) ]
368
368
async fn current (
369
369
& mut self ,
370
370
cas : Resource < wasi_keyvalue:: atomics:: Cas > ,
@@ -389,7 +389,7 @@ impl wasi_keyvalue::atomics::Host for KeyValueDispatch {
389
389
Ok ( error)
390
390
}
391
391
392
- #[ instrument( name = "spin_key_value.increment" , skip ( self , bucket , key , delta ) , fields( otel. kind = "client" ) ) ]
392
+ #[ instrument( name = "spin_key_value.increment" , skip_all , fields( otel. kind = "client" ) ) ]
393
393
async fn increment (
394
394
& mut self ,
395
395
bucket : Resource < wasi_keyvalue:: atomics:: Bucket > ,
@@ -400,7 +400,7 @@ impl wasi_keyvalue::atomics::Host for KeyValueDispatch {
400
400
store. increment ( key, delta) . await . map_err ( to_wasi_err)
401
401
}
402
402
403
- #[ instrument( name = "spin_key_value.swap" , skip ( self , cas_res , value ) , fields( otel. kind = "client" ) ) ]
403
+ #[ instrument( name = "spin_key_value.swap" , skip_all , fields( otel. kind = "client" ) ) ]
404
404
async fn swap (
405
405
& mut self ,
406
406
cas_res : Resource < atomics:: Cas > ,
0 commit comments