Versions in this module Expand all Collapse all v0 v0.0.1 Jun 22, 2020 Changes in this version + func RunGRPCServer(s *grpc.Server, listenAddr string) error + type Archiver interface + type BlockFileNamer func(block *bstream.Block) string + type BlockMarshaller func(block *bstream.Block) ([]byte, error) + type BlockNumberGator struct + func NewBlockNumberGator(blockNum uint64) *BlockNumberGator + type ConsoleReaderBlockTransformer func(obj interface{}) (*bstream.Block, error) + type ConsolerReader interface + Done func() <-chan interface{} + Read func() (obj interface{}, err error) + type ConsolerReaderFactory func(reader io.Reader) (ConsolerReader, error) + type ContinuityChecker interface + IsLocked func() bool + Reset func() + Write func(lastSeenBlockNum uint64) error + type Gator interface + type MergeArchiver struct + func NewMergeArchiver(store dstore.Store, blockWriterFactory bstream.BlockWriterFactory, ...) *MergeArchiver + type MergeArchiverOption func(*MergeArchiver) + func WithOverflowArchiver(archiver Archiver) MergeArchiverOption + type MindReaderPlugin struct + ContinuityChecker ContinuityChecker + func NewMindReaderPlugin(archiver Archiver, blockServer *blockstream.Server, ...) (*MindReaderPlugin, error) + func RunMindReaderPlugin(archiveStoreURL string, mergeArchiveStoreURL string, mergeUploadDirectly bool, ...) (*MindReaderPlugin, error) + func (p *MindReaderPlugin) Close(err error) + func (p *MindReaderPlugin) LogLine(in string) + func (p *MindReaderPlugin) ReadFlow() + type OneblockArchiver struct + func NewOneblockArchiver(workDir string, store dstore.Store, blockFileNamer BlockFileNamer, ...) *OneblockArchiver + type TimeThresholdGator struct + func NewTimeThresholdGatorr(threshold time.Duration) *TimeThresholdGator