transfer

Jun 17, 2026

Changes in this version

type RemoteDedupWriter

+ func (w *RemoteDedupWriter) WriteHardlink(name string, target string, targetOffset encoder.LinkOffset) error

Jun 12, 2026

Changes in this version

type ArchiveWriter

+ Encoder func() *encoder.Encoder

+ InjectChunks func(chunks []backupproxy.KnownChunkRef) error

type SessionWriter

+ func (w *SessionWriter) InjectChunks(chunks []backupproxy.KnownChunkRef) error

type StreamWriter

+ func (w *StreamWriter) InjectChunks(chunks []backupproxy.KnownChunkRef) error

Jun 12, 2026

Changes in this version

type RemoteDedupWriter

+ func (w *RemoteDedupWriter) InjectChunks(chunks []backupproxy.KnownChunkRef) error

May 18, 2026

Changes in this version

+ func ReadChunkedFile(source datastore.ChunkSource, payloadIdx *datastore.DynamicIndexReader, ...) ([]byte, error)

+ func RecordMax(last **uint64, offset uint64) bool

+ type ChunkedReader struct

+ func NewChunkedReader(idxData []byte, source datastore.ChunkSource) (*ChunkedReader, error)

+ func NewChunkedReaderEager(idxData []byte, source datastore.ChunkSource) (*ChunkedReader, error)

+ func (r *ChunkedReader) Close() error

+ func (r *ChunkedReader) ListDirectory(dirOffset int64, opts accessor.ListOption, fn func(*pxar.Entry) error) error

+ func (r *ChunkedReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *ChunkedReader) ReadCatalog(fn func(CatalogEntry) error) error

+ func (r *ChunkedReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

+ func (r *ChunkedReader) ReadEntryAtMinimal(offset int64) (*pxar.Entry, error)

+ func (r *ChunkedReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

+ func (r *ChunkedReader) ReadRoot() (*pxar.Entry, error)

+ func (r *ChunkedReader) ReaderAt() io.ReaderAt

+ type CopyOption struct

+ OnProgress func(path string, bytes uint64)

+ Overwrite bool

+ SourceCryptConfig *datastore.CryptConfig

+ TargetCryptConfig *datastore.CryptConfig

+ TargetFormat format.FormatVersion

+ type DecryptSource struct

+ func NewDecryptSource(inner datastore.ChunkSource, cc *datastore.CryptConfig) *DecryptSource

+ func (d *DecryptSource) GetChunk(digest [32]byte) ([]byte, error)

+ type DedupWriter struct

+ func NewDedupWriter(store *datastore.ChunkStore, source datastore.ChunkSource, ...) *DedupWriter

+ func (w *DedupWriter) Begin(rootMeta *pxar.Metadata, opts Options) error

+ func (w *DedupWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *DedupWriter) Close() error

+ func (w *DedupWriter) DedupStats() (hits, total int)

+ func (w *DedupWriter) EndDirectory() error

+ func (w *DedupWriter) Finish() error

+ func (w *DedupWriter) MetaIndexData() []byte

+ func (w *DedupWriter) PayloadIndexData() []byte

+ func (w *DedupWriter) ReferenceSourcePayloadChunks()

+ func (w *DedupWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ func (w *DedupWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

+ type FileReader struct

+ func NewFileReader(reader io.ReadSeeker) *FileReader

+ func NewSplitFileReader(metaReader, payloadReader io.ReadSeeker) *FileReader

+ func (r *FileReader) Close() error

+ func (r *FileReader) ListDirectory(dirOffset int64, opts accessor.ListOption, fn func(*pxar.Entry) error) error

+ func (r *FileReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *FileReader) ReadCatalog(fn func(CatalogEntry) error) error

+ func (r *FileReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

+ func (r *FileReader) ReadEntryAtMinimal(offset int64) (*pxar.Entry, error)

+ func (r *FileReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

+ func (r *FileReader) ReadRoot() (*pxar.Entry, error)

+ type Options struct

+ Format format.FormatVersion

+ Prelude []byte

+ type PBSReader struct

+ func NewPBSReader(ctx context.Context, cfg PBSReaderConfig) (*PBSReader, error)

+ func (r *PBSReader) Close() error

+ func (r *PBSReader) ListDirectory(dirOffset int64, opts accessor.ListOption, fn func(*pxar.Entry) error) error

+ func (r *PBSReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *PBSReader) ReadCatalog(fn func(CatalogEntry) error) error

+ func (r *PBSReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

+ func (r *PBSReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

+ func (r *PBSReader) ReadRoot() (*pxar.Entry, error)

+ type PBSReaderConfig struct

+ ArchiveName string

+ BackupID string

+ BackupTime int64

+ BackupType string

+ Config backupproxy.PBSConfig

+ MetaName string

+ MetaOnly bool

+ PayloadName string

+ type ReadSeeker struct

+ func NewReadSeeker(idx *datastore.DynamicIndexReader, source datastore.ChunkSource, maxCache int) *ReadSeeker

+ func (r *ReadSeeker) Close() error

+ func (r *ReadSeeker) Read(p []byte) (int, error)

+ func (r *ReadSeeker) ReadAt(p []byte, offset int64) (int, error)

+ func (r *ReadSeeker) Seek(offset int64, whence int) (int64, error)

+ func (r *ReadSeeker) SetCacheSize(n int)

+ type RemoteDedupWriter struct

+ func NewRemoteDedupWriter(ctx context.Context, session backupproxy.BackupSession, ...) (*RemoteDedupWriter, error)

+ func (w *RemoteDedupWriter) AdvancePayloadPosition(n uint64) error

+ func (w *RemoteDedupWriter) Begin(rootMeta *pxar.Metadata, opts Options) error

+ func (w *RemoteDedupWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *RemoteDedupWriter) Close() error

+ func (w *RemoteDedupWriter) Encoder() *encoder.Encoder

+ func (w *RemoteDedupWriter) EndDirectory() error

+ func (w *RemoteDedupWriter) Finish() error

+ func (w *RemoteDedupWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ func (w *RemoteDedupWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

+ func (w *RemoteDedupWriter) WriteEntryRef(entry *pxar.Entry, payloadOffset uint64) error

+ type SessionWriter struct

+ SplitResult *backupproxy.SplitArchiveResult

+ func NewSessionWriter(ctx context.Context, session backupproxy.BackupSession, ...) *SessionWriter

+ func (w *SessionWriter) Begin(rootMeta *pxar.Metadata, opts Options) error

+ func (w *SessionWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *SessionWriter) Close() error

+ func (w *SessionWriter) Encoder() *encoder.Encoder

+ func (w *SessionWriter) EndDirectory() error

+ func (w *SessionWriter) Finish() error

+ func (w *SessionWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ func (w *SessionWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

+ func (w *SessionWriter) WriteEntryRef(entry *pxar.Entry, payloadOffset uint64) error

+ type SplitReader struct

+ func NewSplitReader(metaIdxData, payloadIdxData []byte, source datastore.ChunkSource) (*SplitReader, error)

+ func NewSplitReaderEager(metaIdxData, payloadIdxData []byte, source datastore.ChunkSource) (*SplitReader, error)

+ func NewSplitReaderMetaOnly(metaIdxData []byte, source datastore.ChunkSource) (*SplitReader, error)

+ func (r *SplitReader) Close() error

+ func (r *SplitReader) ListDirectory(dirOffset int64, opts accessor.ListOption, fn func(*pxar.Entry) error) error

+ func (r *SplitReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *SplitReader) PayloadReaderAt() io.ReaderAt

+ func (r *SplitReader) ReadCatalog(fn func(CatalogEntry) error) error

+ func (r *SplitReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

+ func (r *SplitReader) ReadEntryAtMinimal(offset int64) (*pxar.Entry, error)

+ func (r *SplitReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

+ func (r *SplitReader) ReadRoot() (*pxar.Entry, error)

+ func (r *SplitReader) SetPayloadCacheSize(n int)

+ type StreamWriter struct

+ func NewSplitStreamWriter(output, payloadOut io.Writer) *StreamWriter

+ func NewStreamWriter(output io.Writer) *StreamWriter

+ func (w *StreamWriter) Begin(rootMeta *pxar.Metadata, opts Options) error

+ func (w *StreamWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *StreamWriter) Close() error

+ func (w *StreamWriter) Encoder() *encoder.Encoder

+ func (w *StreamWriter) EndDirectory() error

+ func (w *StreamWriter) Finish() error

+ func (w *StreamWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ func (w *StreamWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

+ func (w *StreamWriter) WriteEntryRef(entry *pxar.Entry, payloadOffset uint64) error

+ func (w *StreamWriter) WriteHardlink(name string, target string, targetOffset encoder.LinkOffset) error

May 17, 2026

Changes in this version

type ArchiveReader

+ ReadEntryAt func(offset int64) (*pxar.Entry, error)

type DecryptingReader

+ func (r *DecryptingReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

type PBSArchiveReader

+ func (r *PBSArchiveReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

May 13, 2026

Changes in this version

type ChunkedArchiveReader

+ func (r *ChunkedArchiveReader) ReaderAt() io.ReaderAt

type SplitArchiveReader

+ func (r *SplitArchiveReader) PayloadReaderAt() io.ReaderAt

May 12, 2026

Changes in this version

+ var WalkMetadataOnly = WalkOption

+ func TryRecordStrictlyGreater(last **uint64, offset uint64) bool

+ func WalkTreeMetadata(reader ArchiveReader, rootPath string, filter WalkFilter, fn MetadataWalkFunc) error

type DecryptingReader

+ func (r *DecryptingReader) ReadCatalog(fn func(CatalogEntry) error) error

+ func (r *DecryptingReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

+ type MetadataWalkFunc func(entry *pxar.Entry) error

May 12, 2026

Changes in this version

type RemoteDedupSplitArchiveWriter

+ func (w *RemoteDedupSplitArchiveWriter) AdvancePayloadPosition(n uint64) error

May 12, 2026

Changes in this version

type ArchiveWriter

+ WriteEntryRef func(entry *pxar.Entry, payloadOffset uint64) error

type ChunkedArchiveWriter

+ func (w *ChunkedArchiveWriter) WriteEntryRef(entry *pxar.Entry, payloadOffset uint64) error

+ type RemoteDedupSplitArchiveWriter struct

+ func NewRemoteDedupSplitArchiveWriter(ctx context.Context, session backupproxy.BackupSession, ...) (*RemoteDedupSplitArchiveWriter, error)

+ func (w *RemoteDedupSplitArchiveWriter) Begin(rootMeta *pxar.Metadata, opts WriterOptions) error

+ func (w *RemoteDedupSplitArchiveWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *RemoteDedupSplitArchiveWriter) Close() error

+ func (w *RemoteDedupSplitArchiveWriter) Encoder() *encoder.Encoder

+ func (w *RemoteDedupSplitArchiveWriter) EndDirectory() error

+ func (w *RemoteDedupSplitArchiveWriter) Finish() error

+ func (w *RemoteDedupSplitArchiveWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ func (w *RemoteDedupSplitArchiveWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

+ func (w *RemoteDedupSplitArchiveWriter) WriteEntryRef(entry *pxar.Entry, payloadOffset uint64) error

type SessionArchiveWriter

+ func (w *SessionArchiveWriter) WriteEntryRef(entry *pxar.Entry, payloadOffset uint64) error

type SplitSessionArchiveWriter

+ func (w *SplitSessionArchiveWriter) Encoder() *encoder.Encoder

+ func (w *SplitSessionArchiveWriter) WriteEntryRef(entry *pxar.Entry, payloadOffset uint64) error

type StreamArchiveWriter

+ func (w *StreamArchiveWriter) WriteEntryRef(entry *pxar.Entry, payloadOffset uint64) error

May 11, 2026

Changes in this version

type ChunkedReadSeeker

+ func (r *ChunkedReadSeeker) SetCacheSize(n int)

type SplitArchiveReader

+ func (r *SplitArchiveReader) SetPayloadCacheSize(n int)

May 11, 2026

Changes in this version

type ChunkedReadSeeker

+ func (r *ChunkedReadSeeker) DisableCache()

type SplitArchiveReader

+ func (r *SplitArchiveReader) DisablePayloadCache()

May 11, 2026

Changes in this version

type ChunkedReadSeeker

+ func (r *ChunkedReadSeeker) ReadAt(p []byte, offset int64) (int, error)

May 11, 2026

Changes in this version

type ChunkedArchiveReader

+ func (r *ChunkedArchiveReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

+ func (r *ChunkedArchiveReader) ReadEntryAtMinimal(offset int64) (*pxar.Entry, error)

type FileArchiveReader

+ func (r *FileArchiveReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

+ func (r *FileArchiveReader) ReadEntryAtMinimal(offset int64) (*pxar.Entry, error)

type SplitArchiveReader

+ func (r *SplitArchiveReader) ReadEntryAt(offset int64) (*pxar.Entry, error)

+ func (r *SplitArchiveReader) ReadEntryAtMinimal(offset int64) (*pxar.Entry, error)

May 9, 2026

Changes in this version

type ArchiveWriter

+ WriteEntryReader func(entry *pxar.Entry, r io.Reader, size uint64) error

type ChunkedArchiveWriter

+ func (w *ChunkedArchiveWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

type DedupSplitArchiveWriter

+ func (w *DedupSplitArchiveWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

type SessionArchiveWriter

+ func (w *SessionArchiveWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

type SplitSessionArchiveWriter

+ func (w *SplitSessionArchiveWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

type StreamArchiveWriter

+ func (w *StreamArchiveWriter) WriteEntryReader(entry *pxar.Entry, r io.Reader, size uint64) error

type TransferOption

+ OnProgress func(path string, bytes uint64)

Apr 19, 2026

Changes in this version

type ArchiveReader

+ ListDirectoryWithOptions func(dirOffset int64, opts ListOption) ([]pxar.Entry, error)

+ LookupBatch func(paths []string) ([]*pxar.Entry, error)

+ ReadCatalog func() ([]CatalogEntry, error)

+ ReadFileContentReader func(entry *pxar.Entry) (io.ReadCloser, error)

+ type CatalogEntry struct

+ FileSize uint64

+ Kind pxar.EntryKind

+ ParentPath string

+ Path string

+ func ReadCatalogOn(r ArchiveReader) ([]CatalogEntry, error)

type ChunkedArchiveReader

+ func (r *ChunkedArchiveReader) ListDirectoryWithOptions(dirOffset int64, opts ListOption) ([]pxar.Entry, error)

+ func (r *ChunkedArchiveReader) LookupBatch(paths []string) ([]*pxar.Entry, error)

+ func (r *ChunkedArchiveReader) ReadCatalog() ([]CatalogEntry, error)

+ func (r *ChunkedArchiveReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

type FileArchiveReader

+ func (r *FileArchiveReader) ListDirectoryWithOptions(dirOffset int64, opts ListOption) ([]pxar.Entry, error)

+ func (r *FileArchiveReader) LookupBatch(paths []string) ([]*pxar.Entry, error)

+ func (r *FileArchiveReader) ReadCatalog() ([]CatalogEntry, error)

+ func (r *FileArchiveReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

+ type ListOption struct

+ Minimal bool

type PBSArchiveConfig

+ MetaOnly bool

type PBSArchiveReader

+ func (r *PBSArchiveReader) ListDirectoryWithOptions(dirOffset int64, opts ListOption) ([]pxar.Entry, error)

+ func (r *PBSArchiveReader) LookupBatch(paths []string) ([]*pxar.Entry, error)

+ func (r *PBSArchiveReader) ReadCatalog() ([]CatalogEntry, error)

+ func (r *PBSArchiveReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

type SplitArchiveReader

+ func NewSplitArchiveReaderMetaOnly(metaIdxData []byte, source datastore.ChunkSource) (*SplitArchiveReader, error)

+ func (r *SplitArchiveReader) ListDirectoryWithOptions(dirOffset int64, opts ListOption) ([]pxar.Entry, error)

+ func (r *SplitArchiveReader) LookupBatch(paths []string) ([]*pxar.Entry, error)

+ func (r *SplitArchiveReader) ReadCatalog() ([]CatalogEntry, error)

+ func (r *SplitArchiveReader) ReadFileContentReader(entry *pxar.Entry) (io.ReadCloser, error)

type WalkOption

+ SkipCount int

Apr 19, 2026

Changes in this version

+ var WalkMetaOnly = WalkOption

+ func WalkTreeMeta(reader ArchiveReader, rootPath string, filter WalkFilter, fn MetaWalkFunc) error

+ func WalkTreeWith(reader ArchiveReader, rootPath string, opts WalkOption, fn WalkFunc) error

+ type MetaWalkFunc func(entry *pxar.Entry) error

+ type TreeWalker struct

+ func NewTreeWalker(reader ArchiveReader, opts WalkOption) *TreeWalker

+ func (w *TreeWalker) Entry() *pxar.Entry

+ func (w *TreeWalker) Err() error

+ func (w *TreeWalker) Init(rootPath string) error

+ func (w *TreeWalker) Next() bool

+ type WalkFilter uint

+ const WalkAll

+ const WalkDevices

+ const WalkDirs

+ const WalkFifos

+ const WalkFiles

+ const WalkHardlinks

+ const WalkSockets

+ const WalkSymlinks

+ type WalkOption struct

+ Filter WalkFilter

+ MetaOnly bool

Apr 14, 2026

Changes in this version

+ var ErrSkipDir = fmt.Errorf("skip directory")

+ func ComputeContentDigest(source datastore.ChunkSource, payloadIdx *datastore.DynamicIndexReader, ...) ([32]byte, error)

+ func Copy(src ArchiveReader, dst ArchiveWriter, mappings []PathMapping, ...) error

+ func CopyTree(src ArchiveReader, dst ArchiveWriter, srcPath, dstPath string, ...) error

+ func ReadFileContentFromChunks(source datastore.ChunkSource, payloadIdx *datastore.DynamicIndexReader, ...) ([]byte, error)

+ func WalkTree(reader ArchiveReader, rootPath string, fn WalkFunc) error

+ type ArchiveReader interface

+ Close func() error

+ ListDirectory func(dirOffset int64) ([]pxar.Entry, error)

+ Lookup func(path string) (*pxar.Entry, error)

+ ReadFileContent func(entry *pxar.Entry) ([]byte, error)

+ ReadRoot func() (*pxar.Entry, error)

+ type ArchiveWriter interface

+ Begin func(rootMeta *pxar.Metadata, opts WriterOptions) error

+ BeginDirectory func(name string, meta *pxar.Metadata) error

+ Close func() error

+ EndDirectory func() error

+ Finish func() error

+ WriteEntry func(entry *pxar.Entry, content []byte) error

+ type ChunkRange struct

+ ChunkEnd uint64

+ ChunkIndex int

+ ChunkStart uint64

+ ContentEnd uint64

+ ContentStart uint64

+ Digest [32]byte

+ IsFullChunk bool

+ func MapFileToPayloadChunks(payloadIdx *datastore.DynamicIndexReader, payloadOffset, fileSize uint64) []ChunkRange

+ type ChunkedArchiveReader struct

+ func NewChunkedArchiveReader(idxData []byte, source datastore.ChunkSource) (*ChunkedArchiveReader, error)

+ func NewChunkedArchiveReaderEager(idxData []byte, source datastore.ChunkSource) (*ChunkedArchiveReader, error)

+ func (r *ChunkedArchiveReader) Close() error

+ func (r *ChunkedArchiveReader) ListDirectory(dirOffset int64) ([]pxar.Entry, error)

+ func (r *ChunkedArchiveReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *ChunkedArchiveReader) ReadFileContent(entry *pxar.Entry) ([]byte, error)

+ func (r *ChunkedArchiveReader) ReadRoot() (*pxar.Entry, error)

+ type ChunkedArchiveWriter struct

+ ChunkResults []datastore.ChunkResult

+ IndexData []byte

+ func NewChunkedArchiveWriter(store *datastore.ChunkStore, config buzhash.Config, compress bool) *ChunkedArchiveWriter

+ func (w *ChunkedArchiveWriter) Begin(rootMeta *pxar.Metadata, opts WriterOptions) error

+ func (w *ChunkedArchiveWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *ChunkedArchiveWriter) Close() error

+ func (w *ChunkedArchiveWriter) EndDirectory() error

+ func (w *ChunkedArchiveWriter) Finish() error

+ func (w *ChunkedArchiveWriter) PayloadIndexData() ([]byte, error)

+ func (w *ChunkedArchiveWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ type ChunkedReadSeeker struct

+ func NewChunkedReadSeeker(idx *datastore.DynamicIndexReader, source datastore.ChunkSource, maxCache int) *ChunkedReadSeeker

+ func (r *ChunkedReadSeeker) Close() error

+ func (r *ChunkedReadSeeker) Read(p []byte) (int, error)

+ func (r *ChunkedReadSeeker) Seek(offset int64, whence int) (int64, error)

+ type DecryptingChunkSource struct

+ func NewDecryptingChunkSource(inner datastore.ChunkSource, cc *datastore.CryptConfig) *DecryptingChunkSource

+ func (d *DecryptingChunkSource) GetChunk(digest [32]byte) ([]byte, error)

+ type DecryptingReader struct

+ func NewDecryptingReader(inner ArchiveReader) *DecryptingReader

+ func (r *DecryptingReader) Close() error

+ func (r *DecryptingReader) ListDirectory(dirOffset int64) ([]pxar.Entry, error)

+ func (r *DecryptingReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *DecryptingReader) ReadFileContent(entry *pxar.Entry) ([]byte, error)

+ func (r *DecryptingReader) ReadRoot() (*pxar.Entry, error)

+ type DedupSplitArchiveWriter struct

+ func NewDedupSplitArchiveWriter(store *datastore.ChunkStore, source datastore.ChunkSource, ...) *DedupSplitArchiveWriter

+ func (w *DedupSplitArchiveWriter) Begin(rootMeta *pxar.Metadata, opts WriterOptions) error

+ func (w *DedupSplitArchiveWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *DedupSplitArchiveWriter) Close() error

+ func (w *DedupSplitArchiveWriter) DedupStats() (hits, total int)

+ func (w *DedupSplitArchiveWriter) EndDirectory() error

+ func (w *DedupSplitArchiveWriter) Finish() error

+ func (w *DedupSplitArchiveWriter) MetaIndexData() []byte

+ func (w *DedupSplitArchiveWriter) PayloadIndexData() []byte

+ func (w *DedupSplitArchiveWriter) ReferenceSourcePayloadChunks()

+ func (w *DedupSplitArchiveWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ type FileArchiveReader struct

+ func NewFileArchiveReader(reader io.ReadSeeker) *FileArchiveReader

+ func NewSplitFileArchiveReader(metaReader, payloadReader io.ReadSeeker) *FileArchiveReader

+ func (r *FileArchiveReader) Close() error

+ func (r *FileArchiveReader) ListDirectory(dirOffset int64) ([]pxar.Entry, error)

+ func (r *FileArchiveReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *FileArchiveReader) ReadFileContent(entry *pxar.Entry) ([]byte, error)

+ func (r *FileArchiveReader) ReadRoot() (*pxar.Entry, error)

+ type PBSArchiveConfig struct

+ ArchiveName string

+ BackupID string

+ BackupTime int64

+ BackupType string

+ Config backupproxy.PBSConfig

+ MetaName string

+ PayloadName string

+ type PBSArchiveReader struct

+ func NewPBSArchiveReader(ctx context.Context, cfg PBSArchiveConfig) (*PBSArchiveReader, error)

+ func (r *PBSArchiveReader) Close() error

+ func (r *PBSArchiveReader) ListDirectory(dirOffset int64) ([]pxar.Entry, error)

+ func (r *PBSArchiveReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *PBSArchiveReader) ReadFileContent(entry *pxar.Entry) ([]byte, error)

+ func (r *PBSArchiveReader) ReadRoot() (*pxar.Entry, error)

+ type PathMapping struct

+ Dst string

+ Src string

+ type SessionArchiveWriter struct

+ UploadResult *backupproxy.UploadResult

+ func NewSessionArchiveWriter(ctx context.Context, session backupproxy.BackupSession, name string) *SessionArchiveWriter

+ func (w *SessionArchiveWriter) Begin(rootMeta *pxar.Metadata, opts WriterOptions) error

+ func (w *SessionArchiveWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *SessionArchiveWriter) Close() error

+ func (w *SessionArchiveWriter) EndDirectory() error

+ func (w *SessionArchiveWriter) Finish() error

+ func (w *SessionArchiveWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ type SplitArchiveReader struct

+ func NewSplitArchiveReader(metaIdxData, payloadIdxData []byte, source datastore.ChunkSource) (*SplitArchiveReader, error)

+ func NewSplitArchiveReaderEager(metaIdxData, payloadIdxData []byte, source datastore.ChunkSource) (*SplitArchiveReader, error)

+ func (r *SplitArchiveReader) Close() error

+ func (r *SplitArchiveReader) ListDirectory(dirOffset int64) ([]pxar.Entry, error)

+ func (r *SplitArchiveReader) Lookup(path string) (*pxar.Entry, error)

+ func (r *SplitArchiveReader) ReadFileContent(entry *pxar.Entry) ([]byte, error)

+ func (r *SplitArchiveReader) ReadRoot() (*pxar.Entry, error)

+ type SplitSessionArchiveWriter struct

+ SplitResult *backupproxy.SplitArchiveResult

+ func NewSplitSessionArchiveWriter(ctx context.Context, session backupproxy.BackupSession, ...) *SplitSessionArchiveWriter

+ func (w *SplitSessionArchiveWriter) Begin(rootMeta *pxar.Metadata, opts WriterOptions) error

+ func (w *SplitSessionArchiveWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *SplitSessionArchiveWriter) Close() error

+ func (w *SplitSessionArchiveWriter) EndDirectory() error

+ func (w *SplitSessionArchiveWriter) Finish() error

+ func (w *SplitSessionArchiveWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ type StreamArchiveWriter struct

+ func NewSplitStreamArchiveWriter(output, payloadOut io.Writer) *StreamArchiveWriter

+ func NewStreamArchiveWriter(output io.Writer) *StreamArchiveWriter

+ func (w *StreamArchiveWriter) Begin(rootMeta *pxar.Metadata, opts WriterOptions) error

+ func (w *StreamArchiveWriter) BeginDirectory(name string, meta *pxar.Metadata) error

+ func (w *StreamArchiveWriter) Close() error

+ func (w *StreamArchiveWriter) Encoder() *encoder.Encoder

+ func (w *StreamArchiveWriter) EndDirectory() error

+ func (w *StreamArchiveWriter) Finish() error

+ func (w *StreamArchiveWriter) WriteEntry(entry *pxar.Entry, content []byte) error

+ func (w *StreamArchiveWriter) WriteHardlink(name string, target string, targetOffset encoder.LinkOffset) error

+ type TransferOption struct

+ Overwrite bool

+ ProgressCallback func(path string, bytes uint64)

+ SourceCryptConfig *datastore.CryptConfig

+ TargetCryptConfig *datastore.CryptConfig

+ TargetFormat format.FormatVersion

+ type WalkFunc func(entry *pxar.Entry, content []byte) error

+ type WriterOptions struct

+ Format format.FormatVersion

+ Prelude []byte