Documentation ¶
Index ¶
- Variables
- func ValidateTier1Request(request *pbsubstreamsrpc.Request, blockType string) error
- func ValidateTier2Request(request *pbssinternal.ProcessRangeRequest) error
- type ExecutionStages
- type 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) UsedModulesUpToStage(stage int) (out []*pbsubstreams.Module)
- func (g *Graph) ValidateRequestStartBlock(requestStartBlockNum uint64) error
- type LayerModules
- type StageLayers
Constants ¶
This section is empty.
Variables ¶
View Source
var ValidateRequest = ValidateTier1Request
Deprecated: use ValidateTier1Request
Functions ¶
func ValidateTier1Request ¶ added in v1.1.1
func ValidateTier1Request(request *pbsubstreamsrpc.Request, blockType string) error
ValidateTier1Request is run by the server code.
func ValidateTier2Request ¶ added in v1.1.1
func ValidateTier2Request(request *pbssinternal.ProcessRangeRequest) error
Types ¶
type ExecutionStages ¶ added in v1.1.9
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 ¶ added in v1.1.9
func (e ExecutionStages) LastStage() StageLayers
type Graph ¶
type Graph struct {
// contains filtered or unexported fields
}
func NewOutputModuleGraph ¶
func TestGraphStagedModules ¶ added in v1.1.9
func (*Graph) AncestorsFrom ¶
func (*Graph) IsOutputModule ¶
func (*Graph) LowestInitBlock ¶ added in v1.1.9
func (*Graph) ModuleHashes ¶
func (g *Graph) ModuleHashes() *manifest.ModuleHashes
func (*Graph) OutputModule ¶
func (g *Graph) OutputModule() *pbsubstreams.Module
func (*Graph) SchedulableModuleNames ¶
func (*Graph) StagedUsedModules ¶ added in v1.1.5
func (g *Graph) StagedUsedModules() ExecutionStages
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) UsedModulesUpToStage ¶ added in v1.4.0
func (g *Graph) UsedModulesUpToStage(stage int) (out []*pbsubstreams.Module)
func (*Graph) ValidateRequestStartBlock ¶
type LayerModules ¶ added in v1.1.9
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 ¶ added in v1.1.9
func (l LayerModules) IsStoreLayer() bool
type StageLayers ¶ added in v1.1.9
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) IsLastStage ¶ added in v1.4.0
func (l StageLayers) IsLastStage() bool
func (StageLayers) LastLayer ¶ added in v1.1.9
func (l StageLayers) LastLayer() LayerModules
Click to show internal directories.
Click to hide internal directories.