desync

package module

Go to main page

Versions in this module

v0

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