outputmodules

Documentation

Index

• Variables
• func ValidateTier1Request(request *pbsubstreamsrpc.Request, blockType string) error
• func ValidateTier2Request(request *pbssinternal.ProcessRangeRequest, blockType string) error
• type Graph
  • func NewOutputModuleGraph(outputModule string, productionMode bool, modules *pbsubstreams.Modules) (out *Graph, err error)
  • func TestNew() *Graph
  • func (g *Graph) AncestorsFrom(moduleName string) []string
  • func (g *Graph) IsOutputModule(name string) bool
  • func (g *Graph) ModuleHashes() *manifest.ModuleHashes
  • func (g *Graph) OutputModule() *pbsubstreams.Module
  • func (g *Graph) SchedulableModuleNames() []string
  • func (g *Graph) Stores() []*pbsubstreams.Module
  • func (g *Graph) UsedModules() []*pbsubstreams.Module
  • func (g *Graph) ValidateRequestStartBlock(requestStartBlockNum uint64) error

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 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 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) 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) 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