siafile

package

Go to main page

Versions in this module

v1

v1.4.3

Feb 18, 2020

Changes in this version

+ var ECReedSolomon = modules.ErasureCoderType

+ var ECReedSolomonSubShards64 = modules.ErasureCoderType

type Metadata

+ Skylinks []string

type SiaFile

+ func (sf *SiaFile) AddSkylink(s modules.Skylink) error

type Snapshot

+ func SnapshotFromReader(sp modules.SiaPath, r io.Reader) (*Snapshot, error)

v1.4.3-final-release

Feb 18, 2020

v1.4.2

Jan 22, 2020

Changes in this version

+ const CombinedChunkStatusCompleted

+ const CombinedChunkStatusInComplete

+ const CombinedChunkStatusInvalid

+ var ErrDeleted = errors.New("files was deleted")

+ func CombinedChunkIndex(numChunks, chunkIndex uint64, numCombinedChunks int) int

+ func LoadSiaFileFromReaderWithChunks(r io.ReadSeeker, path string, wal *writeaheadlog.WAL) (*SiaFile, Chunks, error)

type BubbledMetadata

+ UID SiafileUID

+ type Chunks struct

type Metadata

+ CachedUserRedundancy float64

+ DisablePartialChunk bool

+ HasPartialChunk bool

+ PartialChunks []PartialChunkInfo

+ type PartialChunkInfo struct

+ ID modules.CombinedChunkID

+ Index uint64

+ Length uint64

+ Offset uint64

+ Status uint8

type RSCode

+ func (rs *RSCode) Identifier() modules.ErasureCoderIdentifier

type RSSubCode

+ func (rs *RSSubCode) Identifier() modules.ErasureCoderIdentifier

type SiaFile

+ func NewFromLegacyData(fd FileData, siaFilePath string, wal *writeaheadlog.WAL) (*SiaFile, error)

+ func (sf *SiaFile) Chunk(chunkIndex uint64) (chunk, error)

+ func (sf *SiaFile) GoodPieces(chunkIndex int, offlineMap map[string]bool, goodForRenewMap map[string]bool) (uint64, uint64)

+ func (sf *SiaFile) HasPartialChunk() bool

+ func (sf *SiaFile) IsIncludedPartialChunk(chunkIndex uint64) bool

+ func (sf *SiaFile) IsIncompletePartialChunk(chunkIndex uint64) bool

+ func (sf *SiaFile) Lock()

+ func (sf *SiaFile) Merge(newFile *SiaFile) (map[uint64]uint64, error)

+ func (sf *SiaFile) PartialChunks() []PartialChunkInfo

+ func (sf *SiaFile) RemoveLastChunk() error

+ func (sf *SiaFile) SaveHeader() error

+ func (sf *SiaFile) SaveWithChunks(chunks Chunks) error

+ func (sf *SiaFile) SetChunkStatusCompleted(pci uint64) error

+ func (sf *SiaFile) SetPartialChunks(combinedChunks []modules.PartialChunk, updates []writeaheadlog.Update) error

+ func (sf *SiaFile) SetPartialsSiaFile(partialsSiaFile *SiaFile)

+ func (sf *SiaFile) Unlock()

+ func (sf *SiaFile) UnmanagedSetDeleted(deleted bool)

+ func (sf *SiaFile) UnmanagedSetSiaFilePath(newSiaFilePath string)

type Snapshot

+ func (s *Snapshot) IsIncludedPartialChunk(chunkIndex uint64) (PartialChunkInfo, bool)

+ func (s *Snapshot) IsIncompletePartialChunk(chunkIndex uint64) bool

+ func (s *Snapshot) LocalPath() string

+ func (s *Snapshot) PartialChunks() []PartialChunkInfo

+ func (s *Snapshot) UID() SiafileUID

v1.4.1

Jul 3, 2019

Changes in this version

+ type Metadata struct

+ AccessTime time.Time

+ CachedExpiration types.BlockHeight

+ CachedHealth float64

+ CachedRedundancy float64

+ CachedStuckHealth float64

+ CachedUploadProgress float64

+ CachedUploadedBytes uint64

+ ChangeTime time.Time

+ ChunkOffset int64

+ CreateTime time.Time

+ FileSize int64

+ GroupID int

+ Health float64

+ LastHealthCheckTime time.Time

+ LocalPath string

+ ModTime time.Time

+ Mode os.FileMode

+ NumStuckChunks uint64

+ PubKeyTableOffset int64

+ Redundancy float64

+ StaticErasureCodeParams [8]byte

+ StaticErasureCodeType [4]byte

+ StaticMasterKey []byte

+ StaticMasterKeyType crypto.CipherType

+ StaticPagesPerChunk uint8

+ StaticPieceSize uint64

+ StaticSharingKey []byte

+ StaticSharingKeyType crypto.CipherType

+ StaticVersion [16]byte

+ StuckHealth float64

+ UniqueID SiafileUID

+ UserID int

+ func LoadSiaFileMetadata(path string) (Metadata, error)

type RSCode

+ func (rs *RSCode) Reconstruct(pieces [][]byte) error

type RSSubCode

+ func (rs *RSSubCode) Reconstruct(pieces [][]byte) error

type SiaFile

+ func LoadSiaFileFromReader(r io.ReadSeeker, path string, wal *writeaheadlog.WAL) (*SiaFile, error)

+ func (sf *SiaFile) GrowNumChunks(numChunks uint64) error

+ func (sf *SiaFile) Metadata() Metadata

+ func (sf *SiaFile) Save() error

+ func (sf *SiaFile) SaveMetadata() error

+ func (sf *SiaFile) SetAllStuck(stuck bool) (err error)

+ func (sf *SiaFile) SetFileSize(fileSize uint64) error

+ func (sf *SiaFile) SetLastHealthCheckTime()

+ func (sf *SiaFile) SetSiaFilePath(path string)

+ func (sf *SiaFile) SiaFilePath() string

+ func (sf *SiaFile) UpdateUniqueID()

+ func (sf *SiaFile) UploadProgressAndBytes() (float64, uint64)

type SiaFileSet

+ func (sfs *SiaFileSet) AddExistingSiaFile(sf *SiaFile) error

+ func (sfs *SiaFileSet) CachedFileInfo(siaPath modules.SiaPath, offline map[string]bool, goodForRenew map[string]bool, ...) (modules.FileInfo, error)

+ func (sfs *SiaFileSet) DeleteDir(siaPath modules.SiaPath, deleteDir siadir.DeleteDirFunc) error

+ func (sfs *SiaFileSet) FileInfo(siaPath modules.SiaPath, offline map[string]bool, goodForRenew map[string]bool, ...) (modules.FileInfo, error)

+ func (sfs *SiaFileSet) FileList(siaPath modules.SiaPath, recursive, cached bool, offlineMap map[string]bool, ...) ([]modules.FileInfo, error)

+ func (sfs *SiaFileSet) RenameDir(oldPath, newPath modules.SiaPath, rename siadir.RenameDirFunc) error

+ func (sfs *SiaFileSet) SiaPath(entry *SiaFileSetEntry) modules.SiaPath

type SiaFileSetEntry

+ func (entry *SiaFileSetEntry) FileSet() *SiaFileSet

+ func (sf SiaFileSetEntry) Snapshot() *Snapshot

+ type SiafileUID string

v1.4.0

Apr 1, 2019

Changes in this version

+ var ErrPathOverload = errors.New("a file already exists at that location")

+ var ErrUnknownPath = errors.New("no file known with that path")

+ var ErrUnknownThread = errors.New("thread should not be calling Close(), does not have control of the siafile")

+ var RemoteRepairDownloadThreshold = ...

+ func ApplyUpdates(updates ...writeaheadlog.Update) error

+ func ExtractSegment(pieces [][]byte, segmentIndex int, segmentSize uint64) [][]byte

+ func IsSiaFileUpdate(update writeaheadlog.Update) bool

+ func NewRSCode(nData, nParity int) (modules.ErasureCoder, error)

+ func NewRSSubCode(nData, nParity int, segmentSize uint64) (modules.ErasureCoder, error)

+ type BubbledMetadata struct

+ Health float64

+ LastHealthCheckTime time.Time

+ ModTime time.Time

+ NumStuckChunks uint64

+ RecentRepairTime time.Time

+ Redundancy float64

+ Size uint64

+ StuckHealth float64

+ type CachedHealthMetadata struct

+ Health float64

+ Redundancy float64

+ StuckHealth float64

+ type Chunk struct

+ Pieces [][]Piece

+ type FileChunk struct

+ Pieces [][]Piece

+ type FileData struct

+ Chunks []FileChunk

+ Deleted bool

+ ErasureCode modules.ErasureCoder

+ FileSize uint64

+ MasterKey [crypto.EntropySize]byte

+ Mode os.FileMode

+ Name string

+ PieceSize uint64

+ RepairPath string

+ UID string

+ type HostPublicKey struct

+ PublicKey types.SiaPublicKey

+ Used bool

+ func (hpk *HostPublicKey) UnmarshalSia(r io.Reader) error

+ func (hpk HostPublicKey) MarshalSia(w io.Writer) error

+ type Piece struct

+ HostPubKey types.SiaPublicKey

+ MerkleRoot crypto.Hash

+ type RSCode struct

+ func (rs *RSCode) Encode(data []byte) ([][]byte, error)

+ func (rs *RSCode) EncodeShards(pieces [][]byte) ([][]byte, error)

+ func (rs *RSCode) MinPieces() int

+ func (rs *RSCode) NumPieces() int

+ func (rs *RSCode) Recover(pieces [][]byte, n uint64, w io.Writer) error

+ func (rs *RSCode) SupportsPartialEncoding() bool

+ func (rs *RSCode) Type() modules.ErasureCoderType

+ type RSSubCode struct

+ func (rs *RSSubCode) Encode(data []byte) ([][]byte, error)

+ func (rs *RSSubCode) EncodeShards(pieces [][]byte) ([][]byte, error)

+ func (rs *RSSubCode) Recover(pieces [][]byte, n uint64, w io.Writer) error

+ func (rs *RSSubCode) SupportsPartialEncoding() bool

+ func (rs *RSSubCode) Type() modules.ErasureCoderType

+ type SiaFile struct

+ func LoadSiaFile(path string, wal *writeaheadlog.WAL) (*SiaFile, error)

+ func New(siaPath modules.SiaPath, siaFilePath, source string, wal *writeaheadlog.WAL, ...) (*SiaFile, error)

+ func (sf *SiaFile) AccessTime() time.Time

+ func (sf *SiaFile) AddPiece(pk types.SiaPublicKey, chunkIndex, pieceIndex uint64, merkleRoot crypto.Hash) error

+ func (sf *SiaFile) ChangeTime() time.Time

+ func (sf *SiaFile) ChunkHealth(index int, offlineMap map[string]bool, goodForRenewMap map[string]bool) float64

+ func (sf *SiaFile) ChunkIndexByOffset(offset uint64) (chunkIndex uint64, off uint64)

+ func (sf *SiaFile) ChunkSize() uint64

+ func (sf *SiaFile) CreateTime() time.Time

+ func (sf *SiaFile) Delete() error

+ func (sf *SiaFile) Deleted() bool

+ func (sf *SiaFile) ErasureCode() modules.ErasureCoder

+ func (sf *SiaFile) Expiration(contracts map[string]modules.RenterContract) types.BlockHeight

+ func (sf *SiaFile) Health(offline map[string]bool, goodForRenew map[string]bool) (float64, float64, uint64)

+ func (sf *SiaFile) HealthPercentage(health float64) float64

+ func (sf *SiaFile) HostPublicKeys() (spks []types.SiaPublicKey)

+ func (sf *SiaFile) LastHealthCheckTime() time.Time

+ func (sf *SiaFile) LocalPath() string

+ func (sf *SiaFile) MarkAllHealthyChunksAsUnstuck(offline map[string]bool, goodForRenew map[string]bool) (err error)

+ func (sf *SiaFile) MarkAllUnhealthyChunksAsStuck(offline map[string]bool, goodForRenew map[string]bool) (err error)

+ func (sf *SiaFile) MasterKey() crypto.CipherKey

+ func (sf *SiaFile) ModTime() time.Time

+ func (sf *SiaFile) Mode() os.FileMode

+ func (sf *SiaFile) NumChunks() uint64

+ func (sf *SiaFile) NumStuckChunks() uint64

+ func (sf *SiaFile) PieceSize() uint64

+ func (sf *SiaFile) Pieces(chunkIndex uint64) ([][]Piece, error)

+ func (sf *SiaFile) RecentRepairTime() time.Time

+ func (sf *SiaFile) Redundancy(offlineMap map[string]bool, goodForRenewMap map[string]bool) float64

+ func (sf *SiaFile) Rename(newSiaPath modules.SiaPath, newSiaFilePath string) error

+ func (sf *SiaFile) SetLocalPath(path string) error

+ func (sf *SiaFile) SetMode(mode os.FileMode) error

+ func (sf *SiaFile) SetStuck(index uint64, stuck bool) (err error)

+ func (sf *SiaFile) SiaPath() modules.SiaPath

+ func (sf *SiaFile) Size() uint64

+ func (sf *SiaFile) Snapshot() *Snapshot

+ func (sf *SiaFile) SnapshotReader() (*SnapshotReader, error)

+ func (sf *SiaFile) StuckChunkByIndex(index uint64) bool

+ func (sf *SiaFile) UID() string

+ func (sf *SiaFile) UpdateAccessTime() error

+ func (sf *SiaFile) UpdateCachedHealthMetadata(metadata CachedHealthMetadata) error

+ func (sf *SiaFile) UpdateLastHealthCheckTime() error

+ func (sf *SiaFile) UpdateRecentRepairTime() error

+ func (sf *SiaFile) UpdateUsedHosts(used []types.SiaPublicKey) error

+ func (sf *SiaFile) UploadProgress() float64

+ func (sf *SiaFile) UploadedBytes() uint64

+ type SiaFileSet struct

+ func NewSiaFileSet(filesDir string, wal *writeaheadlog.WAL) *SiaFileSet

+ func (sfs *SiaFileSet) Delete(siaPath modules.SiaPath) error

+ func (sfs *SiaFileSet) Exists(siaPath modules.SiaPath) bool

+ func (sfs *SiaFileSet) NewFromLegacyData(fd FileData) (*SiaFileSetEntry, error)

+ func (sfs *SiaFileSet) NewSiaFile(up modules.FileUploadParams, masterKey crypto.CipherKey, fileSize uint64, ...) (*SiaFileSetEntry, error)

+ func (sfs *SiaFileSet) Open(siaPath modules.SiaPath) (*SiaFileSetEntry, error)

+ func (sfs *SiaFileSet) Rename(siaPath, newSiaPath modules.SiaPath) error

+ type SiaFileSetEntry struct

+ func (entry *SiaFileSetEntry) Close() error

+ func (entry *SiaFileSetEntry) CopyEntry() *SiaFileSetEntry

+ type Snapshot struct

+ func (s *Snapshot) ChunkIndexByOffset(offset uint64) (chunkIndex uint64, off uint64)

+ func (s *Snapshot) ChunkSize() uint64

+ func (s *Snapshot) ErasureCode() modules.ErasureCoder

+ func (s *Snapshot) MasterKey() crypto.CipherKey

+ func (s *Snapshot) Mode() os.FileMode

+ func (s *Snapshot) NumChunks() uint64

+ func (s *Snapshot) PieceSize() uint64

+ func (s *Snapshot) Pieces(chunkIndex uint64) ([][]Piece, error)

+ func (s *Snapshot) SiaPath() modules.SiaPath

+ func (s *Snapshot) Size() uint64

+ type SnapshotReader struct

+ func (sfr *SnapshotReader) Close() error

+ func (sfr *SnapshotReader) Read(b []byte) (int, error)

+ func (sfr *SnapshotReader) Stat() (os.FileInfo, error)

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