app

Documentation

Index

• func InitChainCursor(ctx context.Context, entCl *ent.Client, chain netconf.Chain) (uint64, uint64, error)
• func InsertBlockTX(ctx context.Context, tx *ent.Tx, block xchain.Block) error
• func Run(ctx context.Context, cfg Config) error
• func WriteConfigTOML(cfg Config, logCfg log.Config, path string) error
• type Config
  • func DefaultConfig() Config

Functions

func InitChainCursor

func InitChainCursor(ctx context.Context, entCl *ent.Client, chain netconf.Chain) (uint64, uint64, error)

InitChainCursor return the initial cursor height to start streaming from (inclusive). If a cursor exists, it returns the cursor height + 1. Else a new cursor is created with chain deploy height.

func InsertBlockTX

func InsertBlockTX(ctx context.Context, tx *ent.Tx, block xchain.Block) error

InsertBlockTX inserts the block as part of a tx and commits it. The caller should handle rollback on any error.

func Run

func Run(ctx context.Context, cfg Config) error

func WriteConfigTOML

func WriteConfigTOML(cfg Config, logCfg log.Config, path string) error

WriteConfigTOML writes the toml indexer config to disk.

Types

type Config

type Config struct {
	RPCEndpoints   xchain.RPCEndpoints
	Network        netconf.ID
	ExplorerDBConn string
	MonitoringAddr string
}

func DefaultConfig

func DefaultConfig() Config