trxdb_loader

Documentation

Index

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

Types

type App

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

func New

func New(config *Config, modules *Modules) *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
	EnableTruncationMarker    bool   // Enables the storage of truncation markers
	TruncationWindow          uint64 // Truncate date within this duration
	PurgerInterval            uint64 // Purger at every X block
}

type Modules

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