feat(load-generator): Adapt OpenFeature OFREP instead of IN_PROCESS (#2114)

* feat(load-generator): Adapt OpenFeature OFREP instead of IN_PROCESS

OpenFeature supports multiple different modes.
The newest implementation relies on threads and other python internal,
which seem to be monkeypatched by locust.
Due to this, the IN_PROCESS mode is not working properly anymore and
is causing issues.

Instead we suggest to switch to the OFREP (OpenFeature Remote Evaluation Protocol)
for this usecase. This is a simple http call which will return all evaluate flags,
and will regularly poll for changes.

Signed-off-by: Simon Schrottner <simon.schrottner@dynatrace.com>

* Add ports to docker-compose.minimal

* fixup: add missing envvar for the ofrepport to the loadgenerator

Signed-off-by: Simon Schrottner <simon.schrottner@dynatrace.com>

* Add FLAGD_OFREP_PORT to docker compose minimal

---------

Signed-off-by: Simon Schrottner <simon.schrottner@dynatrace.com>
Co-authored-by: Juliano Costa <juliano.costa@datadoghq.com>
Co-authored-by: Juliano Costa <julianocosta89@outlook.com>

Author: aepfli

.env

@@ -133,6 +133,7 @@ SHIPPING_DOCKERFILE=./src/shipping/Dockerfile
 # Flagd
 FLAGD_HOST=flagd
 FLAGD_PORT=8013
+FLAGD_OFREP_PORT=8016
 
 # Flagd UI
 FLAGD_UI_HOST=flagd-ui

CHANGELOG.md

@@ -12,6 +12,9 @@ the release.
 * [quote] Updated open-telemetry/exporter-otlp to 1.2.1 which includes the
   fix for `IS_REMOTE` flag feature
   ([#2112](https://github.com/open-telemetry/opentelemetry-demo/pull/2112))
+* [load-generator] Change OpenFeature Evaluation to Remote Evaluation Protocol,
+  based on [this issue in OpenFeature/python-sdk-contrib](https://github.com/open-feature/python-sdk-contrib/issues/198)
+  ([#2114](https://github.com/open-telemetry/opentelemetry-demo/pull/2114))
 
 ## 2.0.1
 

docker-compose.minimal.yml

@@ -345,7 +345,7 @@ services:
       - PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=python
       - LOCUST_WEB_HOST=0.0.0.0
       - FLAGD_HOST
-      - FLAGD_PORT
+      - FLAGD_OFREP_PORT
     depends_on:
       frontend:
         condition: service_started
@@ -522,7 +522,8 @@ services:
       "file:./etc/flagd/demo.flagd.json"
     ]
     ports:
-      - 8013
+      - "${FLAGD_PORT}"
+      - "${FLAGD_OFREP_PORT}"
     volumes:
       - ./src/flagd:/etc/flagd
     logging:

docker-compose.yml

@@ -421,7 +421,7 @@ services:
       - PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=python
       - LOCUST_WEB_HOST=0.0.0.0
       - FLAGD_HOST
-      - FLAGD_PORT
+      - FLAGD_OFREP_PORT
     depends_on:
       frontend:
         condition: service_started
@@ -608,7 +608,8 @@ services:
       "file:./etc/flagd/demo.flagd.json"
     ]
     ports:
-      - 8013
+      - "${FLAGD_PORT}"
+      - "${FLAGD_OFREP_PORT}"
     volumes:
       - ./src/flagd:/etc/flagd
     logging:

src/load-generator/locustfile.py

@@ -34,7 +34,7 @@
 from opentelemetry.sdk.resources import Resource
 
 from openfeature import api
-from openfeature.contrib.provider.flagd import FlagdProvider
+from openfeature.contrib.provider.ofrep import OFREPProvider
 from openfeature.contrib.hook.opentelemetry import TracingHook
 
 from playwright.async_api import Route, Request
@@ -69,7 +69,8 @@
 logging.info("Instrumentation complete")
 
 # Initialize Flagd provider
-api.set_provider(FlagdProvider(host=os.environ.get('FLAGD_HOST', 'flagd'), port=os.environ.get('FLAGD_PORT', 8013)))
+base_url = f"http://{os.environ.get('FLAGD_HOST', 'localhost')}:{os.environ.get('FLAGD_OFREP_PORT', 8016)}"
+api.set_provider(OFREPProvider(base_url=base_url))
 api.add_hooks([TracingHook()])
 
 def get_flagd_value(FlagName):

src/load-generator/requirements.txt

@@ -31,7 +31,7 @@ opentelemetry-sdk==1.30.0
 opentelemetry-semantic-conventions==0.51b0
 opentelemetry-util-http==0.51b0
 openfeature-sdk==0.8.0
-openfeature-provider-flagd==0.1.5
+openfeature-provider-ofrep==0.1.1
 openfeature-hooks-opentelemetry==0.2.0
 protobuf==5.29.3
 psutil==6.1.1