Documentation
¶
Index ¶
- func MakeCommit(blockID tmtypes.BlockID, height int64, round int32, voteSet *tmtypes.VoteSet, ...) (*tmtypes.Commit, error)
- func RandValidator(randPower bool, minPower int64) (*tmtypes.Validator, tmtypes.PrivValidator)
- func RandValidatorSet(numValidators int, votingPower int64) (*tmtypes.ValidatorSet, []tmtypes.PrivValidator)
- func StartGRPCServer(app srvtypes.Application, appCfg *srvconfig.Config, cctx testnode.Context) (testnode.Context, func() error, error)
- func StartTestNode(t *testing.T) testnode.Context
- func StartTestNodeWithConfig(t *testing.T, cfg *TestConfig) testnode.Context
- type BlockFetcher
- func (f *BlockFetcher) Commit(ctx context.Context, height *int64) (*types.Commit, error)
- func (f *BlockFetcher) GetBlock(ctx context.Context, height *int64) (*types.Block, error)
- func (f *BlockFetcher) GetBlockByHash(ctx context.Context, hash tmbytes.HexBytes) (*types.Block, error)
- func (f *BlockFetcher) GetBlockInfo(ctx context.Context, height *int64) (*types.Commit, *types.ValidatorSet, error)
- func (f *BlockFetcher) IsSyncing(ctx context.Context) (bool, error)
- func (f *BlockFetcher) SubscribeNewBlockEvent(ctx context.Context) (<-chan *types.Block, error)
- func (f *BlockFetcher) UnsubscribeNewBlockEvent(ctx context.Context) error
- func (f *BlockFetcher) ValidatorSet(ctx context.Context, height *int64) (*types.ValidatorSet, error)
- type Client
- type TestConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeCommit ¶ added in v0.3.0
func RandValidator ¶ added in v0.3.0
func RandValidatorSet ¶ added in v0.3.0
func RandValidatorSet(numValidators int, votingPower int64) (*tmtypes.ValidatorSet, []tmtypes.PrivValidator)
func StartGRPCServer ¶ added in v0.6.2
func StartGRPCServer( app srvtypes.Application, appCfg *srvconfig.Config, cctx testnode.Context, ) (testnode.Context, func() error, error)
StartGRPCServer is a copy of https://github.com/celestiaorg/celestia-app/blob/e5a679d11b464d583b616d4d686de9dd44bdab2e/testutil/testnode/rpc_client.go#L46 // It's copied as internal Cosmos SDK logic take 5 seconds to run: https://github.com/cosmos/cosmos-sdk/blob/6dfa0c98062d5d8b38d85ca1d2807937f47da4a3/server/grpc/server.go#L80 // FIXME once the fix for https://github.com/cosmos/cosmos-sdk/issues/14429 lands in our fork
func StartTestNode ¶ added in v0.3.0
StartTestNode simply starts Tendermint and Celestia App tandem with default testing configuration.
func StartTestNodeWithConfig ¶ added in v0.6.2
func StartTestNodeWithConfig(t *testing.T, cfg *TestConfig) testnode.Context
StartTestNodeWithConfig starts Tendermint and Celestia App tandem with custom configuration.
Types ¶
type BlockFetcher ¶
type BlockFetcher struct {
// contains filtered or unexported fields
}
func NewBlockFetcher ¶
func NewBlockFetcher(client Client) *BlockFetcher
NewBlockFetcher returns a new `BlockFetcher`.
func (*BlockFetcher) Commit ¶
Commit queries Core for a `Commit` from the block at the given height.
func (*BlockFetcher) GetBlockByHash ¶
func (*BlockFetcher) GetBlockInfo ¶ added in v0.2.0
func (f *BlockFetcher) GetBlockInfo(ctx context.Context, height *int64) (*types.Commit, *types.ValidatorSet, error)
GetBlockInfo queries Core for additional block information, like Commit and ValidatorSet.
func (*BlockFetcher) IsSyncing ¶ added in v0.3.0
func (f *BlockFetcher) IsSyncing(ctx context.Context) (bool, error)
IsSyncing returns the sync status of the Core connection: true for syncing, and false for already caught up. It can also return an error in the case of a failed status request.
func (*BlockFetcher) SubscribeNewBlockEvent ¶
SubscribeNewBlockEvent subscribes to new block events from Core, returning a new block event channel on success.
func (*BlockFetcher) UnsubscribeNewBlockEvent ¶
func (f *BlockFetcher) UnsubscribeNewBlockEvent(ctx context.Context) error
UnsubscribeNewBlockEvent stops the subscription to new block events from Core.
func (*BlockFetcher) ValidatorSet ¶
func (f *BlockFetcher) ValidatorSet(ctx context.Context, height *int64) (*types.ValidatorSet, error)
ValidatorSet queries Core for the ValidatorSet from the block at the given height.
type TestConfig ¶ added in v0.6.2
type TestConfig struct {
ConsensusParams *tmproto.ConsensusParams
Tendermint *tmconfig.Config
App *appconfig.Config
Accounts []string
SuppressLogs bool
}
TestConfig encompasses all the configs required to run test Tendermint + Celestia App tandem.
func DefaultTestConfig ¶ added in v0.6.2
func DefaultTestConfig() *TestConfig
DefaultTestConfig returns the default testing configuration for Tendermint + Celestia App tandem.
It fetches free ports from OS and sets them into configs, s.t. user can make use of them(unlike 0 port) and allowing to run multiple tests nodes in parallel.
Additionally, it instructs Tendermint + Celestia App tandem to setup 10 funded accounts.
Source Files