manifest

May 21, 2024

Changes in this version

+ const UpdatePolicySetSum

May 13, 2024

Changes in this version

+ type BufImport struct

+ Module string

+ Symbols []string

+ Version string

May 9, 2024

Changes in this version

+ var UseSimpleHash = false

+ type BlockFilterQuery struct

+ Params bool

+ String string

May 3, 2024

Changes in this version

type Protobuf

+ DescriptorSets []string

Mar 22, 2024

Changes in this version

+ const ModuleKindBlockIndex

+ type BlockFilter struct

+ Module string

+ Query string

type Manifest

+ BlockFilters map[string]string

type Module

+ BlockFilter *BlockFilter

+ Use string

Dec 22, 2023

Changes in this version

+ func ApplyNetwork(network string, pkg *pbsubstreams.Package) error

+ func ParseParams(paramsString []string) (map[string]string, error)

type Manifest

+ Networks map[string]*NetworkParams

+ type NetworkParams struct

+ InitialBlocks map[string]uint64

+ Params map[string]string

type Option

+ func WithOverrideNetwork(network string) Option

+ func WithOverrideOutputModule(outputModule string) Option

+ func WithParams(params map[string]string) Option

Oct 27, 2023

Changes in this version

type ModuleGraph

+ func (g *ModuleGraph) HasStatefulDependencies(moduleName string) (bool, error)

Oct 16, 2023

Changes in this version

+ var JPGHeader = []byte

+ var PNGHeader = []byte

+ var WebPHeader = []byte

type PackageMeta

+ Image string

Oct 5, 2023

Changes in this version

+ var HardcodedEndpoints = map[string]string

+ func DescribeSinkConfigs(pkg *pbssv1.Package) (desc string, files map[string][]byte, err error)

+ func ExtractNetworkEndpoint(networkFromManifest, fromFlag string, logger *zap.Logger) (string, error)

type ConfigurationOverride

+ DeriveFrom string

type PackageOverride

+ Version *string

Aug 30, 2023

Changes in this version

+ func IsLikelyManifestInput(in string) bool

+ type ConfigurationOverride struct

+ InitialBlocks map[string]int64

+ Network string

+ Package *PackageOverride

+ Params map[string]string

+ SinkConfig *SinkConfigOverride

+ SinkModule string

+ type ManifestOverrideConfiguration struct

+ InitialBlocks map[string]uint64

+ Network string

+ Package PackageMetaOverride

+ Params map[string]string

+ Workdir string

+ func (o *ManifestOverrideConfiguration) Apply(m *Manifest) error

+ type Option func(r *Reader) *Reader

+ func WithOverrides(overrides ...*ConfigurationOverride) Option

+ type PackageMetaOverride struct

+ Name string

+ type PackageOverride struct

+ Name string

+ type SinkConfigOverride struct

+ TypeUrl string

+ Value string

Jul 6, 2023

Changes in this version

type Options

+ func SkipPackageValidationReader() Options

Jun 2, 2023

Changes in this version

+ var IPFSTimeout time.Duration

+ var IPFSURL string

May 18, 2023

Changes in this version

type Reader

+ func MustNewReader(input string, opts ...Options) *Reader

+ func (r *Reader) ResolvedInput() string

May 5, 2023

Changes in this version

+ func ApplyParams(paramsString []string, pkg *pbsubstreams.Package) error

+ func NewSimpleTestModules() []*pbsubstreams.Module

type ModuleGraph

+ func MustNewModuleGraph(modules []*pbsubstreams.Module) *ModuleGraph

+ func (g *ModuleGraph) ModuleIndexFromName(name string) (int, bool)

+ func (g *ModuleGraph) ModuleNameFromIndex(index int) string

+ func (g *ModuleGraph) Modules() []string

+ func (g *ModuleGraph) TopologicalSortKnownModules(known map[string]bool) ([]*pbsubstreams.Module, bool)

type Reader

+ func (r *Reader) MustRead() *pbsubstreams.Package

Apr 13, 2023

retracted

Changes in this version

+ func BuildMessageDescriptors(pkg *pbsubstreams.Package) (out map[string]*ModuleDescriptor, err error)

+ type ModuleDescriptor struct

+ MapOutputType string

+ MessageDescriptor *desc.MessageDescriptor

+ ProtoMessageType string

+ StoreValueType string

type ModuleGraph

+ func (g *ModuleGraph) ChildrenOf(moduleName string) ([]*pbsubstreams.Module, error)

+ func (g *ModuleGraph) Context(moduleName string) (parents []string, children []string)

+ func (g *ModuleGraph) MustChildrenOf(moduleName string) []*pbsubstreams.Module

+ func (g *ModuleGraph) MustParentsOf(moduleName string) []*pbsubstreams.Module

Apr 6, 2023

Changes in this version

+ func GenerateMermaidLiveURL(mods *pbsubstreams.Modules) string

Mar 7, 2023

Changes in this version

type Input

+ Params string

+ func (i *Input) IsParams() bool

type Manifest

+ Network string

+ Params map[string]string

+ Sink *Sink

+ type Sink struct

+ Config interface{}

+ Module string

+ Type string

Jan 6, 2023

Changes in this version

+ func SortModuleNamesByGraphTopology(mods []string, g *ModuleGraph) []string

+ func TestReadManifest(t testing.T, manifestPath string) *pbsubstreams.Package

type Binary

+ ProtoPackageMapping map[string]string

type Input

+ func (i *Input) IsMap() bool

+ func (i *Input) IsSource() bool

+ func (i *Input) IsStore() bool

type Manifest

+ func LoadManifestFile(inputPath string) (*Manifest, error)

type Options

+ func SkipModuleOutputTypeValidationReader() Options

Oct 31, 2022

Changes in this version

+ const OutputValueTypeBigDecimal

+ const OutputValueTypeBigFloat

+ const OutputValueTypeBigInt

+ const OutputValueTypeFloat64

+ const OutputValueTypeInt64

+ const OutputValueTypeString

type ModuleGraph

+ func (graph *ModuleGraph) ResetGraphHashes()

+ type ModuleHashes struct

+ func NewModuleHashes() *ModuleHashes

+ func (m *ModuleHashes) Get(moduleName string) string

+ func (m *ModuleHashes) HashModule(modules *pbsubstreams.Modules, module *pbsubstreams.Module, graph *ModuleGraph) ModuleHash

+ func (m *ModuleHashes) Iter(cb func(hash, name string) error) error

type Options

+ func WithCollectProtoDefinitions(f func(protoDefinitions []*desc.FileDescriptor)) Options

type Reader

+ func (r *Reader) IsLocalManifest() bool

+ func (r *Reader) IsRemotePackage() bool

Jul 29, 2022

Changes in this version

+ const UpdatePolicyAppend

type ModuleGraph

+ func (g *ModuleGraph) Module(moduleName string) (*pbsubstreams.Module, error)

Jun 3, 2022

Changes in this version

+ const ModuleKindMap

+ const ModuleKindStore

+ const PrefixSeparator

+ const UNSET

+ const UpdatePolicyAdd

+ const UpdatePolicyMax

+ const UpdatePolicyMin

+ const UpdatePolicySet

+ const UpdatePolicySetIfNotExists

+ func HashModuleAsString(modules *pbsubstreams.Modules, graph *ModuleGraph, module *pbsubstreams.Module) string

+ func NewTestModules() []*pbsubstreams.Module

+ func PrintMermaid(mods *pbsubstreams.Modules)

+ func ValidateModules(mods *pbsubstreams.Modules) error

+ type Binary struct

+ Content []byte

+ Entrypoint string

+ File string

+ Native string

+ Type string

+ type Input struct

+ Map string

+ Mode string

+ Name string

+ Source string

+ Store string

+ type Manifest struct

+ Binaries map[string]Binary

+ Graph *ModuleGraph

+ Imports mapSlice

+ Modules []*Module

+ Package PackageMeta

+ Protobuf Protobuf

+ SpecVersion string

+ Workdir string

+ type Module struct

+ Binary string

+ Doc string

+ InitialBlock *uint64

+ Inputs []*Input

+ Kind string

+ Name string

+ Output StreamOutput

+ UpdatePolicy string

+ ValueType string

+ func (m *Module) String() string

+ func (m *Module) ToProtoWASM(codeIndex uint32) (*pbsubstreams.Module, error)

+ type ModuleGraph struct

+ func NewModuleGraph(modules []*pbsubstreams.Module) (*ModuleGraph, error)

+ func (g *ModuleGraph) AncestorStoresOf(moduleName string) ([]*pbsubstreams.Module, error)

+ func (g *ModuleGraph) AncestorsOf(moduleName string) ([]*pbsubstreams.Module, error)

+ func (g *ModuleGraph) GetSources() []string

+ func (g *ModuleGraph) GroupedAncestorStores(moduleName string) ([][]*pbsubstreams.Module, error)

+ func (g *ModuleGraph) ModuleInitialBlock(moduleName string) (uint64, error)

+ func (g *ModuleGraph) ModulesDownTo(moduleNames []string) ([]*pbsubstreams.Module, error)

+ func (g *ModuleGraph) ParentStoresOf(moduleName string) ([]*pbsubstreams.Modules, error)

+ func (g *ModuleGraph) ParentsOf(moduleName string) ([]*pbsubstreams.Module, error)

+ func (g *ModuleGraph) StoresDownTo(moduleNames []string) ([]*pbsubstreams.Module, error)

+ func (g *ModuleGraph) TopologicalSort() ([]*pbsubstreams.Module, bool)

+ type ModuleHash []byte

+ func HashModule(modules *pbsubstreams.Modules, module *pbsubstreams.Module, graph *ModuleGraph) ModuleHash

+ type ModuleMarshaler []*pbsubstreams.Module

+ func (m ModuleMarshaler) MarshalJSON() ([]byte, error)

+ type Options func(r *Reader) *Reader

+ func SkipSourceCodeReader() Options

+ type PackageMeta struct

+ Doc string

+ Name string

+ URL string

+ Version string

+ type Protobuf struct

+ Files []string

+ ImportPaths []string

+ type Reader struct

+ func NewReader(input string, opts ...Options) *Reader

+ func (r *Reader) Read() (*pbsubstreams.Package, error)

+ type StreamOutput struct

+ Type string