Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetFirstStreamableBlock ¶
func SetFirstStreamableBlock(height uint64)
SetFirstStreamableBlock sets first block height available for streaming
Types ¶
type BlockReader ¶
type BlockReader struct {
// contains filtered or unexported fields
}
BlockReader reads the dbin format where each element is assumed to be a `bstream.Block`.
func NewBlockReader ¶
func NewBlockReader(reader io.Reader) (out *BlockReader, err error)
type BlockWriter ¶
type BlockWriter struct {
// contains filtered or unexported fields
}
func NewBlockWriter ¶
func NewBlockWriter(writer io.Writer) (*BlockWriter, error)
type ConsoleReader ¶
type ConsoleReader struct {
// contains filtered or unexported fields
}
func NewConsoleReader ¶
func NewConsoleReader(lines chan string, logger *zap.Logger) (*ConsoleReader, error)
func (*ConsoleReader) Close ¶
func (cr *ConsoleReader) Close()
func (*ConsoleReader) Done ¶
func (cr *ConsoleReader) Done() <-chan interface{}
type ParsedLine ¶
type ParsedLine struct {
Kind string
Data interface{}
}
Source Files
Click to show internal directories.
Click to hide internal directories.