cache

package

v1.18.5 Latest Latest Go to latest Published: May 11, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/streamingfast/substreams

Links

Documentation ¶

Index ¶

type Engine
- func NewEngine(ctx context.Context, execOutWriters map[string]*execout.Writer, ...) (*Engine, error)
type ModuleCache
- func NewModuleCache(ctx context.Context, evictionInterval time.Duration, ttl time.Duration, ...) *ModuleCache
- func (c *ModuleCache) Get(hash string) (wasm.Module, bool)
- func (c *ModuleCache) Set(hash string, module wasm.Module)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Engine ¶

type Engine struct {
	// contains filtered or unexported fields
}

Engine manages the reversible segments and keeps track of the execution output between each module's.

Upon Finality, it writes it to some output cache files.

func NewEngine ¶

func NewEngine(ctx context.Context, execOutWriters map[string]*execout.Writer, blockType string, existingExecOuts map[string]execout.FileReader, indexWriters map[string]*index.Writer) (*Engine, error)

func (*Engine) EndOfStream ¶

func (e *Engine) EndOfStream(lastFinalClock *pbsubstreams.Clock) error

func (*Engine) HandleFinal ¶

func (e *Engine) HandleFinal(clock *pbsubstreams.Clock) error

func (*Engine) HandleStalled ¶

func (e *Engine) HandleStalled(clock *pbsubstreams.Clock) error

func (*Engine) HandleUndo ¶

func (e *Engine) HandleUndo(clock *pbsubstreams.Clock)

func (*Engine) NewBuffer ¶

func (e *Engine) NewBuffer(optionalBlock *pbbstream.Block, clock *pbsubstreams.Clock, cursor *bstream.Cursor) (execout.ExecutionOutput, error)

type ModuleCache ¶ added in v1.18.5

type ModuleCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewModuleCache ¶ added in v1.18.5

func NewModuleCache(ctx context.Context, evictionInterval time.Duration, ttl time.Duration, logger *zap.Logger) *ModuleCache

func (*ModuleCache) Get ¶ added in v1.18.5

func (c *ModuleCache) Get(hash string) (wasm.Module, bool)

func (*ModuleCache) Set ¶ added in v1.18.5

func (c *ModuleCache) Set(hash string, module wasm.Module)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL