最新 最热

Golang框架实战-KisFlow流式计算框架(12)-基于反射自适应注册FaaS形参类型

接下来我们来增强KisFlow中Function对业务数据处理的聚焦,将之前Function的写法:

2024-07-23
1

Golang框架实战-KisFlow流式计算框架(10)-Flow多副本

KisFlow如果在执行流体中,需要被多个Goroutine来并发使用,可能需要同一个配置的创建多个Flow来匹配多个并发的计算流,所以Flow需要一个创建副本的能力。本章将实现这部分的能力。...

2024-07-19
2

Golang框架实战-KisFlow流式计算框架(9)-Cache/Params 数据缓存与数据参数

KisFlow也提供流式计算中的共享缓存,采用简单的本地缓存供开发者按需使用,有关本地缓存的第三方技术依赖选型: https://github.com/patrickmn/go-cache

2024-07-18
2

Golang框架实战-KisFlow流式计算框架(8)-KisFlow Action

KisFlow Action 是指在执行Function的时候,同时可以控制Flow的调度逻辑,KisFlow提供一些Action动作让开发者做选择,本节先介绍最简单的Action动作,Abort(终止当前Flow)。...

2024-07-18
2

Golang框架实战-KisFlow流式计算框架(7)-配置导入与导出

现在每次建立Flow和Function等,都需要一系列繁琐的添加,不是很方便,接下来,我们可以通过批量读写配置文件,构建KisFlow中的结构关系,并且也可以将KisFlow的结构导出到本地文件中。目前我们先用文件的形式做配置的持久化,开发...

2024-06-27
2

Golang框架实战-KisFlow流式计算框架(4)-数据流

KisFlow中可以传递任意类型数据作为Flow的数据源。而且KisFlow支持批量数据的流逝计算处理。

2024-04-23
2