goka.Persist 作用

`goka.Persist` 是 Goka 框架的一个函数，用于指定流处理应用程序中的消息处理逻辑。具体来说，`goka.Persist` 函数需要传入一个 `goka.ProcessCallback` 类型的参数，用于指定消息的处理逻辑。

在 Goka 的流处理应用程序中，消息处理逻辑通常会涉及到对输入消息的处理、状态的更新以及输出消息的发送等操作。`goka.Persist` 函数可以帮助应用程序开发者在处理消息时方便地完成这些操作，从而简化应用程序的实现。

举个例子，如果你的 Goka 应用程序需要从一个名为 `input` 的流中读取消息，并将其转换为大写形式后发送到一个名为 `output` 的流中，你可以使用如下代码指定消息处理逻辑：

func handler(ctx goka.Context, msg interface{}) {
    // 对输入消息进行处理
    upperMsg := strings.ToUpper(msg.(string))
    
    // 更新状态
    ctx.SetValue(upperMsg)
    
    // 发送输出消息
    ctx.Emit("output", ctx.Key(), upperMsg)
}

// ...

goka.DefineGroup(
    "my-group",
    goka.Input("input", new(codec.String), partitioner),
    goka.Persist(new(codec.String), handler),
    goka.Output("output", new(codec.String)),
)

在上面的代码中，`handler` 函数指定了消息的处理逻辑，它将输入消息转换为大写形式后，使用 `ctx.SetValue` 方法更新状态，并使用 `ctx.Emit` 方法将处理结果发送到指定的输出流中。`goka.Persist` 函数会在每次接收到新的消息时调用 `handler` 函数，从而完成对输入消息的处理。