codec

Documentation

Index

• Constants
• 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     = "DMLOG"
	LogBeginBlock = "BLOCK_BEGIN"
	LogBeginTrx   = "BEGIN_TRX"
	LogBeginEvent = "TRX_BEGIN_EVENT"
	LogEventAttr  = "TRX_EVENT_ATTR"
	LogEndTrx     = "END_TRX"
	LogEndBlock   = "BLOCK_END"
)

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

todo: WTF?

func (*ConsoleReader) ProcessData

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

func (*ConsoleReader) ReadBlock

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