codec

Documentation

Index

• Constants
• func Not[E any, T func(E) bool](original T) T
• func StringHasPrefix(prefix string) func(string) bool
• 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) ProcessData(reader io.Reader) error
  • func (r *ConsoleReader) ReadBlock() (out *bstream.Block, err error)

Constants

const (
	LogPrefix     = "FIRE"
	LogInit       = "INIT"
	LogBlockStart = "BLOCK_START"
	LogTrx        = "TRX"
	LogBlockEnd   = "BLOCK_END"
)

Functions

func Not

func Not[E any, T func(E) bool](original T) T

func StringHasPrefix

func StringHasPrefix(prefix string) func(string) bool

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 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{}

func (*ConsoleReader) ProcessData

func (r *ConsoleReader) ProcessData(reader io.Reader) error

func (*ConsoleReader) ReadBlock

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