outputmodules

Documentation

Index

• Variables
• func ValidateTier1Request(request *pbsubstreamsrpc.Request, blockType string) error
• func ValidateTier2Request(request *pbssinternal.ProcessRangeRequest, blockType string) error
• type ExecutionStages
  • func (e ExecutionStages) LastStage() StageLayers
• type Graph
  • func NewOutputModuleGraph(outputModule string, productionMode bool, modules *pbsubstreams.Modules) (out *Graph, err error)
  • func TestGraphStagedModules(initialBlock1, ib2, ib3, ib4, ib5 uint64) *Graph
  • func TestNew() *Graph
  • func (g *Graph) AncestorsFrom(moduleName string) []string
  • func (g *Graph) IsOutputModule(name string) bool
  • func (g *Graph) LowestInitBlock() uint64
  • func (g *Graph) ModuleHashes() *manifest.ModuleHashes
  • func (g *Graph) OutputModule() *pbsubstreams.Module
  • func (g *Graph) SchedulableModuleNames() []string
  • func (g *Graph) StagedUsedModules() ExecutionStages
  • func (g *Graph) Stores() []*pbsubstreams.Module
  • func (g *Graph) UsedModules() []*pbsubstreams.Module
  • func (g *Graph) ValidateRequestStartBlock(requestStartBlockNum uint64) error
• type LayerModules
  • func (l LayerModules) IsStoreLayer() bool
• type StageLayers
  • func (l StageLayers) LastLayer() LayerModules

Variables

var ValidateRequest = ValidateTier1Request

Deprecated: use ValidateTier1Request

Functions

func ValidateTier1Request

func ValidateTier1Request(request *pbsubstreamsrpc.Request, blockType string) error

ValidateTier1Request is run by the server code.

func ValidateTier2Request

func ValidateTier2Request(request *pbssinternal.ProcessRangeRequest, blockType string) error

Types

type ExecutionStages

type ExecutionStages []StageLayers

A list of units that we can schedule, that might include some mappers and a store, or the last module could be an exeuction layer with only a map.

func (ExecutionStages) LastStage

func (e ExecutionStages) LastStage() StageLayers

type Graph

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

func NewOutputModuleGraph

func NewOutputModuleGraph(outputModule string, productionMode bool, modules *pbsubstreams.Modules) (out *Graph, err error)

func TestGraphStagedModules

func TestGraphStagedModules(initialBlock1, ib2, ib3, ib4, ib5 uint64) *Graph

func TestNew

func TestNew() *Graph

func (*Graph) AncestorsFrom

func (g *Graph) AncestorsFrom(moduleName string) []string

func (*Graph) IsOutputModule

func (g *Graph) IsOutputModule(name string) bool

func (*Graph) LowestInitBlock

func (g *Graph) LowestInitBlock() uint64

func (*Graph) ModuleHashes

func (g *Graph) ModuleHashes() *manifest.ModuleHashes

func (*Graph) OutputModule

func (g *Graph) OutputModule() *pbsubstreams.Module

func (*Graph) SchedulableModuleNames

func (g *Graph) SchedulableModuleNames() []string

func (*Graph) StagedUsedModules

func (g *Graph) StagedUsedModules() ExecutionStages

func (*Graph) Stores

func (g *Graph) Stores() []*pbsubstreams.Module

func (*Graph) UsedModules

func (g *Graph) UsedModules() []*pbsubstreams.Module

func (*Graph) ValidateRequestStartBlock

func (g *Graph) ValidateRequestStartBlock(requestStartBlockNum uint64) error

type LayerModules

type LayerModules []*pbsubstreams.Module

The list of modules in a given layer of either maps or stores. A given layer will always be comprised of only the same kind of modules.

func (LayerModules) IsStoreLayer

func (l LayerModules) IsStoreLayer() bool

type StageLayers

type StageLayers []LayerModules

For a given execution stage, the layers of execution, for example: a layer of mappers, followed by a layer of stores.

func (StageLayers) LastLayer

func (l StageLayers) LastLayer() LayerModules