@@ -78,11 +78,7 @@ impl MetricsHandler {
78
78
Self { telemetry }
79
79
}
80
80
81
- fn track_subscription (
82
- & self ,
83
- subscription : & Subscription ,
84
- change : SubscriptionChange ,
85
- ) {
81
+ fn track_subscription ( & self , change : SubscriptionChange ) {
86
82
if let Some ( metrics) = self . telemetry . base_metrics ( ) {
87
83
metrics. update_user_subscription_count ( & change) ;
88
84
match change {
@@ -152,7 +148,7 @@ impl SubscriptionManager {
152
148
self . active_subscriptions . insert ( subscription. clone ( ) , ( ) ) ;
153
149
self . rate_limiter . add_active_key_sub ( api_key. id ( ) ) ;
154
150
self . metrics_handler
155
- . track_subscription ( subscription , SubscriptionChange :: Added ) ;
151
+ . track_subscription ( SubscriptionChange :: Added ) ;
156
152
157
153
let api_key_id = api_key. id ( ) ;
158
154
let api_key_role = api_key. role ( ) ;
@@ -167,15 +163,15 @@ impl SubscriptionManager {
167
163
self . shutdown ( ) . await ;
168
164
if self . active_subscriptions . remove ( subscription) . is_some ( ) {
169
165
self . metrics_handler
170
- . track_subscription ( subscription , SubscriptionChange :: Removed ) ;
166
+ . track_subscription ( SubscriptionChange :: Removed ) ;
171
167
}
172
168
self . rate_limiter . remove_active_key_sub ( self . api_key . id ( ) ) ;
173
169
}
174
170
175
171
pub async fn clear_subscriptions ( & self ) {
176
- for entry in self . active_subscriptions . iter ( ) {
172
+ for _entry in self . active_subscriptions . iter ( ) {
177
173
self . metrics_handler
178
- . track_subscription ( entry . key ( ) , SubscriptionChange :: Removed ) ;
174
+ . track_subscription ( SubscriptionChange :: Removed ) ;
179
175
}
180
176
self . active_subscriptions . clear ( ) ;
181
177
self . rate_limiter . remove_active_key_sub ( self . api_key . id ( ) ) ;
0 commit comments