goka.WithStorageBuilder

`goka.WithStorageBuilder` 是一个函数选项，它可以在创建 Goka 处理器时使用，可以自定义 Goka 中使用的存储引擎。

默认情况下，Goka 使用 `storage.NewMemory` 存储引擎来存储状态。但是，您可以使用 `goka.WithStorageBuilder` 选项来为您的 Goka 处理器选择一个不同的存储引擎。下面是一个示例代码：

import (
    "context"
    "github.com/lovoo/goka"
    "github.com/lovoo/goka/storage"
)

func main() {
    // Create a custom storage builder function
    customStorageBuilder := func(topic string, partition int32) (storage.Storage, error) {
        // Use a different storage engine based on the partition number
        if partition%2 == 0 {
            // Use a file storage engine for even partitions
            return storage.NewFile(fmt.Sprintf("path/to/file/storage/%d", partition)), nil
        } else {
            // Use a memory storage engine for odd partitions
            return storage.NewMemory(), nil
        }
    }

    // Use the custom storage builder when creating the processor
    processor, err := goka.NewProcessor([]string{"your-topic"}, &yourHandler{}, goka.WithStorageBuilder(customStorageBuilder))
    if err != nil {
        // handle error
    }

    // Start the processor
    if err := processor.Run(context.Background()); err != nil {
        // handle error
    }
}

在上面的示例中，我们通过定义 `customStorageBuilder` 函数来自定义存储引擎。这个函数根据分区号选择了不同的存储引擎。我们然后将 `goka.WithStorageBuilder` 选项传递给 `goka.NewProcessor` 函数，以便在创建处理器时使用自定义的存储引擎。

请注意，您可以根据需要自定义存储引擎，例如使用 `storage.NewRedis` 或 `storage.NewLevelDB` 等外部存储引擎。