Documentation
¶
Index ¶
- func ValidateInternalRequest(request *pbssinternal.ProcessRangeRequest, blockType string) error
- func ValidateRequest(request *pbsubstreamsrpc.Request, blockType string) error
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateInternalRequest ¶ added in v1.0.2
func ValidateInternalRequest(request *pbssinternal.ProcessRangeRequest, blockType string) error
func ValidateRequest ¶
func ValidateRequest(request *pbsubstreamsrpc.Request, blockType string) error
ValidateRequest is run by the server code.
Types ¶
type Graph ¶
type Graph struct {
// contains filtered or unexported fields
}
func NewOutputModuleGraph ¶
func (*Graph) AncestorsFrom ¶
func (*Graph) IsOutputModule ¶
func (*Graph) ModuleHashes ¶
func (g *Graph) ModuleHashes() *manifest.ModuleHashes
func (*Graph) OutputModule ¶
func (g *Graph) OutputModule() *pbsubstreams.Module
func (*Graph) SchedulableModuleNames ¶
func (*Graph) Stores ¶
func (g *Graph) Stores() []*pbsubstreams.Module
func (*Graph) UsedModules ¶ added in v1.0.2
func (g *Graph) UsedModules() []*pbsubstreams.Module
func (*Graph) ValidateRequestStartBlock ¶
Click to show internal directories.
Click to hide internal directories.