codec

Documentation

Index

• Constants
• func NewConsoleReader(lines chan string, blockEncoder firecore.BlockEncoder, logger *zap.Logger, ...) (mindreader.ConsolerReader, error)
• type ConsoleReader
  • func (r *ConsoleReader) Close()
  • func (r *ConsoleReader) Done() <-chan interface{}
  • func (r *ConsoleReader) ReadBlock() (out *pbbstream.Block, err error)

Constants

const (
	LogPrefix        = "FIRE"
	LogInit          = "INIT"
	LogCheckpoint    = "CHECKPOINT"
	LogBlockStart    = "BLOCK_START"
	LogTrx           = "TRX"
	LogObjChange     = "OBJ_CHANGE"
	LogEvent         = "EVT"
	LogDisplayUpdate = "DSP_UPDATE"
	LogBlockEnd      = "BLOCK_END"
)

Functions

func NewConsoleReader

func NewConsoleReader(
	lines chan string,
	blockEncoder firecore.BlockEncoder,
	logger *zap.Logger,
	tracer logging.Tracer,
) (mindreader.ConsolerReader, error)

Types

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 (*ConsoleReader) Close

func (r *ConsoleReader) Close()

func (*ConsoleReader) Done

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

func (*ConsoleReader) ReadBlock

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