mindreader

Jan 24, 2024

Changes in this version

+ type CloseableConsoleReader interface

+ Close func() error

Dec 8, 2023

Changes in this version

+ type Archiver struct

+ func NewArchiver(startBlock uint64, oneblockSuffix string, localOneBlocksStore dstore.Store, ...) *Archiver

+ func (a *Archiver) Start(ctx context.Context)

+ func (a *Archiver) StoreBlock(ctx context.Context, block *pbbstream.Block) error

+ type ConsolerReader interface

+ Done func() <-chan interface{}

+ ReadBlock func() (obj *pbbstream.Block, err error)

+ type ConsolerReaderFactory func(lines chan string) (ConsolerReader, error)

+ type FileUploader struct

+ func NewFileUploader(localStore dstore.Store, destinationStore dstore.Store, logger *zap.Logger) *FileUploader

+ func (fu *FileUploader) Start(ctx context.Context)

+ type MindReaderPlugin struct

+ func NewMindReaderPlugin(oneBlocksStoreURL string, workingDirectory string, ...) (*MindReaderPlugin, error)

+ func (p *MindReaderPlugin) LastSeenBlock() bstream.BlockRef

+ func (p *MindReaderPlugin) Launch()

+ func (p *MindReaderPlugin) LogLine(in string)

+ func (p *MindReaderPlugin) Name() string

+ func (p *MindReaderPlugin) OnBlockWritten(callback nodeManager.OnBlockWritten)

+ func (p MindReaderPlugin) Stop()