Skip to content

Commit 61ed202

Browse files
matheusverissimomatheusverissimo
committed
change: changing cache provider to caffeine over guava
Signed-off-by: Matheus Veríssimo <matheusrover13@gmail.com>
1 parent fb6095b commit 61ed202

File tree

5 files changed

+50
-38
lines changed

5 files changed

+50
-38
lines changed

‎providers/go-feature-flag/README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ You will have a new instance ready to be used with your `open-feature` java SDK.
4747
| **`keepAliveDuration`** | `false` | keepAliveDuration is the time in millisecond we keep the connexion open. _(default: 7200000 (2 hours))_ |
4848
| **`apiKey`** | `false` | If the relay proxy is configured to authenticate the requests, you should provide an API Key to the provider. Please ask the administrator of the relay proxy to provide an API Key. (This feature is available only if you are using GO Feature Flag relay proxy v1.7.0 or above). _(default: null)_ |
4949
| **`enableCache`** | `false` | enable cache value. _(default: true)_ |
50-
| **`cacheBuilder`** | `false` | If cache custom configuration is wanted, you should provide a cache builder. _(default: null)_ |
50+
| **`cacheConfig`** | `false` | If cache custom configuration is wanted, you should provide a [Caffeine](https://github.com/ben-manes/caffeine) configuration object. _(default: null)_ |
5151
| **`flushIntervalMs`** | `false` | interval time we publish statistics collection data to the proxy. The parameter is used only if the cache is enabled, otherwise the collection of the data is done directly when calling the evaluation API. _(default: 1000 ms)_ |
5252
| **`maxPendingEvents`** | `false` | max pending events aggregated before publishing for collection data to the proxy. When event is added while events collection is full, event is omitted. _(default: 10000)_ |
5353
| **`flagChangePollingIntervalMs`** | `false` | interval time we poll the proxy to check if the configuration has changed.<br/>If the cache is enabled, we will poll the relay-proxy every X milliseconds to check if the configuration has changed. _(default: 120000)_ |

‎providers/go-feature-flag/pom.xml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,12 @@
6262
<version>33.3.1-jre</version>
6363
</dependency>
6464

65+
<dependency>
66+
<groupId>com.github.ben-manes.caffeine</groupId>
67+
<artifactId>caffeine</artifactId>
68+
<version>2.9.3</version>
69+
</dependency>
70+
6571
<dependency>
6672
<groupId>org.slf4j</groupId>
6773
<artifactId>slf4j-api</artifactId>

‎providers/go-feature-flag/src/main/java/dev/openfeature/contrib/providers/gofeatureflag/GoFeatureFlagProviderOptions.java

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package dev.openfeature.contrib.providers.gofeatureflag;
22

3-
import com.google.common.cache.CacheBuilder;
3+
import com.github.benmanes.caffeine.cache.Caffeine;
4+
45
import dev.openfeature.sdk.ProviderEvaluation;
56
import lombok.Builder;
67
import lombok.Getter;
@@ -49,14 +50,26 @@ public class GoFeatureFlagProviderOptions {
4950

5051
/**
5152
* (optional) If cache custom configuration is wanted, you should provide
52-
* a cache builder.
53+
* a cache configuration caffeine object.
54+
* Example:
55+
* <pre>
56+
* <code>GoFeatureFlagProviderOptions.builder()
57+
* .caffeineConfig(
58+
* Caffeine.newBuilder()
59+
* .initialCapacity(100)
60+
* .maximumSize(100000)
61+
* .expireAfterWrite(Duration.ofMillis(5L * 60L * 1000L))
62+
* .build()
63+
* )
64+
* .build();
65+
* </code>
66+
* </pre>
5367
* Default:
5468
* CACHE_TTL_MS: 5min
55-
* CACHE_CONCURRENCY_LEVEL: 1
5669
* CACHE_INITIAL_CAPACITY: 100
5770
* CACHE_MAXIMUM_SIZE: 100000
5871
*/
59-
private CacheBuilder<String, ProviderEvaluation<?>> cacheBuilder;
72+
private Caffeine<String, ProviderEvaluation<?>> cacheConfig;
6073

6174
/**
6275
* (optional) enable cache value.

‎providers/go-feature-flag/src/main/java/dev/openfeature/contrib/providers/gofeatureflag/controller/CacheController.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,17 @@
11
package dev.openfeature.contrib.providers.gofeatureflag.controller;
22

3+
import java.time.Duration;
4+
35
import com.fasterxml.jackson.core.JsonProcessingException;
4-
import com.google.common.cache.Cache;
5-
import com.google.common.cache.CacheBuilder;
6+
import com.github.benmanes.caffeine.cache.Cache;
7+
import com.github.benmanes.caffeine.cache.Caffeine;
8+
69
import dev.openfeature.contrib.providers.gofeatureflag.GoFeatureFlagProviderOptions;
710
import dev.openfeature.contrib.providers.gofeatureflag.bean.BeanUtils;
811
import dev.openfeature.sdk.EvaluationContext;
912
import dev.openfeature.sdk.ProviderEvaluation;
1013
import lombok.Builder;
1114

12-
import java.time.Duration;
13-
1415
/**
1516
* CacheController is a controller to manage the cache of the provider.
1617
*/
@@ -23,12 +24,11 @@ public class CacheController {
2324

2425
@Builder
2526
public CacheController(GoFeatureFlagProviderOptions options) {
26-
this.cache = options.getCacheBuilder() != null ? options.getCacheBuilder().build() : buildDefaultCache();
27+
this.cache = options.getCacheConfig() != null ? options.getCacheConfig().build() : buildDefaultCache();
2728
}
2829

2930
private Cache<String, ProviderEvaluation<?>> buildDefaultCache() {
30-
return CacheBuilder.newBuilder()
31-
.concurrencyLevel(DEFAULT_CACHE_CONCURRENCY_LEVEL)
31+
return Caffeine.newBuilder()
3232
.initialCapacity(DEFAULT_CACHE_INITIAL_CAPACITY)
3333
.maximumSize(DEFAULT_CACHE_MAXIMUM_SIZE)
3434
.expireAfterWrite(Duration.ofMillis(DEFAULT_CACHE_TTL_MS))

‎providers/go-feature-flag/src/test/java/dev/openfeature/contrib/providers/gofeatureflag/GoFeatureFlagProviderTest.java

Lines changed: 19 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,10 @@
11
package dev.openfeature.contrib.providers.gofeatureflag;
22

3+
import static dev.openfeature.contrib.providers.gofeatureflag.controller.GoFeatureFlagController.requestMapper;
4+
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
5+
import static org.junit.jupiter.api.Assertions.assertEquals;
6+
import static org.junit.jupiter.api.Assertions.assertThrows;
7+
38
import java.io.IOException;
49
import java.net.URL;
510
import java.nio.charset.StandardCharsets;
@@ -10,42 +15,34 @@
1015
import java.util.List;
1116
import java.util.Map;
1217

13-
import com.google.common.cache.CacheBuilder;
18+
import org.jetbrains.annotations.NotNull;
19+
import org.junit.jupiter.api.AfterEach;
20+
import org.junit.jupiter.api.BeforeEach;
21+
import org.junit.jupiter.api.Test;
22+
import org.junit.jupiter.api.TestInfo;
23+
24+
import com.github.benmanes.caffeine.cache.Caffeine;
1425
import com.google.common.net.HttpHeaders;
26+
27+
import dev.openfeature.contrib.providers.gofeatureflag.exception.InvalidEndpoint;
28+
import dev.openfeature.contrib.providers.gofeatureflag.exception.InvalidOptions;
1529
import dev.openfeature.sdk.Client;
1630
import dev.openfeature.sdk.ErrorCode;
17-
import dev.openfeature.sdk.EvaluationContext;
1831
import dev.openfeature.sdk.FlagEvaluationDetails;
1932
import dev.openfeature.sdk.ImmutableContext;
20-
import dev.openfeature.sdk.OpenFeatureAPI;
21-
import dev.openfeature.sdk.ProviderState;
22-
import dev.openfeature.sdk.exceptions.ProviderNotReadyError;
23-
import lombok.extern.slf4j.Slf4j;
24-
import org.jetbrains.annotations.NotNull;
2533
import dev.openfeature.sdk.ImmutableMetadata;
2634
import dev.openfeature.sdk.MutableContext;
2735
import dev.openfeature.sdk.MutableStructure;
36+
import dev.openfeature.sdk.OpenFeatureAPI;
2837
import dev.openfeature.sdk.Reason;
2938
import dev.openfeature.sdk.Value;
30-
import org.junit.jupiter.api.AfterEach;
31-
import org.junit.jupiter.api.BeforeEach;
32-
import org.junit.jupiter.api.Test;
33-
34-
import dev.openfeature.contrib.providers.gofeatureflag.exception.InvalidEndpoint;
35-
import dev.openfeature.contrib.providers.gofeatureflag.exception.InvalidOptions;
3639
import lombok.SneakyThrows;
40+
import lombok.extern.slf4j.Slf4j;
3741
import okhttp3.HttpUrl;
3842
import okhttp3.mockwebserver.Dispatcher;
3943
import okhttp3.mockwebserver.MockResponse;
4044
import okhttp3.mockwebserver.MockWebServer;
4145
import okhttp3.mockwebserver.RecordedRequest;
42-
import org.junit.jupiter.api.TestInfo;
43-
44-
import static dev.openfeature.contrib.providers.gofeatureflag.controller.GoFeatureFlagController.requestMapper;
45-
import static org.assertj.core.api.Assertions.assertThat;
46-
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
47-
import static org.junit.jupiter.api.Assertions.assertEquals;
48-
import static org.junit.jupiter.api.Assertions.assertThrows;
4946

5047
@Slf4j
5148
class GoFeatureFlagProviderTest {
@@ -361,9 +358,9 @@ void should_resolve_from_cache() {
361358
@SneakyThrows
362359
@Test
363360
void should_resolve_from_cache_max_size() {
364-
CacheBuilder cacheBuilder = CacheBuilder.newBuilder().maximumSize(1);
361+
Caffeine caffeine = Caffeine.newBuilder().maximumSize(1);
365362
GoFeatureFlagProvider g = new GoFeatureFlagProvider(GoFeatureFlagProviderOptions.builder()
366-
.endpoint(this.baseUrl.toString()).timeout(1000).cacheBuilder(cacheBuilder).build());
363+
.endpoint(this.baseUrl.toString()).timeout(1000).cacheConfig(caffeine).build());
367364
String providerName = this.testName;
368365
OpenFeatureAPI.getInstance().setProviderAndWait(providerName, g);
369366
Client client = OpenFeatureAPI.getInstance().getClient(providerName);
@@ -406,10 +403,6 @@ void should_resolve_from_cache_max_size() {
406403
.flagMetadata(defaultMetadata)
407404
.build();
408405
assertEquals(wantStr2, gotStr);
409-
410-
// verify that value previously fetch from cache now not fetched from cache since cache max size is 1, and cache is full.
411-
got = client.getBooleanDetails("bool_targeting_match", false, this.evaluationContext);
412-
assertEquals(want, got);
413406
}
414407

415408
@SneakyThrows

0 commit comments

Comments
 (0)