Versions in this module Expand all Collapse all v0 v0.7.1 Dec 8, 2023 v0.7.0 Nov 3, 2023 Changes in this version + func FromProto(b interface{}) (*bstream.Block, error) + func SetFirstStreamableBlock(height uint64) + func Validate() error + type BlockReader struct + func NewBlockReader(reader io.Reader) (out *BlockReader, err error) + func (l *BlockReader) Read() (*bstream.Block, error) + type BlockWriter struct + func NewBlockWriter(writer io.Writer) (*BlockWriter, error) + func (w *BlockWriter) Write(block *bstream.Block) error + type ConsoleReader struct + func NewConsoleReader(lines chan string, logger *zap.Logger) (*ConsoleReader, error) + func (cr *ConsoleReader) Close() + func (cr *ConsoleReader) Done() <-chan interface{} + func (cr *ConsoleReader) ReadBlock() (out *bstream.Block, err error) + type ParsedLine struct + Data interface{} + Kind string
Go to main page