Unverified Commit b01541c4 authored by atchernych's avatar atchernych Committed by GitHub
Browse files

feat: enable routers sync in EPP (#3657)


Signed-off-by: default avatarAnna Tchernych <atchernych@nvidia.com>
parent 598cbbb7
...@@ -407,7 +407,7 @@ index 0000000..b689c00 ...@@ -407,7 +407,7 @@ index 0000000..b689c00
+ - pluginRef: picker + - pluginRef: picker
diff --git a/pkg/epp/scheduling/plugins/dynamo_kv_scorer/plugin.go b/pkg/epp/scheduling/plugins/dynamo_kv_scorer/plugin.go diff --git a/pkg/epp/scheduling/plugins/dynamo_kv_scorer/plugin.go b/pkg/epp/scheduling/plugins/dynamo_kv_scorer/plugin.go
new file mode 100644 new file mode 100644
index 0000000..1f6a41f index 0000000..83a4ace
--- /dev/null --- /dev/null
+++ b/pkg/epp/scheduling/plugins/dynamo_kv_scorer/plugin.go +++ b/pkg/epp/scheduling/plugins/dynamo_kv_scorer/plugin.go
@@ -0,0 +1,428 @@ @@ -0,0 +1,428 @@
...@@ -669,7 +669,7 @@ index 0000000..1f6a41f ...@@ -669,7 +669,7 @@ index 0000000..1f6a41f
+ C.double(ffiOverlapScoreWeight), + C.double(ffiOverlapScoreWeight),
+ C.double(ffiRouterTemperature), + C.double(ffiRouterTemperature),
+ C.bool(getEnvBoolOrDefault("DYNAMO_USE_KV_EVENTS", true)), + C.bool(getEnvBoolOrDefault("DYNAMO_USE_KV_EVENTS", true)),
+ C.bool(getEnvBoolOrDefault("DYNAMO_ROUTER_REPLICA_SYNC", false)), + C.bool(getEnvBoolOrDefault("DYNAMO_ROUTER_REPLICA_SYNC", true)),
+ &pipeline, + &pipeline,
+ ) + )
+ if rc != C.DYNAMO_OK { + if rc != C.DYNAMO_OK {
......
...@@ -98,6 +98,8 @@ spec: ...@@ -98,6 +98,8 @@ spec:
value: "{{ $comp }}" value: "{{ $comp }}"
- name: DYNAMO_KV_BLOCK_SIZE - name: DYNAMO_KV_BLOCK_SIZE
value: "{{ $kv }}" value: "{{ $kv }}"
- name: DYNAMO_ROUTER_REPLICA_SYNC
value: "true"
- name: USE_STREAMING - name: USE_STREAMING
value: "true" value: "true"
{{- end }} {{- end }}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment