Support for removing metrics registered by CaffeineCacheMetrics

[anuragagarwal561994]

Please describe the feature request.
Currently we are able to add instrumentations of lets say caffeine cache based on a reference but we can't remove them.

Rationale
The rationale behind this is we have a caffiene cache that is configurable from database config and hence we change the reference for the same and they are re-constructed. In this case we remove the reference to old caches and add new ones but we want to re-register the new ones but since one is already registered with the ealier name the new one is not registered and honoured, hence we should have a way to remove the old ones and be able to replace it with the new ones.

[jonatan-ivanov]

The MeterRegistry has two remove methods: registry.remove(Meter) and registry.remove(Meter.Id).
KafkaMetrics does something similar because of a similar reason: Kafka drops data holder instances and recreates them: Micrometer needs to re-register them, you might want to take a look and see how it is doing this.

Btw we have instrumentation for Caffeine, see CaffeineCacheMetrics doesn't that provide the data you need?

[anuragagarwal561994]

Yes I am using CaffeineCacheMetrics only but it doens't provide a remove method of the metrics it is registering so for example if I do something like:

var cache = Caffeine.newBuilder().build();
Metrics.addRegistry(new SimpleMeterRegistry());
CaffeineCacheMetrics.monitor(Metrics.globalRegistry, cache, "cache");
cache = Caffeine.newBuilder().build();
CaffeineCacheMetrics.monitor(Metrics.globalRegistry, cache, "cache");

Then second instance of cache is not replaced by earlier instance of cahce, I would be adding my values in the new instance but still the meters will be recording the ealrier instance or since it is WeakReference not sure what will be the behaviour.

[anuragagarwal561994]

I have to do something like this, myself before adding another cache which seems like can be provided as a method in CaffeineCacheMetrics.unmonitor(registry, cacheName) or something similar:

List<Meter> metersToRemove = new ArrayList<>();
    MeterRegistry meterRegistry = Metrics.globalRegistry;
    meterRegistry.forEachMeter(meter -> {
      if (StringUtils.equals(meter.getId().getTag("cache"), cacheName)) {
        metersToRemove.add(meter);
      }
    });
    metersToRemove.forEach(meterRegistry::remove);

[jonatan-ivanov]

Oh I think I misunderstood what you are trying to do.

Yes I am using CaffeineCacheMetrics only but it doens't provide a remove method of the metrics it is registering

It should not, why would it need to?

Then second instance of cache is not replaced by earlier instance of cahce, I would be adding my values in the new instance but still the meters will be recording the ealrier instance

That's expected, why do you want to use the binder twice?

[anuragagarwal561994]

Because I want to re-register the cache with the new config. I have a cache which I have configured with lets say a refresh interval of 30 mins and now in the runitme I would want to change it to 1 hour. So I would create a new cache instance and replace the old one in my code and would like to re-register the metrics in micrometer for the new cache instance.

[jonatan-ivanov]

I see, so you are dropping your whole cache with its config runtime and create a new one from scratch. I think a close/de-register on the cache binder could be possible but this could be an even broader possible feature for every binder.

Let me discuss this with @shakuzen and see what we could do.

[anuragagarwal561994]

I haven't checked other metrics, I think there might be some instrumentation where this can be possible

[ben-manes]

fwiw, you can reconfigure the cache at runtime using cache.policy(), e.g. setRefreshesAfter(duration). The features have to be defined at construction time, but afterwards you can perform feature-specific inspections and operations.