Skip to content

Commit b60be0c

Browse files
committed
Use StreamingList initial list strategy for k8s watch
1 parent a4426e6 commit b60be0c

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/providers/k8s.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,9 @@ fn configmap_events(
165165
let config_writer = kube::runtime::reflector::store::Writer::<ConfigMap>::default();
166166
kube::runtime::watcher(
167167
configmap,
168-
kube::runtime::watcher::Config::default().labels("quilkin.dev/configmap=true"),
168+
kube::runtime::watcher::Config::default()
169+
.labels("quilkin.dev/configmap=true")
170+
.streaming_lists(),
169171
)
170172
.default_backoff()
171173
.reflect(config_writer)
@@ -182,6 +184,7 @@ fn gameserver_events(
182184
let gs_writer =
183185
kube::runtime::reflector::store::Writer::<DeserializeGuard<GameServer>>::default();
184186
let mut config = kube::runtime::watcher::Config::default()
187+
.streaming_lists()
185188
// Default timeout is 5 minutes, far too slow for us to react.
186189
.timeout(15);
187190

0 commit comments

Comments
 (0)