console_reader

Documentation

Index

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

Constants

const BlockLogPrefix = "BLOCK "

const BlockLogPrefixLen = len(BlockLogPrefix)

const FirePrefix = "FIRE "

const FirePrefixLen = len(FirePrefix)

const InitLogPrefix = "INIT "

const InitLogPrefixLen = len(InitLogPrefix)

Variables

var ConsoleReaderBlockReadCount = metrics.NewCounter("firecore_console_reader_block_read_count", "Number of blocks read by the console reader")

Functions

func NewConsoleReader

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

func RegisterMetrics

func RegisterMetrics()

Types

type ConsoleReader

type ConsoleReader struct {
	// contains filtered or unexported fields
}

func (*ConsoleReader) Close

func (r *ConsoleReader) Close() error

func (*ConsoleReader) Done

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

func (*ConsoleReader) ReadBlock

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

type ParsingStats

type ParsingStats struct {
}