substreams-sink-kv

此包是一个将 Substream 输出格式化到 kv 存储的简单包装。

在您的 substreams 中创建一个 kv_out 模块

// lib.rs

use substreams_sink_kv::pb::kv::KvOperations;

...

pub fn kv_out(
    ... some stores ...
) -> Result<KvOperations, Error> {

    let mut kv_ops: KvOperations = Default::default();

    // process your data, push to your KV
    kv_ops.push_new(someKey, someValue, ordinal);
    kv_ops.push_delete(anotherKey, anotherOrdinal);

    Ok(kv_ops)
}

lib.rs:

用于编写 Substream Sink Wasm 查询处理器的库。