Versions in this module Expand all Collapse all v0 v0.43.1 Aug 21, 2021 Changes in this version + func DrainChunks(chunks <-chan io.ReadCloser) + type ChunkReader struct + func NewChunkReader(ch <-chan io.ReadCloser) *ChunkReader + func (r *ChunkReader) Close() error + func (r *ChunkReader) Read(p []byte) (int, error) + type ChunkWriter struct + func NewChunkWriter(ch chan<- io.ReadCloser, chunkSize uint64) *ChunkWriter + func (w *ChunkWriter) Close() error + func (w *ChunkWriter) CloseWithError(err error) + func (w *ChunkWriter) Write(data []byte) (int, error) + type Manager struct + func NewManager(store *Store, target types.Snapshotter) *Manager + func (m *Manager) Create(height uint64) (*types.Snapshot, error) + func (m *Manager) List() ([]*types.Snapshot, error) + func (m *Manager) LoadChunk(height uint64, format uint32, chunk uint32) ([]byte, error) + func (m *Manager) Prune(retain uint32) (uint64, error) + func (m *Manager) Restore(snapshot types.Snapshot) error + func (m *Manager) RestoreChunk(chunk []byte) (bool, error) + type Store struct + func NewStore(db db.DB, dir string) (*Store, error) + func (s *Store) Delete(height uint64, format uint32) error + func (s *Store) Get(height uint64, format uint32) (*types.Snapshot, error) + func (s *Store) GetLatest() (*types.Snapshot, error) + func (s *Store) List() ([]*types.Snapshot, error) + func (s *Store) Load(height uint64, format uint32) (*types.Snapshot, <-chan io.ReadCloser, error) + func (s *Store) LoadChunk(height uint64, format uint32, chunk uint32) (io.ReadCloser, error) + func (s *Store) Prune(retain uint32) (uint64, error) + func (s *Store) Save(height uint64, format uint32, chunks <-chan io.ReadCloser) (*types.Snapshot, error)
Go to main page