Documentation ¶
Index ¶
Constants ¶
View Source
const ( LogPrefix = "FIRE" LogBlockStart = "BLOCK_START" LogHeader = "BLOCK_HEADER" LogTrx = "BLOCK_TRX" LogRatification = "BLOCK_RATIFICATION" LogCoinbase = "BLOCK_COINBASE" LogBlockEnd = "BLOCK_END" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Start struct { Args []string `yaml:"args"` Flags struct { ReaderNodePath string `yaml:"reader-node-path"` ReaderNodeArguments string `yaml:"reader-node-arguments"` SubstreamsEnabled bool `yaml:"substreams-enabled"` SubstreamsClientEndpoint string `yaml:"substreams-client-endpoint"` SubstreamsClientPlaintext bool `yaml:"substreams-client-plaintext"` SubstreamsPartialModeEnabled bool `yaml:"substreams-partial-mode-enabled"` SubstreamsSubRequestBlockRangeSize int `yaml:"substreams-sub-request-block-range-size"` SubstreamsCacheSaveInterval int `yaml:"substreams-cache-save-interval"` SubstreamsSubRequestParallelJobs int `yaml:"substreams-sub-request-parallel-jobs"` } `yaml:"flags"` } `yaml:"start"` }
type ConsoleReader ¶
type ConsoleReader struct {
// contains filtered or unexported fields
}
ConsoleReader is what reads the `geth` output directly. It builds up some LogEntry objects. See `LogReader to read those entries .
func NewConsoleReader ¶
func NewConsoleReader(logger *zap.Logger, lines chan string) (*ConsoleReader, error)
func (*ConsoleReader) Close ¶
func (r *ConsoleReader) Close()
Click to show internal directories.
Click to hide internal directories.