test

package

v1.0.0 Latest Latest Go to latest Published: Aug 15, 2021 License: Apache-2.0, MIT Imports: 53 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/EpiK-Protocol/go-epik

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CreateClientFile(ctx context.Context, client api.FullNode, rseed int) (*api.ImportRes, []byte, error)
func MakeDeal(t *testing.T, ctx context.Context, rseed int, client api.FullNode, ...)
func MineUntilBlock(ctx context.Context, t *testing.T, fn TestNode, sn TestStorageNode, ...)
func SendFunds(ctx context.Context, t *testing.T, sender TestNode, addr address.Address, ...)
func TestApis(t *testing.T, b APIBuilder)
func TestDealFlow(t *testing.T, b APIBuilder, blocktime time.Duration, carExport, fastRet bool, ...)
func TestDealMining(t *testing.T, b APIBuilder, blocktime time.Duration, carExport bool)
func TestDoubleDealFlow(t *testing.T, b APIBuilder, blocktime time.Duration, startEpoch abi.ChainEpoch)
func TestFastRetrievalDealFlow(t *testing.T, b APIBuilder, blocktime time.Duration, startEpoch abi.ChainEpoch)
func TestPaymentChannels(t *testing.T, b APIBuilder, blocktime time.Duration)
func TestPledgeSector(t *testing.T, b APIBuilder, blocktime time.Duration, nSectors int)
func TestPublishDealsBatching(t *testing.T, b APIBuilder, blocktime time.Duration, startEpoch abi.ChainEpoch)
func TestSecondDealRetrieval(t *testing.T, b APIBuilder, blocktime time.Duration)
func TestTerminate(t *testing.T, b APIBuilder, blocktime time.Duration)
func TestWindowPost(t *testing.T, b APIBuilder, blocktime time.Duration, nSectors int)
func TestWindowPostDispute(t *testing.T, b APIBuilder, blocktime time.Duration)
func TestWindowPostDisputeFails(t *testing.T, b APIBuilder, blocktime time.Duration)
func TestZeroPricePerByteRetrievalDealFlow(t *testing.T, b APIBuilder, blocktime time.Duration, startEpoch abi.ChainEpoch)
type APIBuilder
type BlockMiner
- func NewBlockMiner(ctx context.Context, t *testing.T, miner TestStorageNode, ...) *BlockMiner
- func (bm *BlockMiner) MineBlocks()
- func (bm *BlockMiner) Stop()
type FullNodeOpts
- func DefaultFullOpts(nFull int) []FullNodeOpts
type OptionGenerator
type StorageMiner
type TestNode
type TestStorageNode

Constants ¶

View Source

const GenesisPreseals = 2

Variables ¶

View Source

var FullNodeWithActorsV3At = func(upgradeHeight abi.ChainEpoch) FullNodeOpts {
	return FullNodeOpts{
		Opts: func(nodes []TestNode) node.Option {
			return node.Override(new(stmgr.UpgradeSchedule), stmgr.UpgradeSchedule{})
		},
	}
}

View Source

var MineNext = miner.MineReq{
	InjectNulls: 0,
	Done:        func(bool, abi.ChainEpoch, error) {},
}

View Source

var OneFull = DefaultFullOpts(1)

View Source

var OneMiner = []StorageMiner{{Full: 0, Preseal: PresealGenesis}}

View Source

var PresealGenesis = -1

View Source

var TwoFull = DefaultFullOpts(2)

Functions ¶

func CreateClientFile ¶

func CreateClientFile(ctx context.Context, client api.FullNode, rseed int) (*api.ImportRes, []byte, error)

func MakeDeal ¶

func MakeDeal(t *testing.T, ctx context.Context, rseed int, client api.FullNode, miner TestStorageNode, carExport, fastRet bool, startEpoch abi.ChainEpoch)

func MineUntilBlock ¶

func MineUntilBlock(ctx context.Context, t *testing.T, fn TestNode, sn TestStorageNode, cb func(abi.ChainEpoch))

func SendFunds ¶

func SendFunds(ctx context.Context, t *testing.T, sender TestNode, addr address.Address, amount abi.TokenAmount)

func TestApis ¶

func TestApis(t *testing.T, b APIBuilder)

TestApis is the entry point to API test suite

func TestDealFlow ¶

func TestDealFlow(t *testing.T, b APIBuilder, blocktime time.Duration, carExport, fastRet bool, startEpoch abi.ChainEpoch)

func TestDealMining ¶

func TestDealMining(t *testing.T, b APIBuilder, blocktime time.Duration, carExport bool)

func TestDoubleDealFlow ¶

func TestDoubleDealFlow(t *testing.T, b APIBuilder, blocktime time.Duration, startEpoch abi.ChainEpoch)

func TestFastRetrievalDealFlow ¶

func TestFastRetrievalDealFlow(t *testing.T, b APIBuilder, blocktime time.Duration, startEpoch abi.ChainEpoch)

func TestPaymentChannels ¶

func TestPaymentChannels(t *testing.T, b APIBuilder, blocktime time.Duration)

func TestPledgeSector ¶

func TestPledgeSector(t *testing.T, b APIBuilder, blocktime time.Duration, nSectors int)

func TestPublishDealsBatching ¶

func TestPublishDealsBatching(t *testing.T, b APIBuilder, blocktime time.Duration, startEpoch abi.ChainEpoch)

func TestSecondDealRetrieval ¶

func TestSecondDealRetrieval(t *testing.T, b APIBuilder, blocktime time.Duration)

func TestTerminate ¶

func TestTerminate(t *testing.T, b APIBuilder, blocktime time.Duration)

func TestWindowPost ¶

func TestWindowPost(t *testing.T, b APIBuilder, blocktime time.Duration, nSectors int)

func TestWindowPostDispute ¶

func TestWindowPostDispute(t *testing.T, b APIBuilder, blocktime time.Duration)

func TestWindowPostDisputeFails ¶

func TestWindowPostDisputeFails(t *testing.T, b APIBuilder, blocktime time.Duration)

func TestZeroPricePerByteRetrievalDealFlow ¶

func TestZeroPricePerByteRetrievalDealFlow(t *testing.T, b APIBuilder, blocktime time.Duration, startEpoch abi.ChainEpoch)

Types ¶

type APIBuilder ¶

type APIBuilder func(t *testing.T, full []FullNodeOpts, storage []StorageMiner) ([]TestNode, []TestStorageNode)

APIBuilder is a function which is invoked in test suite to provide test nodes and networks

fullOpts array defines options for each full node storage array defines storage nodes, numbers in the array specify full node index the storage node 'belongs' to

type BlockMiner ¶

type BlockMiner struct {
	// contains filtered or unexported fields
}

func NewBlockMiner ¶

func NewBlockMiner(ctx context.Context, t *testing.T, miner TestStorageNode, blocktime time.Duration) *BlockMiner

func (*BlockMiner) MineBlocks ¶

func (bm *BlockMiner) MineBlocks()

func (*BlockMiner) Stop ¶

func (bm *BlockMiner) Stop()

type FullNodeOpts ¶

type FullNodeOpts struct {
	Lite bool            // run node in "lite" mode
	Opts OptionGenerator // generate dependency injection options
}

Options for setting up a mock full node

func DefaultFullOpts ¶

func DefaultFullOpts(nFull int) []FullNodeOpts

type OptionGenerator ¶

type OptionGenerator func([]TestNode) node.Option

type StorageMiner ¶

type StorageMiner struct {
	Full    int
	Opts    node.Option
	Preseal int
}

Options for setting up a mock storage miner

type TestNode ¶

type TestNode struct {
	api.FullNode
	// ListenAddr is the address on which an API server is listening, if an
	// API server is created for this Node
	ListenAddr multiaddr.Multiaddr
}

type TestStorageNode ¶

type TestStorageNode struct {
	api.StorageMiner
	// ListenAddr is the address on which an API server is listening, if an
	// API server is created for this Node
	ListenAddr multiaddr.Multiaddr

	MineOne func(context.Context, miner.MineReq) error
	Stop    func(context.Context) error
}

Source Files ¶

View all Source files

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