desync

package module

Go to main page

Versions in this module

v0

v0.9.5

Jul 4, 2023

v0.9.4

Jun 30, 2023

v0.9.3

Aug 26, 2022

Changes in this version

+ func GetFileSize(fileName string) (size uint64, err error)

+ type AssembleOptions struct

+ InvalidSeedAction InvalidSeedAction

+ N int

+ type DefaultProgressBar struct

+ func (p DefaultProgressBar) Set(current int)

+ func (p DefaultProgressBar) SetTotal(total int)

+ func (p DefaultProgressBar) Start()

+ func (p DefaultProgressBar) Write(b []byte) (n int, err error)

type FileSeed

+ func (s *FileSeed) IsInvalid() bool

+ func (s *FileSeed) RegenerateIndex(ctx context.Context, n int, attempt int, seedNumber int) error

+ func (s *FileSeed) SetInvalid(value bool)

+ type InvalidSeedAction int

+ const InvalidSeedActionBailOut

+ const InvalidSeedActionRegenerate

+ const InvalidSeedActionSkip

+ type NullProgressBar struct

+ func (p NullProgressBar) Add(add int) int

+ func (p NullProgressBar) Finish()

+ func (p NullProgressBar) Increment() int

+ func (p NullProgressBar) Set(current int)

+ func (p NullProgressBar) SetTotal(total int)

+ func (p NullProgressBar) Start()

+ func (p NullProgressBar) Write(b []byte) (n int, err error)

+ type Plan []SeedSegmentCandidate

+ func (p Plan) Validate(ctx context.Context, n int, pb ProgressBar) (err error)

type ProgressBar

+ func NewProgressBar(prefix string) ProgressBar

+ type RepairableCache struct

+ func NewRepairableCache(l WriteStore) RepairableCache

+ func (r RepairableCache) Close() error

+ func (r RepairableCache) GetChunk(id ChunkID) (*Chunk, error)

+ func (r RepairableCache) HasChunk(id ChunkID) (bool, error)

+ func (r RepairableCache) StoreChunk(c *Chunk) error

+ func (r RepairableCache) String() string

type Seed

+ IsInvalid func() bool

+ RegenerateIndex func(ctx context.Context, n int, attempt int, seedNumber int) error

+ SetInvalid func(value bool)

type SeedSegment

+ FileName func() string

+ Validate func(file *os.File) error

+ type SeedSegmentCandidate struct

type SeedSequencer

+ func (r *SeedSequencer) Plan() (plan Plan)

+ func (r *SeedSequencer) RegenerateInvalidSeeds(ctx context.Context, n int, attempt int) error

+ func (r *SeedSequencer) Rewind()

type StoreOptions

+ HTTPCookie string

v0.9.2

May 8, 2021

v0.9.1

Apr 24, 2021

Changes in this version

type Chunk

+ func NewChunk(b []byte) *Chunk

+ func NewChunkFromStorage(id ChunkID, b []byte, modifiers Converters, skipVerify bool) (*Chunk, error)

+ func (c *Chunk) Data() ([]byte, error)

+ type Compressor struct

+ type Converters []converter

type IndexMountFS — darwin/amd64, js/wasm, linux/amd64

+ func (r *IndexMountFS) Close() error

+ type MountFS interface — darwin/amd64, js/wasm, linux/amd64

+ Close func() error

+ type SparseFile struct

+ func NewSparseFile(name string, idx Index, s Store, opt SparseFileOptions) (*SparseFile, error)

+ func (sf *SparseFile) Length() int64

+ func (sf *SparseFile) Open() (*SparseFileHandle, error)

+ func (sf *SparseFile) WriteState() error

+ type SparseFileHandle struct

+ func (h *SparseFileHandle) Close() error

+ func (h *SparseFileHandle) ReadAt(b []byte, offset int64) (int, error)

+ type SparseFileOptions struct

+ StateInitConcurrency int

+ StateInitFile string

+ StateSaveFile string

+ type SparseMountFS struct — darwin/amd64, js/wasm, linux/amd64

+ FName string

+ func NewSparseMountFS(idx Index, name string, s Store, sparseFile string, opt SparseFileOptions) (*SparseMountFS, error)

+ func (r *SparseMountFS) Close() error

+ func (r *SparseMountFS) OnAdd(ctx context.Context)

+ func (r *SparseMountFS) WriteState() error

v0.9.0

Jul 5, 2020

Changes in this version

+ const TarFeatureFlags — windows/amd64

+ var Log = logrus.New()

+ func Tar(ctx context.Context, w io.Writer, fs FilesystemReader) error — windows/amd64

+ type GCIndexStore struct

+ func NewGCIndexStore(location *url.URL, opt StoreOptions) (s GCIndexStore, e error)

+ func (s GCIndexStore) GetIndex(name string) (i Index, e error)

+ func (s GCIndexStore) GetIndexReader(name string) (r io.ReadCloser, err error)

+ func (s GCIndexStore) StoreIndex(name string, idx Index) error

+ type GCStore struct

+ func NewGCStore(location *url.URL, opt StoreOptions) (s GCStore, e error)

+ func (s GCStore) GetChunk(id ChunkID) (*Chunk, error)

+ func (s GCStore) HasChunk(id ChunkID) (bool, error)

+ func (s GCStore) Prune(ctx context.Context, ids map[ChunkID]struct{}) error

+ func (s GCStore) RemoveChunk(id ChunkID) error

+ func (s GCStore) StoreChunk(chunk *Chunk) error

+ type GCStoreBase struct

+ Location string

+ func NewGCStoreBase(u *url.URL, opt StoreOptions) (GCStoreBase, error)

+ func (s GCStoreBase) Close() error

+ func (s GCStoreBase) String() string

+ type GetReaderForRequestBody func() io.Reader

type IndexMountFS — darwin/amd64, js/wasm, linux/amd64

+ func (r *IndexMountFS) OnAdd(ctx context.Context)

+ type LocalFS struct — windows/amd64

+ Root string

+ func NewLocalFS(root string, opts LocalFSOptions) *LocalFS

+ func (fs *LocalFS) CreateDevice(n NodeDevice) error

+ func (fs *LocalFS) CreateDir(n NodeDirectory) error

+ func (fs *LocalFS) CreateFile(n NodeFile) error

+ func (fs *LocalFS) CreateSymlink(n NodeSymlink) error

+ func (fs *LocalFS) Next() (*File, error)

+ func (fs *LocalFS) SetDirPermissions(n NodeDirectory) error

+ func (fs *LocalFS) SetFilePermissions(n NodeFile) error

+ func (fs *LocalFS) SetSymlinkPermissions(n NodeSymlink) error

+ type LocalFSOptions struct — windows/amd64

+ NoSameOwner bool

+ NoSamePermissions bool

+ NoTime bool

+ OneFileSystem bool

type RemoteHTTPBase

+ func (r *RemoteHTTPBase) IssueHttpRequest(method string, u *url.URL, getReader GetReaderForRequestBody, attempt int) (int, []byte, error)

+ func (r *RemoteHTTPBase) IssueRetryableHttpRequest(method string, u *url.URL, getReader GetReaderForRequestBody) (int, []byte, error)

type StoreOptions

+ ErrorRetryBaseInterval time.Duration

+ type SwapStore struct

+ func NewSwapStore(s Store) *SwapStore

+ func (s *SwapStore) Close() error

+ func (s *SwapStore) GetChunk(id ChunkID) (*Chunk, error)

+ func (s *SwapStore) HasChunk(id ChunkID) (bool, error)

+ func (s *SwapStore) String() string

+ func (s *SwapStore) Swap(new Store) error

+ type SwapWriteStore struct

+ func NewSwapWriteStore(s Store) *SwapWriteStore

+ func (s *SwapWriteStore) StoreChunk(chunk *Chunk) error

+ type TarReaderOptions struct

+ AddRoot bool

+ type WriteDedupQueue struct

+ S WriteStore

+ func NewWriteDedupQueue(store WriteStore) *WriteDedupQueue

+ func (q *WriteDedupQueue) GetChunk(id ChunkID) (*Chunk, error)

+ func (q *WriteDedupQueue) HasChunk(id ChunkID) (bool, error)

+ func (q *WriteDedupQueue) StoreChunk(chunk *Chunk) error

v0.8.0

Sep 29, 2019

Changes in this version

+ const CaFormatExcludeFile

+ func FilemodeToStatMode(mode os.FileMode) uint32

+ func StatModeToFilemode(mode uint32) os.FileMode

+ func UnTar(ctx context.Context, r io.Reader, fs FilesystemWriter) error — windows/amd64

+ func UnTarIndex(ctx context.Context, fs FilesystemWriter, index Index, s Store, n int, ...) error — windows/amd64

type Chunker

+ func (c *Chunker) Advance(n int) error

+ type File struct

+ Data io.ReadCloser

+ DevMajor uint64

+ DevMinor uint64

+ Gid int

+ LinkTarget string

+ ModTime time.Time

+ Mode os.FileMode

+ Name string

+ Path string

+ Size uint64

+ Uid int

+ Xattrs map[string]string

+ func (f *File) Close() error

+ func (f *File) IsDevice() bool

+ func (f *File) IsDir() bool

+ func (f *File) IsRegular() bool

+ func (f *File) IsSymlink() bool

+ type FilesystemReader interface

+ Next func() (*File, error)

+ type FilesystemWriter interface

+ CreateDevice func(n NodeDevice) error

+ CreateDir func(n NodeDirectory) error

+ CreateFile func(n NodeFile) error

+ CreateSymlink func(n NodeSymlink) error

+ type HashAlgorithm interface

+ Algorithm func() crypto.Hash

+ Sum func([]byte) [32]byte

+ var Digest HashAlgorithm = SHA512256{}

+ type LocalFS struct — darwin/amd64, js/wasm, linux/amd64

+ Root string

+ func NewLocalFS(root string, opts LocalFSOptions) *LocalFS

+ func (fs *LocalFS) CreateDevice(n NodeDevice) error

+ func (fs *LocalFS) CreateDir(n NodeDirectory) error

+ func (fs *LocalFS) CreateFile(n NodeFile) error

+ func (fs *LocalFS) CreateSymlink(n NodeSymlink) error

+ func (fs *LocalFS) Next() (*File, error)

+ type LocalFSOptions struct — darwin/amd64, js/wasm, linux/amd64

+ NoSameOwner bool

+ NoSamePermissions bool

+ OneFileSystem bool

+ type MtreeFS struct

+ func NewMtreeFS(w io.Writer) (MtreeFS, error)

+ func (fs MtreeFS) CreateDevice(n NodeDevice) error

+ func (fs MtreeFS) CreateDir(n NodeDirectory) error

+ func (fs MtreeFS) CreateFile(n NodeFile) error

+ func (fs MtreeFS) CreateSymlink(n NodeSymlink) error

type NodeFile

+ Size uint64

+ type SHA256 struct

+ func (h SHA256) Algorithm() crypto.Hash

+ func (h SHA256) Sum(data []byte) [32]byte

+ type SHA512256 struct

+ func (h SHA512256) Algorithm() crypto.Hash

+ func (h SHA512256) Sum(data []byte) [32]byte

+ type TarReader struct

+ func NewTarReader(r io.Reader) TarReader

+ func (fs TarReader) Next() (*File, error)

+ type TarWriter struct

+ func NewTarWriter(w io.Writer) TarWriter

+ func (fs TarWriter) Close() error

+ func (fs TarWriter) CreateDevice(n NodeDevice) error

+ func (fs TarWriter) CreateDir(n NodeDirectory) error

+ func (fs TarWriter) CreateFile(n NodeFile) error

+ func (fs TarWriter) CreateSymlink(n NodeSymlink) error

v0.7.1

Jul 14, 2019

v0.7.0

Jun 2, 2019

Changes in this version

+ type DedupQueue struct

+ func NewDedupQueue(store Store) *DedupQueue

+ func (q *DedupQueue) Close() error

+ func (q *DedupQueue) GetChunk(id ChunkID) (*Chunk, error)

+ func (q *DedupQueue) HasChunk(id ChunkID) (bool, error)

+ func (q *DedupQueue) String() string

+ type FailoverGroup struct

+ func NewFailoverGroup(stores ...Store) *FailoverGroup

+ func (g *FailoverGroup) Close() error

+ func (g *FailoverGroup) GetChunk(id ChunkID) (*Chunk, error)

+ func (g *FailoverGroup) HasChunk(id ChunkID) (bool, error)

+ func (g *FailoverGroup) String() string

type StoreOptions

+ CACert string

+ HTTPAuth string

+ TrustInsecure bool

v0.6.0

Jan 29, 2019

v0.5.0

Jan 18, 2019

Changes in this version

type NodeDevice

+ Xattrs Xattrs

type NodeDirectory

+ Xattrs Xattrs

type NodeFile

+ Xattrs Xattrs

type NodeSymlink

+ Xattrs Xattrs

+ type Xattrs map[string]string

v0.4.0

Oct 15, 2018

Changes in this version

+ const CompressedChunkExt

+ const DefaultBlockSize

+ const TarFeatureFlags — darwin/amd64, js/wasm, linux/amd64

+ const UncompressedChunkExt

+ func CanClone(dstFile string, srcFile string) bool — darwin/amd64, js/wasm, windows/amd64

+ func CanClone(dstFile, srcFile string) bool — linux/amd64

+ func CloneRange(dst, src *os.File, srcOffset, srcLength, dstOffset uint64) error

+ type Chunk struct

+ func NewChunkFromUncompressed(b []byte) *Chunk

+ func NewChunkWithID(id ChunkID, uncompressed, compressed []byte, skipVerify bool) (*Chunk, error)

+ func (c *Chunk) Compressed() ([]byte, error)

+ func (c *Chunk) ID() ChunkID

+ func (c *Chunk) Uncompressed() ([]byte, error)

+ type ExtractStats struct

+ Blocksize uint64

+ BytesCloned uint64

+ BytesCopied uint64

+ BytesTotal int64

+ ChunksFromSeeds uint64

+ ChunksFromStore uint64

+ ChunksInPlace uint64

+ ChunksTotal int

+ Seeds int

+ type FileSeed struct

+ func NewIndexSeed(dstFile string, srcFile string, index Index) (*FileSeed, error)

+ func (s *FileSeed) LongestMatchWith(chunks []IndexChunk) (int, SeedSegment)

type HTTPHandler

+ SkipVerifyWrite bool

+ Uncompressed bool

+ type IndexSegment struct

type LocalIndexStore

+ func NewLocalIndexStore(path string) (LocalIndexStore, error)

type ProgressBar

+ Finish func()

+ Increment func() int

+ SetTotal func(total int)

+ type Seed interface

+ LongestMatchWith func(chunks []IndexChunk) (int, SeedSegment)

+ type SeedSegment interface

+ Size func() uint64

+ WriteInto func(dst *os.File, offset, end, blocksize uint64, isBlank bool) (copied uint64, cloned uint64, err error)

+ type SeedSequencer struct

+ func NewSeedSequencer(idx Index, src ...Seed) *SeedSequencer

+ func (r *SeedSequencer) Next() (segment IndexSegment, source SeedSegment, done bool)

+ type StoreOptions struct

+ ClientCert string

+ ClientKey string

+ ErrorRetry int

+ N int

+ SkipVerify bool

+ Timeout time.Duration

+ Uncompressed bool

v0.3.0

Aug 19, 2018

Changes in this version

+ func NewHTTPIndexHandler(s IndexStore, writable bool) http.Handler

+ type ConsoleIndexStore struct

+ func NewConsoleIndexStore() (ConsoleIndexStore, error)

+ func (r ConsoleIndexStore) String() string

+ func (s ConsoleIndexStore) Close() error

+ func (s ConsoleIndexStore) GetIndex(string) (i Index, e error)

+ func (s ConsoleIndexStore) GetIndexReader(string) (io.ReadCloser, error)

+ func (s ConsoleIndexStore) StoreIndex(name string, idx Index) error

+ type HTTPHandlerBase struct

+ type HTTPIndexHandler struct

+ func (h HTTPIndexHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type IndexStore interface

+ GetIndex func(name string) (Index, error)

+ GetIndexReader func(name string) (io.ReadCloser, error)

+ type IndexWriteStore interface

+ StoreIndex func(name string, idx Index) error

+ type LocalIndexStore struct

+ Path string

+ func NewLocaIndexStore(path string) (LocalIndexStore, error)

+ func (r LocalIndexStore) String() string

+ func (s LocalIndexStore) Close() error

+ func (s LocalIndexStore) GetIndex(name string) (i Index, e error)

+ func (s LocalIndexStore) GetIndexReader(name string) (rdr io.ReadCloser, e error)

+ func (s LocalIndexStore) StoreIndex(name string, idx Index) error

+ type NoSuchObject struct

+ func (e NoSuchObject) Error() string

+ type RemoteHTTPBase struct

+ func NewRemoteHTTPStoreBase(location *url.URL, n int, cert string, key string) (*RemoteHTTPBase, error)

+ func (r *RemoteHTTPBase) Close() error

+ func (r *RemoteHTTPBase) GetObject(name string) ([]byte, error)

+ func (r *RemoteHTTPBase) SetErrorRetry(n int)

+ func (r *RemoteHTTPBase) SetTimeout(timeout time.Duration)

+ func (r *RemoteHTTPBase) StoreObject(name string, rdr io.Reader) error

+ func (r *RemoteHTTPBase) String() string

+ type RemoteHTTPIndex struct

+ func NewRemoteHTTPIndexStore(location *url.URL, n int, cert string, key string) (*RemoteHTTPIndex, error)

+ func (r *RemoteHTTPIndex) GetIndex(name string) (i Index, e error)

+ func (r *RemoteHTTPIndex) StoreIndex(name string, idx Index) error

+ func (r RemoteHTTPIndex) GetIndexReader(name string) (rdr io.ReadCloser, e error)

+ type S3IndexStore struct

+ func NewS3IndexStore(location *url.URL, s3Creds *credentials.Credentials, region string) (s S3IndexStore, e error)

+ func (s S3IndexStore) GetIndex(name string) (i Index, e error)

+ func (s S3IndexStore) GetIndexReader(name string) (r io.ReadCloser, e error)

+ func (s S3IndexStore) StoreIndex(name string, idx Index) error

+ type S3StoreBase struct

+ Location string

+ func NewS3StoreBase(u *url.URL, s3Creds *credentials.Credentials, region string) (S3StoreBase, error)

+ func (s S3StoreBase) Close() error

+ func (s S3StoreBase) String() string

+ type SFTPIndexStore struct

+ func NewSFTPIndexStore(location *url.URL) (*SFTPIndexStore, error)

+ func (s *SFTPIndexStore) GetIndex(name string) (i Index, e error)

+ func (s *SFTPIndexStore) GetIndexReader(name string) (r io.ReadCloser, e error)

+ func (s *SFTPIndexStore) StoreIndex(name string, idx Index) error

+ type SFTPStoreBase struct

+ func (s *SFTPStoreBase) Close() error

+ func (s *SFTPStoreBase) StoreObject(name string, r io.Reader) error

+ func (s *SFTPStoreBase) String() string

v0.2.0

Aug 4, 2018

Changes in this version

+ const CaFormatACLDefault

+ const CaFormatACLDefaultGroup

+ const CaFormatACLDefaultUser

+ const CaFormatACLGroup

+ const CaFormatACLGroupObj

+ const CaFormatACLUser

+ const CaFormatDevice

+ const CaFormatEntry

+ const CaFormatExcludeNoDump

+ const CaFormatExcludeSubmounts

+ const CaFormatFCaps

+ const CaFormatFilename

+ const CaFormatGoodbye

+ const CaFormatGoodbyeHashKey0

+ const CaFormatGoodbyeHashKey1

+ const CaFormatGoodbyeTailMarker

+ const CaFormatGroup

+ const CaFormatPayload

+ const CaFormatSELinux

+ const CaFormatSHA512256

+ const CaFormatSymlink

+ const CaFormatTable

+ const CaFormatTableTailMarker

+ const CaFormatUser

+ const CaFormatWith16BitUIDs

+ const CaFormatWith2SecTime

+ const CaFormatWith32BitUIDs

+ const CaFormatWithACL

+ const CaFormatWithDeviceNodes

+ const CaFormatWithFIFOs

+ const CaFormatWithFcaps

+ const CaFormatWithFlagAppend

+ const CaFormatWithFlagArchive

+ const CaFormatWithFlagCompr

+ const CaFormatWithFlagDirSync

+ const CaFormatWithFlagHidden

+ const CaFormatWithFlagImmutable

+ const CaFormatWithFlagNoAtime

+ const CaFormatWithFlagNoComp

+ const CaFormatWithFlagNoCow

+ const CaFormatWithFlagNoDump

+ const CaFormatWithFlagProjectInherit

+ const CaFormatWithFlagSync

+ const CaFormatWithFlagSystem

+ const CaFormatWithNSecTime

+ const CaFormatWithPermissions

+ const CaFormatWithReadOnly

+ const CaFormatWithSELinux

+ const CaFormatWithSecTime

+ const CaFormatWithSockets

+ const CaFormatWithSubvolume

+ const CaFormatWithSubvolumeRO

+ const CaFormatWithSymlinks

+ const CaFormatWithUSecTime

+ const CaFormatWithUserNames

+ const CaFormatWithXattrs

+ const CaFormatXAttr

+ const CaProtocolChunkCompressed

+ const ChunkerWindowSize

+ var FormatString = map[uint64]string

+ var TrustInsecure bool

+ func AssembleFile(ctx context.Context, name string, idx Index, s Store, n int, progress func()) error

+ func ChopFile(ctx context.Context, name string, chunks []IndexChunk, ws WriteStore, n int, ...) error

+ func Compress(b []byte) ([]byte, error)

+ func Copy(ctx context.Context, ids []ChunkID, src Store, dst WriteStore, n int, ...) error

+ func Decompress(out, in []byte) ([]byte, error)

+ func IndexFromFile(ctx context.Context, name string, n int, min, avg, max uint64, ...) (Index, ChunkingStats, error)

+ func MountIndex(ctx context.Context, idx Index, path, name string, s Store, n int) error

+ func NewHTTPHandler(s Store, writable bool) http.Handler

+ func SipHash(b []byte) uint64

+ func Tar(ctx context.Context, w io.Writer, src string) error — darwin/amd64, js/wasm, linux/amd64

+ func UnTar(ctx context.Context, r io.Reader, dst string, opts UntarOptions) error — darwin/amd64, js/wasm, linux/amd64

+ func UnTarIndex(ctx context.Context, dst string, index Index, s Store, n int, ...) error — darwin/amd64, js/wasm, linux/amd64

+ func VerifyIndex(ctx context.Context, name string, idx Index, n int, progress func()) error

+ type ArchiveDecoder struct

+ func NewArchiveDecoder(r io.Reader) ArchiveDecoder

+ func (a *ArchiveDecoder) Next() (interface{}, error)

type Cache

+ func (c Cache) Close() error

+ func (c Cache) HasChunk(id ChunkID) bool

+ func (c Cache) String() string

+ type ChunkInvalid struct

+ ID ChunkID

+ Sum ChunkID

+ func (e ChunkInvalid) Error() string

+ type ChunkStorage struct

+ func NewChunkStorage(ws WriteStore) *ChunkStorage

+ func (s *ChunkStorage) StoreChunk(id ChunkID, b []byte) error

+ type Chunker struct

+ func NewChunker(r io.Reader, min, avg, max uint64) (Chunker, error)

+ func (c *Chunker) Avg() uint64

+ func (c *Chunker) Max() uint64

+ func (c *Chunker) Min() uint64

+ func (c *Chunker) Next() (uint64, []byte, error)

+ type ChunkingStats struct

+ ChunksAccepted uint64

+ ChunksProduced uint64

+ type FormatACLDefault struct

+ GroupObjPermissions uint64

+ MaskPermissions uint64

+ OtherPermissions uint64

+ UserObjPermissions uint64

+ type FormatACLGroup struct

+ GID uint64

+ Name string

+ Permissions uint64

+ type FormatACLGroupObj struct

+ Permissions uint64

+ type FormatACLUser struct

+ Name string

+ Permissions uint64

+ UID uint64

+ type FormatDecoder struct

+ func NewFormatDecoder(r io.Reader) FormatDecoder

+ func (d *FormatDecoder) Next() (interface{}, error)

+ type FormatDevice struct

+ Major uint64

+ Minor uint64

+ type FormatEncoder struct

+ func NewFormatEncoder(w io.Writer) FormatEncoder

+ func (e *FormatEncoder) Encode(v interface{}) (int64, error)

+ type FormatEntry struct

+ FeatureFlags uint64

+ Flags uint64

+ GID int

+ MTime time.Time

+ Mode os.FileMode

+ UID int

+ type FormatFCaps struct

+ Data []byte

+ type FormatFilename struct

+ Name string

+ type FormatGoodbye struct

+ Items []FormatGoodbyeItem

+ type FormatGoodbyeItem struct

+ Hash uint64

+ Offset uint64

+ Size uint64

+ type FormatGroup struct

+ Name string

+ type FormatHeader struct

+ Size uint64

+ Type uint64

+ type FormatIndex struct

+ ChunkSizeAvg uint64

+ ChunkSizeMax uint64

+ ChunkSizeMin uint64

+ FeatureFlags uint64

+ type FormatPayload struct

+ Data io.Reader

+ type FormatSELinux struct

+ Label string

+ type FormatSymlink struct

+ Target string

+ type FormatTable struct

+ Items []FormatTableItem

+ type FormatTableItem struct

+ Chunk ChunkID

+ Offset uint64

+ type FormatUser struct

+ Name string

+ type FormatXAttr struct

+ NameAndValue string

+ type HTTPHandler struct

+ func (h HTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Hash struct

+ func NewHash(size int, discriminator uint32) Hash

+ func (h *Hash) Initialize(b []byte)

+ func (h *Hash) IsBoundary() bool

+ func (h *Hash) Reset()

+ func (h *Hash) Roll(b byte)

type Index

+ Chunks []IndexChunk

+ Index FormatIndex

+ func ChunkStream(ctx context.Context, c Chunker, ws WriteStore, n int) (Index, error)

+ func IndexFromReader(r io.Reader) (c Index, err error)

+ func (i *Index) Length() int64

+ func (i *Index) WriteTo(w io.Writer) (int64, error)

+ type IndexChunk struct

+ ID ChunkID

+ Size uint64

+ Start uint64

+ type IndexMountFS struct

+ FName string

+ Idx Index

+ Store Store

+ func NewIndexMountFS(idx Index, name string, s Store) *IndexMountFS

+ func (me *IndexMountFS) GetAttr(name string, context *fuse.Context) (*fuse.Attr, fuse.Status)

+ func (me *IndexMountFS) Open(name string, flags uint32, context *fuse.Context) (file nodefs.File, code fuse.Status)

+ func (me *IndexMountFS) OpenDir(name string, context *fuse.Context) (c []fuse.DirEntry, code fuse.Status)

+ type IndexMountFile struct

+ func NewIndexMountFile(idx Index, s Store) *IndexMountFile

+ func (f *IndexMountFile) GetAttr(out *fuse.Attr) fuse.Status

+ func (f *IndexMountFile) Read(dest []byte, off int64) (fuse.ReadResult, fuse.Status)

+ type IndexPos struct

+ Index Index

+ Length int64

+ Store Store

+ func NewIndexReadSeeker(i Index, s Store) *IndexPos

+ func (ip *IndexPos) Read(p []byte) (n int, err error)

+ func (ip *IndexPos) Seek(offset int64, whence int) (int64, error)

+ type Interrupted struct

+ func (e Interrupted) Error() string

+ type InvalidFormat struct

+ Msg string

+ func (e InvalidFormat) Error() string

type LocalStore

+ func (s LocalStore) Close() error

+ func (s LocalStore) HasChunk(id ChunkID) bool

+ func (s LocalStore) Prune(ctx context.Context, ids map[ChunkID]struct{}) error

+ func (s LocalStore) RemoveChunk(id ChunkID) error

+ func (s LocalStore) String() string

+ func (s LocalStore) Verify(ctx context.Context, n int, repair bool) error

+ type NodeDevice struct

+ GID int

+ MTime time.Time

+ Major uint64

+ Minor uint64

+ Mode os.FileMode

+ Name string

+ UID int

+ type NodeDirectory struct

+ GID int

+ MTime time.Time

+ Mode os.FileMode

+ Name string

+ UID int

+ type NodeFile struct

+ Data io.Reader

+ GID int

+ MTime time.Time

+ Mode os.FileMode

+ Name string

+ UID int

+ type NodeSymlink struct

+ GID int

+ MTime time.Time

+ Mode os.FileMode

+ Name string

+ Target string

+ UID int

+ type NullChunk struct

+ Data []byte

+ ID ChunkID

+ func NewNullChunk(size uint64) *NullChunk

+ type ProgressBar interface

+ Add func(n int)

+ Set func(n int)

+ Start func()

+ Stop func()

+ type Protocol struct

+ func NewProtocol(r io.Reader, w io.Writer) *Protocol

+ func StartProtocol(u *url.URL) (*Protocol, error)

+ func (p *Protocol) Initialize(flags uint64) (uint64, error)

+ func (p *Protocol) ReadMessage() (Message, error)

+ func (p *Protocol) RecvHello() (uint64, error)

+ func (p *Protocol) RequestChunk(id ChunkID) ([]byte, error)

+ func (p *Protocol) SendGoodbye() error

+ func (p *Protocol) SendHello(flags uint64) error

+ func (p *Protocol) SendMissing(id ChunkID) error

+ func (p *Protocol) SendProtocolChunk(id ChunkID, flags uint64, chunk []byte) error

+ func (p *Protocol) SendProtocolRequest(id ChunkID, flags uint64) error

+ func (p *Protocol) WriteMessage(m Message) error

+ type ProtocolServer struct

+ func NewProtocolServer(r io.Reader, w io.Writer, s Store) *ProtocolServer

+ func (s *ProtocolServer) Serve(ctx context.Context) error

+ type PruneStore interface

+ Prune func(ctx context.Context, ids map[ChunkID]struct{}) error

+ type RemoteHTTP struct

+ func NewRemoteHTTPStore(location *url.URL, n int, cert string, key string) (*RemoteHTTP, error)

+ func (r *RemoteHTTP) GetChunk(id ChunkID) ([]byte, error)

+ func (r *RemoteHTTP) HasChunk(id ChunkID) bool

+ func (r *RemoteHTTP) SetErrorRetry(n int)

+ func (r *RemoteHTTP) SetTimeout(timeout time.Duration)

+ func (r *RemoteHTTP) StoreChunk(id ChunkID, b []byte) error

+ func (r *RemoteHTTP) String() string

+ func (s RemoteHTTP) Close() error

type RemoteSSH

+ func (r *RemoteSSH) Close() error

+ func (r *RemoteSSH) HasChunk(id ChunkID) bool

+ func (r *RemoteSSH) String() string

+ type S3Store struct

+ Location string

+ func NewS3Store(location string, s3Creds *credentials.Credentials, region string) (S3Store, error)

+ func (s S3Store) Close() error

+ func (s S3Store) GetChunk(id ChunkID) ([]byte, error)

+ func (s S3Store) HasChunk(id ChunkID) bool

+ func (s S3Store) Prune(ctx context.Context, ids map[ChunkID]struct{}) error

+ func (s S3Store) RemoveChunk(id ChunkID) error

+ func (s S3Store) StoreChunk(id ChunkID, b []byte) error

+ func (s S3Store) String() string

+ func (s S3Store) Upgrade(ctx context.Context) error

+ type SFTPStore struct

+ func NewSFTPStore(location *url.URL) (*SFTPStore, error)

+ func (s *SFTPStore) Close() error

+ func (s *SFTPStore) GetChunk(id ChunkID) ([]byte, error)

+ func (s *SFTPStore) HasChunk(id ChunkID) bool

+ func (s *SFTPStore) Prune(ctx context.Context, ids map[ChunkID]struct{}) error

+ func (s *SFTPStore) RemoveChunk(id ChunkID) error

+ func (s *SFTPStore) StoreChunk(id ChunkID, b []byte) error

+ func (s *SFTPStore) String() string

type Store

+ Close func() error

+ HasChunk func(id ChunkID) bool

+ type StoreRouter struct

+ Stores []Store

+ func NewStoreRouter(stores ...Store) StoreRouter

+ func (r StoreRouter) Close() error

+ func (r StoreRouter) GetChunk(id ChunkID) ([]byte, error)

+ func (r StoreRouter) HasChunk(id ChunkID) bool

+ func (r StoreRouter) String() string

+ type UntarOptions struct — darwin/amd64, js/wasm, linux/amd64

+ NoSameOwner bool

+ NoSamePermissions bool

+ type WriteStore interface

+ StoreChunk func(id ChunkID, b []byte) error

v0.1.0

Nov 10, 2017

Changes in this version

+ const CaFormatHeader

+ const CaFormatIndex

+ const CaProtocolAbort

+ const CaProtocolArchive

+ const CaProtocolArchiveEOF

+ const CaProtocolChunk

+ const CaProtocolGoodbye

+ const CaProtocolHello

+ const CaProtocolIndex

+ const CaProtocolIndexEOF

+ const CaProtocolMissing

+ const CaProtocolPullArchive

+ const CaProtocolPullChunks

+ const CaProtocolPullIndex

+ const CaProtocolPushArchive

+ const CaProtocolPushChunks

+ const CaProtocolPushIndex

+ const CaProtocolPushIndexChunks

+ const CaProtocolReadableArchive

+ const CaProtocolReadableIndex

+ const CaProtocolReadableStore

+ const CaProtocolRequest

+ const CaProtocolRequestHighPriority

+ const CaProtocolWritableArchive

+ const CaProtocolWritableIndex

+ const CaProtocolWritableStore

+ func DecompressInto(w io.Writer, b []byte) (int64, error)

+ type BlobIndexChunk struct

+ ID ChunkID

+ Size uint64

+ Start uint64

+ type Cache struct

+ func NewCache(s Store, l LocalStore) Cache

+ func (c Cache) GetChunk(id ChunkID) ([]byte, error)

+ type Caibx struct

+ Chunks []BlobIndexChunk

+ Header Header

+ Index Index

+ func CaibxFromReader(r io.Reader) (c Caibx, err error)

+ type ChunkID [32]byte

+ func ChunkIDFromSlice(b []byte) (ChunkID, error)

+ func ChunkIDFromString(id string) (ChunkID, error)

+ func (c ChunkID) String() string

+ type ChunkMissing struct

+ ID ChunkID

+ func (e ChunkMissing) Error() string

+ type Header struct

+ Size uint64

+ Type uint64

+ type Index struct

+ ChunkSizeAvg uint64

+ ChunkSizeMax uint64

+ ChunkSizeMin uint64

+ Flags uint64

+ Size uint64

+ Type uint64

+ type LocalStore struct

+ Base string

+ UpdateTimes bool

+ func NewLocalStore(dir string) (LocalStore, error)

+ func (s LocalStore) GetChunk(id ChunkID) ([]byte, error)

+ func (s LocalStore) StoreChunk(id ChunkID, b []byte) error

+ type Message struct

+ Body []byte

+ Type uint64

+ type RemoteSSH struct

+ func NewRemoteSSHStore(location *url.URL, n int) (*RemoteSSH, error)

+ func (s *RemoteSSH) GetChunk(id ChunkID) ([]byte, error)

+ type Session struct

+ func StartSession(host string, path string) (Session, error)

+ func (s Session) ReadMessage() (Message, error)

+ func (s Session) RecvHello() (uint64, error)

+ func (s Session) RequestChunk(id ChunkID) ([]byte, error)

+ func (s Session) SendHello(flags uint64) error

+ func (s Session) SendProtocolRequest(id ChunkID, flags uint64) error

+ func (s Session) WriteMessage(m Message) error

+ type Store interface

+ GetChunk func(id ChunkID) ([]byte, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL