testutil

package

v0.18.0 Latest Latest Go to latest Published: Apr 23, 2024 License: Apache-2.0, MIT Imports: 24 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/filecoin-project/lily

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func DatabaseAvailable() bool
func DatabaseOptions() string
func FakeBlockHeader(t testing.TB, height int64, stateRoot cid.Cid) *types.BlockHeader
func FakeTipset(t testing.TB) *types.TipSet
func MustFakeTipSet(t *testing.T, height int64) *types.TipSet
func MustMakeAddress(t *testing.T, id uint64) address.Address
func NewAPIWrapper(node *itestkit.TestFullNode) lens.API
func NewMockClock() *clock.Mock
func RandomCid() cid.Cid
func TruncateBlockTables(tb testing.TB, db *pg.DB) error
func WaitForExclusiveDatabase(ctx context.Context, tb testing.TB) (*pg.DB, func() error, error)
func WaitForExclusiveDatabaseLock(ctx context.Context, db *pg.DB) (func() error, error)
type APIWrapper
type BlockHeaderList
- func CollectBlockHeaders(n lens.API, ts *types.TipSet) (BlockHeaderList, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var KnownTime = time.Unix(1601378000, 0).UTC()

Functions ¶

func DatabaseAvailable ¶

func DatabaseAvailable() bool

DatabaseAvailable reports whether a database is available for testing

func DatabaseOptions ¶

func DatabaseOptions() string

Database returns the connection string for connecting to the test database

func FakeBlockHeader ¶

func FakeBlockHeader(t testing.TB, height int64, stateRoot cid.Cid) *types.BlockHeader

func FakeTipset ¶

func FakeTipset(t testing.TB) *types.TipSet

func MustFakeTipSet ¶ added in v0.10.1

func MustFakeTipSet(t *testing.T, height int64) *types.TipSet

func MustMakeAddress ¶ added in v0.10.1

func MustMakeAddress(t *testing.T, id uint64) address.Address

func NewAPIWrapper ¶

func NewAPIWrapper(node *itestkit.TestFullNode) lens.API

func NewMockClock ¶

func NewMockClock() *clock.Mock

func RandomCid ¶

func RandomCid() cid.Cid

func TruncateBlockTables ¶ added in v0.10.0

func TruncateBlockTables(tb testing.TB, db *pg.DB) error

TruncateBlockTables ensures the indexing tables are empty

func WaitForExclusiveDatabase ¶

func WaitForExclusiveDatabase(ctx context.Context, tb testing.TB) (*pg.DB, func() error, error)

WaitForExclusiveDatabase waits for exclusive access to the test database until the context is done or the exclusive access is granted. It returns a cleanup function that should be called to close the database connection.

func WaitForExclusiveDatabaseLock ¶

func WaitForExclusiveDatabaseLock(ctx context.Context, db *pg.DB) (func() error, error)

WaitForExclusiveDatabaseLock waits for a an exclusive lock on the test database until the context is done or the exclusive access is granted. It returns a cleanup function that should be called to release the exclusive lock. In any case the lock will be automatically released when the database session ends.

Types ¶

type APIWrapper ¶

type APIWrapper struct {
	*itestkit.TestFullNode
	// contains filtered or unexported fields
}

func (*APIWrapper) BurnFundsFn ¶ added in v0.12.0

func (aw *APIWrapper) BurnFundsFn(ctx context.Context, ts *types.TipSet) (lens.ShouldBurnFn, error)

func (*APIWrapper) ChainGetTipSetAfterHeight ¶

func (aw *APIWrapper) ChainGetTipSetAfterHeight(ctx context.Context, epoch abi.ChainEpoch, key types.TipSetKey) (*types.TipSet, error)

func (*APIWrapper) CirculatingSupply ¶ added in v0.9.0

func (aw *APIWrapper) CirculatingSupply(ctx context.Context, key types.TipSetKey) (api.CirculatingSupply, error)

func (*APIWrapper) ComputeBaseFee ¶ added in v0.12.0

func (aw *APIWrapper) ComputeBaseFee(ctx context.Context, ts *types.TipSet) (abi.TokenAmount, error)

func (*APIWrapper) Context ¶

func (aw *APIWrapper) Context() context.Context

func (*APIWrapper) Get ¶

func (aw *APIWrapper) Get(ctx context.Context, c cid.Cid, out interface{}) error

func (*APIWrapper) GetMessageExecutionsForTipSet ¶

func (aw *APIWrapper) GetMessageExecutionsForTipSet(ctx context.Context, ts, pts *types.TipSet) ([]*lens.MessageExecution, error)

func (*APIWrapper) MessagesForTipSetBlocks ¶ added in v0.12.0

func (aw *APIWrapper) MessagesForTipSetBlocks(ctx context.Context, ts *types.TipSet) ([]*lens.BlockMessages, error)

func (*APIWrapper) MessagesWithDeduplicationForTipSet ¶ added in v0.17.2

func (aw *APIWrapper) MessagesWithDeduplicationForTipSet(ctx context.Context, ts *types.TipSet) (map[cid.Cid]types.ChainMsg, error)

func (*APIWrapper) Put ¶

func (aw *APIWrapper) Put(ctx context.Context, v interface{}) (cid.Cid, error)

func (*APIWrapper) StateGetReceipt ¶

func (aw *APIWrapper) StateGetReceipt(ctx context.Context, msg cid.Cid, from types.TipSetKey) (*types.MessageReceipt, error)

func (*APIWrapper) Store ¶

func (aw *APIWrapper) Store() adt.Store

func (*APIWrapper) TipSetMessageReceipts ¶ added in v0.12.0

func (aw *APIWrapper) TipSetMessageReceipts(ctx context.Context, ts, pts *types.TipSet) ([]*lens.BlockMessageReceipts, error)

type BlockHeaderList ¶ added in v0.10.0

type BlockHeaderList []*types.BlockHeader

func CollectBlockHeaders ¶ added in v0.10.0

func CollectBlockHeaders(n lens.API, ts *types.TipSet) (BlockHeaderList, error)

CollectBlockHeaders walks the chain to collect blocks that should be indexed

func (BlockHeaderList) Cids ¶ added in v0.10.0

func (b BlockHeaderList) Cids() []string

func (BlockHeaderList) Heights ¶ added in v0.10.1

func (b BlockHeaderList) Heights() []int64

func (BlockHeaderList) Rounds ¶ added in v0.10.0

func (b BlockHeaderList) Rounds() []uint64

Source Files ¶

View all Source files

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