testutil

package

v0.22.0 Latest Latest Go to latest Published: Dec 13, 2024 License: Apache-2.0, MIT Imports: 24 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/filecoin-project/lily

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