subgraph

Jun 3, 2022

Changes in this version

+ type Base struct

+ ID string

+ Log *zap.Logger

+ type BlockRef interface

+ ID func() string

+ Number func() uint64

+ Timestamp func() time.Time

+ type DDL interface

+ CreateIndexes func(handleStatement func(table string, statement string) error) error

+ CreateTables func(handleStatement func(table string, statement string) error) error

+ DropIndexes func(handleStatement func(table string, statement string) error) error

+ InitiateSchema func(handleStatement func(statement string) error) error

+ type Definition struct

+ Abis map[string]string

+ DDL DDL

+ Entities *graphnode.Registry

+ GraphQLSchema string

+ HighestParallelStep int

+ IncludeFilter string

+ Manifest string

+ MergeFunc func(step int, current, next graphnode.Entity) graphnode.Entity

+ New func(Base) Subgraph

+ PackageName string

+ StartBlock uint64

+ var MainSubgraphDef *Definition

+ type Intrinsics interface

+ Block func() BlockRef

+ Load func(entity graphnode.Entity) error

+ LoadAllDistinct func(model graphnode.Entity, blockNum uint64) ([]graphnode.Entity, error)

+ RPC func(calls []*RPCCall) ([]*RPCResponse, error)

+ Remove func(entity graphnode.Entity) error

+ Save func(entity graphnode.Entity) error

+ Step func() int

+ StepAbove func(step int) bool

+ StepBelow func(step int) bool

+ type RPCCall struct

+ MethodSignature string

+ ToAddr string

+ func (c *RPCCall) ToString() string

+ type RPCResponse struct

+ CallError error

+ Decoded []interface{}

+ DecodingError error

+ Raw string

+ type Subgraph interface

+ Init func() error

+ LoadDynamicDataSources func(blockNum uint64) error

+ LogStatus func()