Versions in this module Expand all Collapse all v1 v1.0.0 Oct 9, 2024 Changes in this version + var MaxAccounts = 10 + var TimeIncrement = time.Second * 5 + func AssertEvents(suite *suite.Suite, expected EventsMap, actual []abci.Event) + func GetChainID(index int) string + func GetSendPackets(evts []abci.Event) []channeltypes.Packet + func MakeBlockID(hash []byte, partSetSize uint32, partSetHash []byte) cmttypes.BlockID + func ParseAckFromEvents(events []abci.Event) ([]byte, error) + func ParseChannelIDFromEvents(events []abci.Event) (string, error) + func ParseChannelVersionFromEvents(events []abci.Event) (string, error) + func ParseClientIDFromEvents(events []abci.Event) (string, error) + func ParseConnectionIDFromEvents(events []abci.Event) (string, error) + func ParsePacketFromEvent(evt abci.Event) channeltypes.Packet + func ParsePacketFromEvents(events []abci.Event) (channeltypes.Packet, error) + func ParsePortIDFromEvents(events []abci.Event) (string, error) + type ChainApp interface + AppCodec func() codec.Codec + GetAccountKeeper func() authkeeper.AccountKeeper + GetBankKeeper func() bankkeeper.Keeper + GetBaseApp func() *baseapp.BaseApp + GetContextForFinalizeBlock func(txBytes []byte) sdk.Context + GetIBCKeeper func() *ibckeeper.Keeper + GetScopedIBCKeeper func() capabilitykeeper.ScopedKeeper + GetStakingKeeper func() *stakingkeeper.Keeper + GetWasmKeeper func() wasmkeeper.Keeper + LastBlockHeight func() int64 + LastCommitID func() storetypes.CommitID + NewContextLegacy func(isCheckTx bool, header cmtproto.Header) sdk.Context + NewUncachedContext func(isCheckTx bool, header cmtproto.Header) sdk.Context + TxConfig func() client.TxConfig + func DefaultWasmAppFactory(t *testing.T, valSet *cmttypes.ValidatorSet, ...) ChainApp + type ChainAppFactory func(t *testing.T, valSet *cmttypes.ValidatorSet, ...) ChainApp + type Coordinator struct + Chains map[string]*TestChain + CurrentTime time.Time + func NewCoordinator(t *testing.T, n int, opts ...[]wasmkeeper.Option) *Coordinator + func NewCoordinatorX(t *testing.T, n int, appFactory ChainAppFactory, opts ...[]wasmkeeper.Option) *Coordinator + func (coord *Coordinator) ChanOpenInitOnBothChains(path *Path) error + func (coord *Coordinator) CloseChannel(path *Path) + func (coord *Coordinator) CommitBlock(chains ...*TestChain) + func (coord *Coordinator) CommitNBlocks(chain *TestChain, n uint64) + func (coord *Coordinator) ConnOpenInitOnBothChains(path *Path) error + func (coord *Coordinator) CreateChannels(path *Path) + func (coord *Coordinator) CreateConnections(path *Path) + func (coord *Coordinator) CreateMockChannels(path *Path) + func (coord *Coordinator) CreateTransferChannels(path *Path) + func (coord *Coordinator) GetChain(chainID string) *TestChain + func (coord *Coordinator) IncrementTime() + func (coord *Coordinator) IncrementTimeBy(increment time.Duration) + func (coord *Coordinator) RelayAndAckPendingPackets(path *Path) error + func (coord *Coordinator) Setup(path *Path) + func (coord *Coordinator) SetupClients(path *Path) + func (coord *Coordinator) SetupConnections(path *Path) + func (coord *Coordinator) TimeoutPendingPackets(path *Path) error + func (coord *Coordinator) UpdateTime() + func (coord *Coordinator) UpdateTimeForChain(chain *TestChain) + type Endpoint struct + Chain *TestChain + ChannelConfig *ibctesting.ChannelConfig + ChannelID string + ClientConfig ibctesting.ClientConfig + ClientID string + ConnectionConfig *ibctesting.ConnectionConfig + ConnectionID string + Counterparty *Endpoint + func NewDefaultEndpoint(chain *TestChain) *Endpoint + func NewEndpoint(chain *TestChain, clientConfig ibctesting.ClientConfig, ...) *Endpoint + func (endpoint *Endpoint) AcknowledgePacket(packet channeltypes.Packet, ack []byte) error + func (endpoint *Endpoint) ChanCloseConfirm() error + func (endpoint *Endpoint) ChanCloseInit() error + func (endpoint *Endpoint) ChanOpenAck() error + func (endpoint *Endpoint) ChanOpenConfirm() error + func (endpoint *Endpoint) ChanOpenInit() error + func (endpoint *Endpoint) ChanOpenTry() error + func (endpoint *Endpoint) ConnOpenAck() error + func (endpoint *Endpoint) ConnOpenConfirm() error + func (endpoint *Endpoint) ConnOpenInit() error + func (endpoint *Endpoint) ConnOpenTry() error + func (endpoint *Endpoint) CreateClient() (err error) + func (endpoint *Endpoint) GetChannel() channeltypes.Channel + func (endpoint *Endpoint) GetClientState() exported.ClientState + func (endpoint *Endpoint) GetConnection() connectiontypes.ConnectionEnd + func (endpoint *Endpoint) GetConsensusState(height exported.Height) exported.ConsensusState + func (endpoint *Endpoint) QueryClientStateProof() (exported.ClientState, []byte) + func (endpoint *Endpoint) QueryConnectionHandshakeProof() (clientState exported.ClientState, proofClient, proofConsensus []byte, ...) + func (endpoint *Endpoint) QueryProof(key []byte) ([]byte, clienttypes.Height) + func (endpoint *Endpoint) QueryProofAtHeight(key []byte, height uint64) ([]byte, clienttypes.Height) + func (endpoint *Endpoint) RecvPacket(packet channeltypes.Packet) error + func (endpoint *Endpoint) RecvPacketWithResult(packet channeltypes.Packet) (*abci.ExecTxResult, error) + func (endpoint *Endpoint) SendPacket(timeoutHeight clienttypes.Height, timeoutTimestamp uint64, data []byte) (uint64, error) + func (endpoint *Endpoint) SetChannel(channel channeltypes.Channel) + func (endpoint *Endpoint) SetChannelClosed() error + func (endpoint *Endpoint) SetClientState(clientState exported.ClientState) + func (endpoint *Endpoint) SetConnection(connection connectiontypes.ConnectionEnd) + func (endpoint *Endpoint) SetConsensusState(consensusState exported.ConsensusState, height exported.Height) + func (endpoint *Endpoint) TimeoutOnClose(packet channeltypes.Packet) error + func (endpoint *Endpoint) TimeoutPacket(packet channeltypes.Packet) error + func (endpoint *Endpoint) UpdateClient() (err error) + func (endpoint *Endpoint) UpgradeChain() error + func (endpoint *Endpoint) WriteAcknowledgement(ack exported.Acknowledgement, packet exported.PacketI) error + type EventsMap map[string]map[string]string + type PacketAck struct + Ack []byte + Packet channeltypes.Packet + type Path struct + EndpointA *Endpoint + EndpointB *Endpoint + func NewPath(chainA, chainB *TestChain) *Path + func (path *Path) Invert() *Path + func (path *Path) RelayPacket(packet channeltypes.Packet, _ []byte) error + func (path *Path) RelayPacketWithoutAck(packet channeltypes.Packet, _ []byte) error + func (path *Path) SendMsg(msgs ...sdk.Msg) error + func (path *Path) SetChannelOrdered() + type SenderAccount struct + SenderAccount sdk.AccountI + SenderPrivKey cryptotypes.PrivKey + type TestChain struct + App ChainApp + ChainID string + Codec codec.Codec + Coordinator *Coordinator + CurrentHeader cmtproto.Header + DefaultMsgFees sdk.Coins + LastHeader *ibctm.Header + NextVals *cmttypes.ValidatorSet + PendingSendPackets []channeltypes.Packet + QueryServer types.QueryServer + SenderAccount sdk.AccountI + SenderAccounts []SenderAccount + SenderPrivKey cryptotypes.PrivKey + Signers map[string]cmttypes.PrivValidator + TxConfig client.TxConfig + Vals *cmttypes.ValidatorSet + func NewDefaultTestChain(t *testing.T, coord *Coordinator, chainID string, opts ...wasmkeeper.Option) *TestChain + func NewTestChain(t *testing.T, coord *Coordinator, appFactory ChainAppFactory, chainID string, ...) *TestChain + func NewTestChainWithValSet(t *testing.T, coord *Coordinator, appFactory ChainAppFactory, chainID string, ...) *TestChain + func (chain *TestChain) AllBalances(acc sdk.AccAddress) sdk.Coins + func (chain *TestChain) Balance(acc sdk.AccAddress, denom string) sdk.Coin + func (chain *TestChain) CaptureIBCEvents(r *abci.ExecTxResult) + func (chain *TestChain) ConstructUpdateCMTClientHeaderWithTrustedHeight(counterparty *TestChain, clientID string, trustedHeight clienttypes.Height) (*ibctm.Header, error) + func (chain *TestChain) ConstructUpdateTMClientHeader(counterparty *TestChain, clientID string) (*ibctm.Header, error) + func (chain *TestChain) ContractInfo(contractAddr sdk.AccAddress) *types.ContractInfo + func (chain *TestChain) CreateChannelCapability(scopedKeeper capabilitykeeper.ScopedKeeper, portID, channelID string) + func (chain *TestChain) CreateCmtClientHeader(chainID string, blockHeight int64, trustedHeight clienttypes.Height, ...) *ibctm.Header + func (chain *TestChain) CreatePortCapability(scopedKeeper capabilitykeeper.ScopedKeeper, portID string) + func (chain *TestChain) CurrentCmtClientHeader() *ibctm.Header + func (chain *TestChain) ExpireClient(amount time.Duration) + func (chain *TestChain) Fund(addr sdk.AccAddress, amount math.Int) + func (chain *TestChain) GetAcknowledgement(packet exported.PacketI) []byte + func (chain *TestChain) GetChannelCapability(portID, channelID string) *capabilitytypes.Capability + func (chain *TestChain) GetClientState(clientID string) exported.ClientState + func (chain *TestChain) GetConsensusState(clientID string, height exported.Height) (exported.ConsensusState, bool) + func (chain *TestChain) GetContext() sdk.Context + func (chain *TestChain) GetPortCapability(portID string) *capabilitytypes.Capability + func (chain *TestChain) GetPrefix() commitmenttypes.MerklePrefix + func (chain *TestChain) GetTimeoutHeight() clienttypes.Height + func (chain *TestChain) GetValsAtHeight(height int64) (*cmttypes.ValidatorSet, bool) + func (chain *TestChain) InstantiateContract(codeID uint64, initMsg []byte) sdk.AccAddress + func (chain *TestChain) NextBlock() + func (chain *TestChain) QueryConsensusStateProof(clientID string) ([]byte, clienttypes.Height) + func (chain *TestChain) QueryProof(key []byte) ([]byte, clienttypes.Height) + func (chain *TestChain) QueryProofAtHeight(key []byte, height int64) ([]byte, clienttypes.Height) + func (chain *TestChain) QueryProofForStore(storeKey string, key []byte, height int64) ([]byte, clienttypes.Height) + func (chain *TestChain) QueryUpgradeProof(key []byte, height uint64) ([]byte, clienttypes.Height) + func (chain *TestChain) RawQuery(contractAddr string, queryData []byte) ([]byte, error) + func (chain *TestChain) SeedNewContractInstance() sdk.AccAddress + func (chain *TestChain) SendMsgs(msgs ...sdk.Msg) (*abci.ExecTxResult, error) + func (chain *TestChain) SendNonDefaultSenderMsgs(senderPrivKey cryptotypes.PrivKey, msgs ...sdk.Msg) (*abci.ExecTxResult, error) + func (chain *TestChain) SmartQuery(contractAddr string, queryMsg, response interface{}) error + func (chain *TestChain) StoreCode(byteCode []byte) types.MsgStoreCodeResponse + func (chain *TestChain) StoreCodeFile(filename string) types.MsgStoreCodeResponse + func (chain *TestChain) UnwrapExecTXResult(r *abci.ExecTxResult, target proto.Message)
Go to main page