codec

Documentation

Index

• Constants
• func SplitInChunks(line string, count int) ([]string, error)
• type ConsoleReader
  • func NewConsoleReader(lines chan string, blockEncoder firecore.BlockEncoder, rpcUrl 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)
• type RPCBlockMetaGetter
  • func NewRPCBlockMetaGetter(endpointURL string) *RPCBlockMetaGetter

Constants

const FirePrefixLen = len("FIRE ")

Functions

func SplitInChunks

func SplitInChunks(line string, count int) ([]string, 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, blockEncoder firecore.BlockEncoder, rpcUrl 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)

type RPCBlockMetaGetter

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

func NewRPCBlockMetaGetter

func NewRPCBlockMetaGetter(endpointURL string) *RPCBlockMetaGetter