tokenmeta

Documentation

Index

• Variables
• type App
  • func New(config *Config, modules *Modules) *App
  • func (a *App) Run() error
• type Config
• type Modules

Variables

var TokenmetaAppGeneratCacheFromAbiAborted = fmt.Errorf("getting abi cache file aborted by tokenmeta application")

Types

type App

type App struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func New

func New(config *Config, modules *Modules) *App

func (*App) Run

func (a *App) Run() error

type Config

type Config struct {
	GRPCListenAddr       string        // Address to listen for incoming gRPC requests
	StateDBGRPCAddr      string        // StateDB gRPC URL
	BlockStreamAddr      string        // gRPC URL to reach a stream of blocks
	ABICodecAddr         string        // Abi Codec URL
	ABICacheBaseURL      string        // cached ABIS base URL
	ABICacheFileName     string        // cached ABIS filename
	CacheFile            string        // Path to GOB file containing tokenmeta cache. will try to Load and Save to that cache file
	SaveEveryNBlock      uint32        // Save the cache after N blocks processed
	BlocksStoreURL       string        // GS path to read blocks archives
	BootstrapBlockOffset uint64        // Block offset to ensure that we are not bootstrapping from StateDB on a reversible fork
	ReadinessMaxLatency  time.Duration // we advertise as not-ready if the last processed block is older than this
}

type Modules

type Modules struct {
	BlockFilter func(blk *bstream.Block) error
	BlockMeta   pbblockmeta.BlockIDClient
}