codec

Documentation

Index

• Constants
• func BlockDecoder(blk *bstream.Block) (interface{}, error)
• func BlockFromProto(b *pbcodec.Block) (*bstream.Block, error)
• type ConsoleReader
  • func NewConsoleReader(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"
	LogBlock  = "BLOCK"
)

const CONFIRMS uint64 = 20

Functions

func BlockDecoder

func BlockDecoder(blk *bstream.Block) (interface{}, error)

func BlockFromProto

func BlockFromProto(b *pbcodec.Block) (*bstream.Block, 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 NewConsoleReader

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