Versions in this module Expand all Collapse all v0 v0.0.21 Oct 31, 2022 Changes in this version + func ComputeDBinFilename(startBlock, stopBlock uint64) string + func ComputeStartBlock(startBlock uint64, saveBlockInterval uint64) uint64 + func NewEngine(runtimeConfig config.RuntimeConfig, logger *zap.Logger) (execout.CacheEngine, error) + type CacheItem struct + BlockID string + BlockNum uint64 + Cursor string + Payload []byte + Timestamp *timestamppb.Timestamp + type Engine struct + func (e *Engine) Close() error + func (e *Engine) EndOfStream(blockNum uint64) error + func (e *Engine) HandleFinal(clock *pbsubstreams.Clock) error + func (e *Engine) HandleUndo(clock *pbsubstreams.Clock, moduleName string) + func (e *Engine) Init(modules *manifest.ModuleHashes) error + func (e *Engine) NewExecOutput(blockType string, block *bstream.Block, clock *pbsubstreams.Clock, ...) (execout.ExecutionOutput, error) + type ExecOutputCache struct + func (e *ExecOutputCache) Get(moduleName string) (value []byte, cached bool, err error) + func (e *ExecOutputCache) Set(moduleName string, value []byte) (err error) + type OutputCache struct + func NewOutputCache(moduleName string, store dstore.Store, saveBlockInterval uint64, ...) *OutputCache + func (c *OutputCache) Delete(blockID string) + func (c *OutputCache) Get(clock *pbsubstreams.Clock) ([]byte, bool) + func (c *OutputCache) GetAtBlock(blockNumber uint64) ([]byte, bool) + func (c *OutputCache) ListCacheRanges(ctx context.Context) (block.Ranges, error) + func (c *OutputCache) ListContinuousCacheRanges(ctx context.Context, from uint64) (block.Ranges, error) + func (c *OutputCache) Load(ctx context.Context, blockRange *block.Range) error + func (c *OutputCache) LoadAtBlock(ctx context.Context, atBlock uint64) (found bool, err error) + func (c *OutputCache) MarshalLogObject(enc zapcore.ObjectEncoder) error + func (c *OutputCache) Set(clock *pbsubstreams.Clock, cursor string, data []byte) error + func (c *OutputCache) SortedCacheItems() (out []*CacheItem) + func (c *OutputCache) String() string
Go to main page