siatest

Sep 21, 2021

Changes in this version

+ var DefaultPaymentContractInitialFunding = types.SiacoinPrecision.Mul64(10)

+ func CheckBalanceVsSpending(r *TestNode, initialBalance types.Currency) error

+ func CheckContractVsReportedSpending(r *TestNode, WindowSize types.BlockHeight, ...) error

+ func CheckExpectedNumberOfContracts(r *TestNode, ...) error

+ func CheckRenewedContractIDs(oldContracts, renewedContracts []api.RenterContract) error

+ func CheckRenewedContractsSpending(renewedContracts []api.RenterContract) error

+ func DrainContractsByUploading(renter *TestNode, tg *TestGroup) (startingUploadSpend types.Currency, err error)

+ func FundNodes(miner *TestNode, nodes map[*TestNode]struct{}) error

+ func PrintJSON(a interface{}) string

+ func RenewContractsByRenewWindow(renter *TestNode, tg *TestGroup) error

+ func RenterContractsStable(renter *TestNode, tg *TestGroup) error

+ func RunSubTests(t *testing.T, params GroupParams, directory string, tests []SubTest) error

type LocalDir

+ func (ld *LocalDir) NewFileWithMode(size int, mode os.FileMode) (*LocalFile, error)

+ func (ld *LocalDir) NewFileWithName(name string, size int) (*LocalFile, error)

type LocalFile

+ func (lf *LocalFile) Data() ([]byte, error)

+ func (lf *LocalFile) Size() int

+ func (lf *LocalFile) Stat() (os.FileInfo, error)

type RemoteFile

+ func (rf *RemoteFile) Root() bool

+ type SubTest struct

+ Name string

+ Test func(*testing.T, *TestGroup)

type TestGroup

+ func (tg *TestGroup) Portals() []*TestNode

+ func (tg *TestGroup) RemoveNodeN(tns ...*TestNode) error

+ func (tg *TestGroup) StartNodeCleanDeps(tn *TestNode) error

type TestNode

+ func NewCleanNodeAsync(nodeParams node.NodeParams) (*TestNode, error)

+ func (tn *TestNode) DownloadByStreamWithDiskFetch(rf *RemoteFile, disableLocalFetch bool) (uid modules.DownloadID, data []byte, err error)

+ func (tn *TestNode) DownloadToDiskWithDiskFetch(rf *RemoteFile, async bool, disableLocalFetch bool) (modules.DownloadID, *LocalFile, error)

+ func (tn *TestNode) IsAlertRegistered(a modules.Alert) error

+ func (tn *TestNode) IsAlertUnregistered(a modules.Alert) error

+ func (tn *TestNode) MineEmptyBlock() error

+ func (tn *TestNode) RenameRoot(rf *RemoteFile, newPath modules.SiaPath, root bool) (*RemoteFile, error)

+ func (tn *TestNode) StartNodeCleanDeps() error

+ func (tn *TestNode) StreamWithDiskFetch(rf *RemoteFile, disableLocalFetch bool) (data []byte, err error)

+ func (tn *TestNode) WaitForFileAvailable(rf *RemoteFile) error

+ func (tn *TestNode) WaitForUploadHealth(rf *RemoteFile) error

Apr 1, 2019

Changes in this version

+ const NumberOfParallelGroups

+ var ErrFileNotTracked = errors.New("file is not tracked by renter")

+ func NewGroupBuffer(size int) chan struct

+ type LocalDir struct

+ func (ld *LocalDir) CreateDir(name string) (*LocalDir, error)

+ func (ld *LocalDir) Files() ([]*LocalFile, error)

+ func (ld *LocalDir) Name() string

+ func (ld *LocalDir) NewFile(size int) (*LocalFile, error)

+ func (ld *LocalDir) Path() string

+ func (ld *LocalDir) PopulateDir(files, dirs, levels uint) error

type LocalFile

+ func (lf *LocalFile) Equal(data []byte) error

+ func (lf *LocalFile) FileName() string

+ func (lf *LocalFile) Path() string

+ type RemoteDir struct

+ func (rd *RemoteDir) SiaPath() string

type RemoteFile

+ func (rf *RemoteFile) Checksum() crypto.Hash

type TestGroup

+ func (tg *TestGroup) RestartNode(tn *TestNode) error

type TestNode

+ func (tn *TestNode) BlockHeight() (types.BlockHeight, error)

+ func (tn *TestNode) ConfirmedBalance() (types.Currency, error)

+ func (tn *TestNode) ConfirmedTransactions() ([]modules.ProcessedTransaction, error)

+ func (tn *TestNode) Dirs() ([]string, error)

+ func (tn *TestNode) DownloadDir() *LocalDir

+ func (tn *TestNode) FilesDir() *LocalDir

+ func (tn *TestNode) NewLocalDir() *LocalDir

+ func (tn *TestNode) Rename(rf *RemoteFile, newPath string) (*RemoteFile, error)

+ func (tn *TestNode) RenterDir() string

+ func (tn *TestNode) RenterFilesDir() string

+ func (tn *TestNode) SiaPath(path string) string

+ func (tn *TestNode) UploadBlocking(localFile *LocalFile, dataPieces uint64, parityPieces uint64, force bool) (*RemoteFile, error)

+ func (tn *TestNode) UploadDirectory(ld *LocalDir) (*RemoteDir, error)

+ func (tn *TestNode) UploadNewDirectory() (*RemoteDir, error)

+ func (tn *TestNode) WaitForStuckChunksToBubble() error

+ func (tn *TestNode) WaitForStuckChunksToRepair() error

Oct 16, 2018

Changes in this version

+ func NewDependencyCustomResolver(lookupIP func(string) ([]net.IP, error)) modules.Dependencies

type LocalFile

+ func (lf *LocalFile) Move() error

type TestNode

+ func (tn *TestNode) DownloadToDiskPartial(rf *RemoteFile, lf *LocalFile, async bool, offset, length uint64) (*LocalFile, error)

+ func (tn *TestNode) PrintDebugInfo(t *testing.T, contractInfo, hostInfo, renterInfo bool)

+ func (tn *TestNode) SetFileRepairPath(rf *RemoteFile, lf *LocalFile) error

Sep 5, 2018

Changes in this version

type RemoteFile

+ func (rf RemoteFile) SiaPath() string

type TestNode

+ func (tn *TestNode) NewFile(size int) (*LocalFile, error)

Jun 12, 2018

Changes in this version

+ var DefaultAllowance = modules.Allowance

+ func ChunkSize(minPieces uint64) uint64

+ type DependencyInterruptOnceOnKeyword struct

+ func NewDependencyInterruptOnceOnKeyword(str string) *DependencyInterruptOnceOnKeyword

+ func (d *DependencyInterruptOnceOnKeyword) Disable()

+ func (d *DependencyInterruptOnceOnKeyword) Disrupt(s string) bool

+ func (d *DependencyInterruptOnceOnKeyword) Fail()

type LocalFile

+ func (lf *LocalFile) Delete() error

type TestGroup

+ func (tg *TestGroup) AddNodeN(np node.NodeParams, n int) error

+ func (tg *TestGroup) AddNodes(nps ...node.NodeParams) error

+ func (tg *TestGroup) RemoveNode(tn *TestNode) error

+ func (tg *TestGroup) SetRenterAllowance(renter *TestNode, allowance modules.Allowance) error

+ func (tg *TestGroup) StartNode(tn *TestNode) error

+ func (tg *TestGroup) StopNode(tn *TestNode) error

+ func (tg *TestGroup) Sync() error

type TestNode

+ func (tn *TestNode) File(siaPath string) (modules.FileInfo, error)

+ func (tn *TestNode) KnowsHost(host *TestNode) error

+ func (tn *TestNode) RestartNode() error

+ func (tn *TestNode) StartNode() error

+ func (tn *TestNode) StopNode() error

+ func (tn *TestNode) Stream(rf *RemoteFile) (data []byte, err error)

+ func (tn *TestNode) StreamPartial(rf *RemoteFile, lf *LocalFile, from, to uint64) (data []byte, err error)

+ func (tn *TestNode) WaitForDecreasingRedundancy(rf *RemoteFile, redundancy float64) error

Mar 13, 2018

Changes in this version

+ var MinerTemplate = node.NodeParams

+ var SiaTestingDir = filepath.Join(os.TempDir(), "SiaTesting")

+ func Fuzz() int

+ func Miner(dir string) node.NodeParams

+ func Retry(tries int, durationBetweenAttempts time.Duration, fn func() error) (err error)

+ func TestDir(dirs ...string) (string, error)

+ type GroupParams struct

+ Hosts int

+ Miners int

+ Renters int

+ type LocalFile struct

+ func NewFile(size int) (*LocalFile, error)

+ type RemoteFile struct

+ type TestGroup struct

+ func NewGroup(nodeParams ...node.NodeParams) (*TestGroup, error)

+ func NewGroupFromTemplate(groupParams GroupParams) (*TestGroup, error)

+ func (tg *TestGroup) Close() error

+ func (tg *TestGroup) Hosts() []*TestNode

+ func (tg *TestGroup) Miners() []*TestNode

+ func (tg *TestGroup) Nodes() []*TestNode

+ func (tg *TestGroup) Renters() []*TestNode

+ type TestNode struct

+ func NewCleanNode(nodeParams node.NodeParams) (*TestNode, error)

+ func NewNode(nodeParams node.NodeParams) (*TestNode, error)

+ func (tn *TestNode) DownloadByStream(rf *RemoteFile) (data []byte, err error)

+ func (tn *TestNode) DownloadInfo(lf *LocalFile, rf *RemoteFile) (*api.DownloadInfo, error)

+ func (tn *TestNode) DownloadToDisk(rf *RemoteFile, async bool) (*LocalFile, error)

+ func (tn *TestNode) FileInfo(rf *RemoteFile) (modules.FileInfo, error)

+ func (tn *TestNode) Files() ([]modules.FileInfo, error)

+ func (tn *TestNode) MineBlock() error

+ func (tn *TestNode) Upload(lf *LocalFile, dataPieces, parityPieces uint64) (*RemoteFile, error)

+ func (tn *TestNode) UploadNewFile(filesize int, dataPieces uint64, parityPieces uint64) (rf *RemoteFile, err error)

+ func (tn *TestNode) UploadNewFileBlocking(filesize int, dataPieces uint64, parityPieces uint64) (rf *RemoteFile, err error)

+ func (tn *TestNode) WaitForDownload(lf *LocalFile, rf *RemoteFile) error

+ func (tn *TestNode) WaitForUploadProgress(rf *RemoteFile, progress float64) error

+ func (tn *TestNode) WaitForUploadRedundancy(rf *RemoteFile, redundancy float64) error