首页
开源
资讯
活动
开源许可证
软件工程云服务
软件代码质量检测云服务
持续集成与部署云服务
社区个性化内容推荐服务
贡献审阅人推荐服务
群体化学习服务
重睛鸟代码扫描工具
登录
注册
代码拉取完成,页面将自动刷新
Watch
34
Star
309
Fork
74
Ahoo-Wang
/
Wow
Fork 仓库
加载中
取消
确认
代码
Issues
2
Pull Requests
0
Wiki
0
统计
发行版
最新版
v3.18.6
5ad7127
2024-12-19 13:24
对比
v3.18.6
Ahoo-Wang
## 更新内容 > 增强数据安全性! * 特性(query): 添加 `StateDynamicDocumentMasker` 以支持状态聚合的动态文档脱敏 * 特性(query): 添加 `EventStreamDynamicDocumentMasker` 以支持事件流的动态文档脱敏 * 特性(query): `EventStreamQueryService` 支持 `count` 函数接口 * 特性(core): 添加 `StateRecord` 以 支持跨服务上下文使用 `@OnStateEvent` 订阅状态聚合事件,以降低RPC成本。 * 依赖(core): 更新 `com.google.guava:guava` 到 `v33.4.0-jre` * 依赖(build): 更新 `org.jetbrains.dokka` 到 `v2` * 依赖(openapi): 更新 `io.swagger.core.v3:swagger-core-jakarta` 到 `v2.2.27`
最后提交信息为:
feat(webflux): add data masking function to load aggregate state (#...
v3.18.0
9950741
2024-12-12 08:21
对比
v3.18.0
Ahoo-Wang
## 更新内容 > 适配 Spring Boot 3.4.0 * 特性(query): 支持 `BEFORE_TODAY` 查询操作符 * 特性(query): 支持 `ZoneId` 条件选项 * 依赖(spring): 更新 `org.springframework.boot:spring-boot-dependencies` 到 `v3.4.0` * 依赖(core): 更新 `me.ahoo.cosid:cosid-bom` 到 `v2.10.1` * 依赖(api): 更新 `me.ahoo.coapi:coapi-bom` 到 `v1.9.1` * 依赖(compensation): 更新 `me.ahoo.simba:simba-bom` 到 `v2.6.1` * 依赖(compile): 更新 `dev.zacsweers.kctfork:ksp` 到 `v0.7.0` * 依赖(opentelemetry): 更新 `io.opentelemetry:opentelemetry-bom` 到 `v1.45.0` * 依赖(openapi): 更新 `io.swagger.core.v3:swagger-core-jakarta` 到 `v2.2.26` * 依赖(openapi): 更新 `springdoc` 到 `v2.7.0`
最后提交信息为:
fix(deps): update dependency me.ahoo.coapi:coapi-bom to v1.9.0 (#1036)
v3.16.8
9ca9714
2024-11-24 18:23
对比
v3.16.8
Ahoo-Wang
## 更新内容 * 特性(test): 支持使用 `givenState` 来编排测试,无需事件源,DEBUG 效率 * 特性(webflux): 添加 `BatchTaskException` 以记录失败的批次任务。 * 特性(mongodb): 支持使用特殊字符作为查询条件 * 特性(dashboard): 使用分页查询事件流 * 依赖(test): 更新 `org.testcontainers:testcontainers-bom` 到 `v1.20.4` * 依赖(build): 更新 `gradle` 到 `v8.11.1` * 依赖(compensation): 更新 `jte` 到 `v3.1.15`
最后提交信息为:
feat(test): Support using
givenState
to orchestrate tests, elimin...
v3.16.4
97c0e3b
2024-11-18 18:32
对比
v3.16.4
Ahoo-Wang
## 更新内容 * 特性(webflux): 当批处理任务发生异常时响应当前处理位置以及异常信息 * 特性(webflux): 确保批处理任务的有序性 * 特性(mongo): 添加 `batchSize`参数 到 `scanAggregateId` * 依赖(compensation): 更新 `me.ahoo.coapi:coapi-bom` 到 `v1.8.0` * 依赖(build): 更新 `com.google.devtools.ksp` 到 `v2.0.21-1.0.28` * 依赖(build): 更新 `codecov/codecov-action` 到 `v5` * 依赖(opentelemetry): 更新 `io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom` 到 `v2.10.0`
最后提交信息为:
feat(webflux): Improve batch operation performance (#1002)
v3.16.3
2a92873
2024-11-13 09:15
对比
v3.16.3
Ahoo-Wang
## 更新内容 > :tada: **ElasticSearch** 全面支持 _EventStore_ / _SnapshotRepository_ / _QueryService_ :tada: * 特性(es): 添加 `ElasticsearchEventStore` 以支持使用 **ElasticSearch** 作为事件源存储 * 特性(es): 添加 `ElasticsearchEventStreamQueryService` 以支持事件查询服务 * 特性(es): 添加 `IndexTemplateInitializer` 以支持自动初始化索引模板 * 特性(spring): 为 `ElasticsearchEventStore` 添加_Spring_自动配置 * 特性(core): 为 `SnapshotRepository` 添加 `AggregateIdScanner` 支持 * 特性(tck): 添加 `SnapshotQueryServiceSpec` 兼容性测试规范 * 依赖(build): 更新 `Kotlin` 到 `v2.0.21` * 依赖(build): 更新 `gradle` 到 `v8.11` * 依赖(build): 更新 `dev.zacsweers.kctfork:ksp` 到 `v0.6.0` * 依赖(compensation): 更新 `jte` 到 `v3.1.14` * 依赖(opentelemetry): 更新 `io.opentelemetry:opentelemetry-bom` 到 `v1.44.1`
最后提交信息为:
feat(core): optimize LocalFirstMessageBus (#994)
v3.15.4
3596bc2
2024-11-07 18:57
对比
v3.15.4
Ahoo-Wang
## 更新内容 * 特性(elasticsearch): 添加 `ElasticsearchSnapshotQueryService` 以支持 *ElasticSearch* 快照查询服务 * 特性(elasticsearch): `RAW` 操作符支持 `String` 和 `Map` 条件值 * 特性(elasticsearch): 为聚合快照存储配置索引模板 * 特性(core): 当创建的命令消息返回空信号时切换到异常信号 `CommandMessageFactory` * 特性(compensation): 支持使用 `ElasticSearch` 作为快照存储 * 特性(apiclient): 添加 `RestCommandGatewayException` 以提升 RESTfull 命令网关的易用性 * 重构(apiclient): 当查询请求响应 404 时切换到空信号 * 重构(compensation): 重命名 `CompensationSaga` 为 `CompensationEventProcessor` * 依赖(doc): 更新 `vitepress` 到 `v1.5.0`。
最后提交信息为:
feat(doc): update elasticsearch.md (#976)
v3.14.0
be79be6
2024-10-31 09:29
对比
v3.14.0
Ahoo-Wang
## 更新内容 * 特性(webflux): 为 `GlobalExceptionHandler` 添加 `NoResourceFoundException` 自定义支持。 * 重构(command-gateway): 统一命令验证职责到命名网关。 * 重构(core): 替换消息头KEY中的 `.` 为 `_`,以便兼容 `MongoDB`/`ElasticSearch` 的查询请求。 * 依赖(compensation): 更新 ` gg.jte:jte` 到 `v3.1.13`。 * 依赖(spring): 更新 `org.springframework.boot:spring-boot-dependencies` 到 `v3.3.5`。 * 依赖(doc): 更新 `vitepress` 到 `v1.4.2`。 * 依赖(opentelemetry): 更新 `io.opentelemetry:opentelemetry-bom` 到 `v1.43.0`。 * 依赖(opentelemetry): 更新 `io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom` 到 `v2.9.0`。 * 依赖(test): 更新 `org.testcontainers:testcontainers-bom` 到 `v1.20.3`。 * 依赖(build): 更新 `mockk` 到 `v1.13.13`。 ### Message.Header - `command.wait.*` -> `command_wait_*` - `command.operator` -> `command_operator` - `trace.id` -> `trace_id` - `upstream.id` -> `upstream_id` - `upstream.name` -> `upstream_name`
最后提交信息为:
Update Version
v3.12.11
29d8514
2024-10-29 06:48
对比
v3.12.11
Ahoo-Wang
## 更新内容 * 特性(dashboard): 支持(`NOR`)逻辑运算符。 * 特性(core): 为 `CommandBuilder` 添加支持 `LocalFirst` 模式。 * 特性(query): 为 `Condition` 添加 `options` 以提升扩展性。 * 重构(apiclient): `RestCommandGateway`。 * 重构(webflux): 使用 `appendTenantId` 替换 `Condition.and(it, Condition.tenantId(tenantId))`。 * 依赖(core): 更新 `me.ahoo.cosid:cosid-bom` 到 `v2.9.9`。 * 依赖(spring): 更新 `org.springframework.boot:spring-boot-dependencies` 到 `v3.3.4`。 * 依赖(openapi): 更新 `io.swagger.core.v3:swagger-core-jakarta` 到 `v2.2.25`。 * 依赖(opentelemetry): 更新 `io.opentelemetry:opentelemetry-bom` 到 `v1.42.1`。 * 依赖(opentelemetry): 更新 `io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom` 到 `v2.8.0`。 * 依赖(build): 更新 `detekt` 到 `v1.23.7`。 * 依赖(build): 更新 `gradle` 到 `v8.10.2`。
最后提交信息为:
Update Version
v3.12.6
9604878
2024-09-09 08:52
对比
v3.12.6
Ahoo-Wang
## 更新内容 * 特性(query): 支持或非(`NOR`)逻辑运算符。 * 依赖(dashboard): 更新 `typescript` 到 `~5.5.0`。 * 依赖(opentelemetry): 更新 `io.opentelemetry:opentelemetry-bom` 到 `1.42.0`。 * 依赖(build): 更新 `detekt` 到 `1.23.7`。 * 依赖(dashboard): 更新 `jasmine-core` 到 `~5.3.0`。 ### QueryDsl ```kotlin condition { deleted(false) and { tenantId("tenantId") all() } nor { all() } id("id") ids("id", "id2") "field1" eq "value1" "field2" ne "value2" "filed3" gt 1 "field4" lt 1 "field5" gte 1 "field6" lte 1 "field7" contains "value7" "field8" isIn listOf("value8") "field9" notIn listOf("value9") "field10" between (1 to 2) "field100" between 1 to 2 "field11" all listOf("value11") "field12" startsWith "value12" "field12" endsWith "value12" "field13" elemMatch { "field14" eq "value14" } "field15".isNull() "field16".notNull() "field17".isTrue() "field18".isFalse() and { "field3" eq "value3" "field4" eq "value4" } or { "field3" eq "value3" "field4" eq "value4" } "field19".today() "field20".tomorrow() "field21".thisWeek() "field22".nextWeek() "field23".lastWeek() "field24".thisMonth() "field25".lastMonth() "field26".recentDays(1) raw("1=1") "state" nested { "field27" eq "value27" "field28" eq "value28" "child" nested { "field29" eq "value29" } nested("") "field30" eq "value30" } } ```
最后提交信息为:
Update Version
v3.12.5
b985a93
2024-09-05 20:40
对比
v3.12.5
Ahoo-Wang
## 更新内容 * 特性(compensation): 合并领域事件补偿、状态事件补偿为事件补偿。 * 特性(mongo): 自动为快照创建 `deleted` 索引。 * 重构(query): 移除重复的状态字段定义。 * 依赖(doc): 更新 `vitepress` 到 `v1.3.4`。 * 依赖(dashboard): 更新 `monaco-editor` 到 `^0.51.0`。 * 依赖(openapi): 更新 `io.swagger.core.v3:swagger-core-jakarta` 到 `v2.2.23`。 * 依赖(compensation): 更新 `me.ahoo.coapi:coapi-bom` 到 `v1.6.9`。
最后提交信息为:
feat(core): Improve unit test coverage (#910)
v3.12.3
aa31889
2024-08-23 14:09
对比
v3.12.3
Ahoo-Wang
## 更新内容 * 特性(query): 添加 `EventStreamQueryService` API * 特性(spring): 添加 `EventStreamQueryServiceRegistrar` 以支持自动注入 `EventStreamQueryService` * 特性(openapi): 添加 `ListQueryEventStreamRouteSpec` 以支持自动注册 RESTfull API 端点 * 特性(apiclient): 支持 `SyncSnapshotQueryApi` 和 `SyncRestCommandGateway` * 特性(test): 为 `for` 添加 `deepCody` 支持。 * 特性(test): 支持通过 `ExpectedResult` 获取 `DomainEventExchange`。 * 重构(dashboard): 使用 `EventStreamQueryService` 加载重试历史。 * 依赖(core): 更新 `me.ahoo.cosid:cosid-bom` 到 `v2.9.6`。 * 依赖(spring): 更新 `org.springframework.boot:spring-boot-dependencies` 到 `v3.3.3`。 * 依赖(opentelemetry): 更新 `io.opentelemetry:opentelemetry-bom` 到 `v1.41.0`。 * 依赖(opentelemetry): 更新 `io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom` 到 `v2.7.0`。 * 依赖(build): 更新 `gradle` 到 `v8.10`。 * 依赖(core): 更新 `com.google.guava:guava` 到 `v33.3.0-jre`。 * 依赖(doc): 更新 `vitepress` 到 `v1.3.3`。
最后提交信息为:
feat(test): Support get
DomainEventExchange
by
ExpectedResult
. ...
v3.11.6
f7ccfeb
2024-08-09 14:06
对比
v3.11.6
Ahoo-Wang
## 更新内容 * 特性(api): `Condition` 添加 `valueAs` 以支持边界的类型转换。 * 特性(core): 添加深拷贝 `deepCody` 扩展函数。 * 依赖(build): 更新 `kotlin` 到 `v2.0.10`。 * 依赖(build): 更新 `ksp` 到 `v2.0.10-1.0.24`。 * 依赖(build): 更新 `org.jetbrains.kotlin.kapt` 到 `v2.0.10`。 * 依赖(test): 更新 `org.hamcrest:hamcrest` 到 `v3`。 * 依赖(doc): 更新 `vitepress` 到 `v1.3.2`。
最后提交信息为:
feat(core): support
deepCody
ext fun (#878)
v3.11.4
54be6c5
2024-08-02 09:20
对比
v3.11.4
Ahoo-Wang
## 更新内容 * 特性(core): 添加 `TraceMessagePropagator` 以支持消息跟踪。 * 特性(core): 支持 `Saga `函数生成的命令的消息传播。 * 依赖(test): 更新 `org.testcontainers:testcontainers-bom` 到 `v1.20.1`。
最后提交信息为:
feat(core): add
TraceMessagePropagator
to support message tracing...
v3.11.3
4739369
2024-08-01 10:13
对比
v3.11.3
Ahoo-Wang
## 更新内容 * 特性(core): 添加 `CommandBuilderRewriter` 支持 重写命令消息体。 * 特性(core): 当本地消息总线出现背压时,临时降级 `LocalFirst` 模式。 * 特性(core): 添加检查点(`checkpoint`)以提高调试能力。 * 特性(core): 为 `MessageFunction` 添加 `qualifiedName`。 * 特性(api): 添加 `FunctionInfo` API。 * 特性(core): 添加 `CommandNameMessagePropagator` 以支持命令名称向 事件流 传播。 * 特性(opentelemetry): 使用事件函数的完全限定名称作为 `SpanName` 。 * 特性(core): 为 `WaitSignal` 添加 `FunctionInfo` 支持。 * 特性(openapi): 支持定义命令的路由顺序。 * 特性(core): `sortedByOrder` 扩展函数支持对 `JavaClass` 和 `KClass` 排序。 * 特性(api): 支持 `Mount` 命令到聚合根,主要用于命令重写场景。同时,它会在OpenApi中生成命令路由。 * 特性(compensation): 禁用 `CompensationSaga` 的重试策略。 * 修复(dashboard): 无法正确初始化 `ApplyRetrySpecComponent` 对问题 * 依赖(dashboard): 更新 `jasmine-core` 到 `~5.2.0` * 依赖(core): 更新 `me.ahoo.cosid:cosid-bom` 到 `v2.9.3` * 依赖(build): 更新 `ksp` 到 `v2.0.0-1.0.24`
最后提交信息为:
feat(core): Support Sort JavaClass / KClass for
sortedByOrder
. (#...
v3.10.3
d144591
2024-07-22 09:12
对比
v3.10.3
Ahoo-Wang
## 更新内容 * 特性(core): 使用 `CommandBuilder` 替换 `CommandOptions`。 * 特性(core): `StatelessSagaFunction` 支持 `CommandBuilder` 返回值。 * 特性(doc): 更新 Saga 文档。 * 依赖(deps): 更新 `org.springframework.boot:spring-boot-dependencies` 到 `v3.3.2` * 依赖(core): 更新 `me.ahoo.cosid:cosid-bom` 到 `v2.9.2` * 依赖(compensation): 更新 `me.ahoo.coapi:coapi-bom` 到 `v1.6.8` * 依赖(compensation): 更新 `me.ahoo.simba:simba-bom` 到 `v2.5.2` * 依赖(build): 更新 `gradle` 到 `v8.9` * 依赖(build): 更新 `ksp` 到 `v2.0.0-1.0.23` * 依赖(doc): 更新 `vitepress` 到 `v1.3.1` * 依赖(test): 更新 `io.mockk:mockk` 到 `v1.13.12` * 依赖(opentelemetry): 更新 `io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom` 到 `v2.6.0` * 依赖(test): 更新 `org.testcontainers:testcontainers-bom` 到 `v1.20.0`
最后提交信息为:
Update Version
v3.10.0
bec0b75
2024-07-12 09:32
对比
v3.10.0
Ahoo-Wang
## 更新内容 * 特性(core): 添加 `RecoverAggregate` API以支持恢复已删除的聚合根。 * 特性(core): 添加 `generateGlobalId` 便捷的生成全局ID。 * 特性(core): `SimpleServiceProvider` 支持 `Copy` 。 * 特性(test): 在测试编排`fork`后使用复制的`ServiceProvider`作为上下文,以防止不同的测试编排上下文依赖注入混乱。 * 特性(test): `fork` 支持自定义新上下文 `ServiceProvider` 和 `CommandAggregateFactory`。 * 特性(test): 添加 `functionFilter` 以支持单个 `Saga` 中的多个函数订阅同一事件。
最后提交信息为:
Update Version
v3.9.8
3aa6569
2024-07-10 09:00
对比
v3.9.8
Ahoo-Wang
## 更新内容 * 特性(query): `SortDsl` 支持嵌套语法 * 依赖(core): 更新 `me.ahoo.cosid:cosid-bom` 到 `v2.9.1` * 依赖(doc): 更新 `vitepress` 到 `v1.3.0` * 依赖(opentelemetry): 更新 `io.opentelemetry:opentelemetry-bom` 到 `v1.40.0 ` ### `QueryDsl` ```kotlin singleQuery { condition { deleted(false) nestedState() BinInventoryStateProperties.SKU_ID__ID eq request.skuId BinInventoryStateProperties.BIN__TYPE eq request.type BinInventoryStateProperties.QTY gt 0 } sort { nestedState() BinInventoryStateProperties.QTY.desc() } }.query(binInventoryQueryService).toState().map { it.bin }.throwNotFoundIfEmpty() ```
最后提交信息为:
fix(deps): update dependency me.ahoo.cosid:cosid-bom to v2.9.1 (#814)
v3.9.6
a366ba3
2024-07-02 22:11
对比
v3.9.6
Ahoo-Wang
## 更新内容 * 特性(openapi): 当 id 路由参数存在时,默认会附加 id 路径 * 特性(api): 添加 `CommandValidator` API以支持复杂的命令验证 * 特性(apiclient): 为 `SnapshotQueryApi` 添加便捷的查询扩展方法 * 特性(apiclient): 为 `RestCommandGateway` 添加命令验证以支持快速失败 * 特性(core): 添加 `AggregateIdempotencyCheckerProvider` API * 特性(test): 添加 `fork` 方法,增强测试编排能力 * 依赖(core): 更新 `me.ahoo.cosid:cosid-bom` 到 `v2.9.0` * 依赖(compensation): 更新 `me.ahoo.coapi:coapi-bom` 到 `v1.6.6` * 依赖(compiler): 更新 `dev.zacsweers.kctfork:ksp` 到 `v0.5.1` * 依赖(openapi): 更新 `springdoc ` 到 `v2.6.0` ```kotlin aggregateVerifier<Order, OrderState>(tenantId = tenantId) .inject(DefaultCreateOrderSpec(inventoryService, pricingService)) .whenCommand(CreateOrder(customerId, orderItems, SHIPPING_ADDRESS, false)) .expectEventType(OrderCreated::class.java) .expectStateAggregate { assertThat(it.aggregateId.tenantId, equalTo(tenantId)) } .expectState { assertThat(it.id, notNullValue()) assertThat(it.customerId, equalTo(customerId)) assertThat(it.address, equalTo(SHIPPING_ADDRESS)) assertThat(it.items, hasSize(1)) val item = it.items.first() assertThat(item.productId, equalTo(orderItem.productId)) assertThat(item.price, equalTo(orderItem.price)) assertThat(item.quantity, equalTo(orderItem.quantity)) assertThat(it.status, equalTo(OrderStatus.CREATED)) }.expect { assertThat(it.exchange.getCommandResult().size, equalTo(1)) val result = it.exchange.getCommandResult<BigDecimal>(OrderState::totalAmount.name) assertThat(result, equalTo(orderItem.price.multiply(BigDecimal.valueOf(orderItem.quantity.toLong())))) } .verify() .fork { changeAddress(it) }.fork { payOrder(it) } ```
最后提交信息为:
Update Version
v3.9.0
abfbafe
2024-06-24 09:14
对比
v3.9.0
Ahoo-Wang
## 更新内容 * 特性(test): 添加 `givenEvent` 、`whenCommand` 方法别名 * 依赖(spring): 更新 `org.springframework.boot:spring-boot-dependencies` 到 `v3.3.1` * 依赖(build): 更新 `docker/build-push-action` 到 `v6` * 依赖(opentelemetry): 更新 `io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom` 到 `v2.5.0` * 依赖(core): 更新 `me.ahoo.cosid:cosid-bom` 到 `v2.9.0` * 依赖(compensation): 更新 `me.ahoo.coapi:coapi-bom` 到 `v1.5.0` * 依赖(com): 更新 `me.ahoo.simba:simba-bom` 到 `v2.5.0` * 依赖(dashboard): 更新 `ng-zorro-antd` 到 `v18` * 依赖(dashboard): 更新 `monaco-editor` 到 `^0.50.0`
最后提交信息为:
fix(deps): update dependency monaco-editor to ^0.50.0 (#792)
v3.8.4
6bdbc8e
2024-06-17 09:47
对比
v3.8.4
Ahoo-Wang
## 更新内容 * 特性(models): 重构 `Tree` 命令聚合根模型 * 修复(openapi): 修复 `PagedList` 错误的 `Schema` 定义
最后提交信息为:
Update Version
下载
请输入验证码,防止盗链导致资源被占用
取消
下载