trxdb_loader

Documentation

Index

• type App
  • func New(config *Config) *App
  • func (a *App) IsReady() bool
  • func (a *App) Run() error
• type Config

Types

type App

type App struct {
	*shutter.Shutter
	Config *Config
}

func New

func New(config *Config) *App

func (*App) IsReady

func (a *App) IsReady() bool

func (*App) Run

func (a *App) Run() error

type Config

type Config struct {
	ChainId                   string // Chain ID
	ProcessingType            string // The actual processing type to perform, either `live`, `batch` or `patch`
	BlockStoreURL             string // GS path to read batch files from
	BlockStreamAddr           string // [LIVE] Address of grpc endpoint
	KvdbDsn                   string // Storage connection string
	BatchSize                 uint64 // DB batch size
	StartBlockNum             uint64 // [BATCH] Block number where we start processing
	StopBlockNum              uint64 // [BATCH] Block number where we stop processing
	NumBlocksBeforeStart      uint64 // [BATCH] Number of blocks to fetch before start block
	ParallelFileDownloadCount int    // Number of threads of parallel file download
	AllowLiveOnEmptyTable     bool   // [LIVE] force pipeline creation if live request and table is empty
	HTTPListenAddr            string //  http listen address for /healthz endpoint
}