codec

Documentation

Index

• Constants
• type Config
• type ConsoleReader
  • func NewConsoleReader(logger *zap.Logger, lines chan string) (*ConsoleReader, error)
  • func (r *ConsoleReader) Close()
  • func (r *ConsoleReader) Done() <-chan interface{}
  • func (r *ConsoleReader) ReadBlock() (out *bstream.Block, err error)

Constants

const (
	LogPrefix       = "FIRE"
	LogBlockStart   = "BLOCK_START"
	LogHeader       = "BLOCK_HEADER"
	LogTrx          = "BLOCK_TRX"
	LogRatification = "BLOCK_RATIFICATION"
	LogCoinbase     = "BLOCK_COINBASE"
	LogBlockEnd     = "BLOCK_END"
)

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()

func (*ConsoleReader) Done

func (r *ConsoleReader) Done() <-chan interface{}

todo: WTF?

func (*ConsoleReader) ReadBlock

func (r *ConsoleReader) ReadBlock() (out *bstream.Block, err error)