outputmodules

Documentation

Index

• func ValidateRequest(request *pbsubstreams.Request, blockType string, isSubRequest bool) error
• type Graph
  • func NewOutputModuleGraph(request *pbsubstreams.Request) (out *Graph, err error)
  • func TestNew() *Graph
  • func (g *Graph) AllModules() []*pbsubstreams.Module
  • 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) ValidateRequestStartBlock(requestStartBlockNum uint64) error

Functions

func ValidateRequest

func ValidateRequest(request *pbsubstreams.Request, blockType string, isSubRequest bool) error

ValidateRequest is run by the server code.

Types

type Graph

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

func NewOutputModuleGraph

func NewOutputModuleGraph(request *pbsubstreams.Request) (out *Graph, err error)

func TestNew

func TestNew() *Graph

func (*Graph) AllModules

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

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

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