Allow just registerPredicate for the polling to be overridden/configured for PerResourcePollingDependentResources
还没有人认领这个 Issue。
评估
- 难度
- 3/5
- 预计耗时
- 1-2 天
- 新手友好度
- 48/100
- Issue 类型
- 功能
- 描述清晰度
- 基本清楚
- 活跃度
- 停滞
- 技术栈
- java
调研方向
首先阅读 PerResourcePollingDependentResource.createEventSource 和 PerResourcePollingConfigurationBuilder.withRegisterPredicate,以了解现有的轮询设置。添加 issue 中描述的可重写 pollingRegisterPredicate 行为,保留当前的默认轮询行为,并记录 register predicate 如何与 informer 过滤器和资源轮询交互。
由索引模型根据 Issue 内容生成。
描述
Is your feature request related to a problem? Please describe.
When using the PerResourcePollingDependentResource and you do not want polling (yet) for certain resources, it is hard to discover and cumbersome that you need to override the createEventSource method (which happens to be the only implemented method of that class) just to add the single line withRegisterPredicate(mypredicate::test) to the PerResourcePollingConfigurationBuilder-builder (which also happens to be the only configuration property that is not already out-of-the-box overridable when using PerResourcePollingDependentResource).
This has the additional downside that if the code for PerResourcePollingDependentResource.createEventSource is improved, we'd have to update our overridden method accordingly because we want the same behaviour, just only with the registerPredicate.
Describe the solution you'd like
A pollingRegisterPredicate method on PerResourcePollingDependentResource that could be overridden and by default returns null. Eg
@Override
protected Predicate<MyResource> pollingRegisterPredicate() {
return resource -> "someType".equals(resource.getSpec().type());
}
PerResourcePollingDependentResource could then use this method to configure the registerPredicate when setting op the polling event source.
Additionally, documenting the fact that by default polling is started for every resource (even if the depending reconciler has informer filters) and how this could be adjusted would greatly help new consumers.
Alternatively, an annotation @PollingRegisterPredicate could be added to your class that would then get picked up by PerResourcePollingDependentResource.
Describe alternatives you've considered
For our case (see below), it would also work if the polling picks up on the genericFilter/onAddFilter in the @ControllerConfiguration/@Informer annotations on the depending reconciler, so that the polling does not start if no event is processed by the reconciler.
We recognize that his may be too specific to our use case which may not apply to other people and is also more complex than exposing the existing registerPredicate a bit more which would also be more generic.
Additional context
Our use case is that we have a reconciler with a PerResourcePollingDependentResource which polls an external system. Our reconciler should only reconcile specific resources within a kind (eg based on a static type field). We achieve this by adding a genericFilter to the @ControllerConfiguration/@Informer annotation:
@ControllerConfiguration(informer = @Informer(genericFilter = PredicateClass.class) ...)
We noticed that, even for resources not being handled by the reconciler, polling was being started and the external system was being queried. This puts load on the operator and the external system for resource we know will never need something to happen in the external system.
This behaviour is not (clearly) documented and required some digging around to discover that PerResourcePollingConfigurationBuilder has the method withRegisterPredicate which to control this behaviour, but this method is not used by the PerResourcePollingDependentResource.
To use this register predicate, it's therefor required to override the createEventSource method of PerResourcePollingDependentResource, just to add the register predicate:
@Override
protected ExternalResourceCachingEventSource<MyInfo, MyResource> createEventSource(EventSourceContext<MyResource> context) {
return new PerResourcePollingEventSource<>(
resourceType(),
context,
new PerResourcePollingConfigurationBuilder<>(this, getPollingPeriod())
.withCacheKeyMapper(this)
.withName(name())
.withRegisterPredicate(resource -> "someType".equals(resource.getSpec().type())) // <--- only difference with original method
.build());
}
- 主要语言
- Java
- 星标
- 944
- 派生
- 242
- 平均合并
- 1 天 14 小时
- 30 天内合并 PR
- 46
贡献指南
从这里开始
- 先读完整个 Issue,再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库,在一个分支上完成修改。
- 提交 Pull Request,并在描述里引用这个 Issue 编号。
operator-framework/java-operator-sdk 的其他 Issue
-
难度 4/5 3-5 天 新手友好度 55/100
operator-framework/java-operator-sdk#3621 · 7 条评论 · 已指派 1 人 ·
-
难度 4/5 3-5 天 新手友好度 38/100
operator-framework/java-operator-sdk#3615 · 1 条评论 · 3 个 reaction ·
-
难度 4/5 3-5 天 新手友好度 45/100
operator-framework/java-operator-sdk#3568 · 1 条评论 · 1 个 reaction ·
-
难度 5/5 一周以上 新手友好度 25/100
-
operator-framework/java-operator-sdk#3538 · 2 条评论 · 已指派 2 人 ·
查看 operator-framework/java-operator-sdk 的全部 Issue
相似的 Issue
-
area/plugin
难度 2/5 1-3 小时 新手友好度 75/100
kestra-io/plugin-kestra#190 ·
-
难度 2/5 1-3 小时 新手友好度 70/100
google-ai-edge/LiteRT-LM#3739 ·
-
难度 2/5 1-3 小时 新手友好度 75/100
integra-team-red/meet-map#249 ·
-
[Studio][Bug] Cancelled create-user dialog keeps the password and admin switch for the next attempt 未关闭
难度 2/5 1-3 小时 新手友好度 75/100
apache/rocketmq-dashboard#5064 ·
-
难度 2/5 1-3 小时 新手友好度 75/100
wso2/dpdp-accelerator#287 ·