testutil

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 NewAPIWrapper(node *itestkit.TestFullNode) lens.API
• func NewMockClock() *clock.Mock
• func RandomCid() cid.Cid
• 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
  • func (aw *APIWrapper) ChainGetTipSetAfterHeight(ctx context.Context, epoch abi.ChainEpoch, key types.TipSetKey) (*types.TipSet, error)
  • func (aw *APIWrapper) Context() context.Context
  • func (aw *APIWrapper) Get(ctx context.Context, c cid.Cid, out interface{}) error
  • func (aw *APIWrapper) GetExecutedAndBlockMessagesForTipset(ctx context.Context, ts, pts *types.TipSet) (*lens.TipSetMessages, error)
  • func (aw *APIWrapper) GetMessageExecutionsForTipSet(ctx context.Context, ts, pts *types.TipSet) ([]*lens.MessageExecution, error)
  • func (aw *APIWrapper) Put(ctx context.Context, v interface{}) (cid.Cid, error)
  • func (aw *APIWrapper) StateGetReceipt(ctx context.Context, msg cid.Cid, from types.TipSetKey) (*types.MessageReceipt, error)
  • func (aw *APIWrapper) Store() adt.Store

Variables

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 NewAPIWrapper

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

func NewMockClock

func NewMockClock() *clock.Mock

func RandomCid

func RandomCid() cid.Cid

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) ChainGetTipSetAfterHeight

func (aw *APIWrapper) ChainGetTipSetAfterHeight(ctx context.Context, epoch abi.ChainEpoch, key types.TipSetKey) (*types.TipSet, 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) GetExecutedAndBlockMessagesForTipset

func (aw *APIWrapper) GetExecutedAndBlockMessagesForTipset(ctx context.Context, ts, pts *types.TipSet) (*lens.TipSetMessages, error)

func (*APIWrapper) GetMessageExecutionsForTipSet

func (aw *APIWrapper) GetMessageExecutionsForTipSet(ctx context.Context, ts, pts *types.TipSet) ([]*lens.MessageExecution, 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