Versions in this module Expand all Collapse all v1 v1.20.2 Jul 24, 2026 Changes in this version + type ActiveBoundary struct + EndBlockNumber uint64 + StartBlockNumber uint64 + type BlockState struct + ID string + Number uint64 + type FileState struct + ActiveBoundary ActiveBoundary + Block BlockState + Cursor string + RestartedAt time.Time + StartedAt time.Time + type FileStateStore struct + func NewFileStateStore(outputPath string, outputStore dstore.Store, logger *zap.Logger) (*FileStateStore, error) + func (s *FileStateStore) Close() + func (s *FileStateStore) GetState() (Saveable, error) + func (s *FileStateStore) NewBoundary(boundary *bstream.Range) + func (s *FileStateStore) ReadCursor(ctx context.Context) (cursor *sink.Cursor, err error) + func (s *FileStateStore) SetCursor(cursor *sink.Cursor) + func (s *FileStateStore) Start(ctx context.Context) + func (s *FileStateStore) UploadCursor(saveable Saveable) + type Saveable interface + GetUploadeable func() writer.Uploadeable + Save func() error + type Store interface + Close func() + GetState func() (Saveable, error) + NewBoundary func(*bstream.Range) + OnTerminating func(func(error)) + ReadCursor func(context.Context) (*sink.Cursor, error) + SetCursor func(*sink.Cursor) + Shutdown func(error) + Start func(context.Context) + UploadCursor func(state Saveable)
Go to main page