Documentation ¶
Index ¶
- Variables
- func MockChainParams(chainID int64, confirmation uint64) observertypes.ChainParams
- func MockConnectorNonEth(t *testing.T, chainID int64) *zetaconnector.ZetaConnectorNonEth
- func MockERC20Custody(t *testing.T, chainID int64) *erc20custody.ERC20Custody
- func NewKeyring() ckeys.Keyring
- type BTCObserver
- type BTCRPCClient
- func (_m *BTCRPCClient) CreateWallet(name string, opts ...rpcclient.CreateWalletOpt) (*btcjson.CreateWalletResult, error)
- func (_m *BTCRPCClient) EstimateSmartFee(confTarget int64, mode *btcjson.EstimateSmartFeeMode) (*btcjson.EstimateSmartFeeResult, error)
- func (_m *BTCRPCClient) GenerateToAddress(numBlocks int64, address btcutil.Address, maxTries *int64) ([]*chainhash.Hash, error)
- func (_m *BTCRPCClient) GetBalance(account string) (btcutil.Amount, error)
- func (_m *BTCRPCClient) GetBlockCount() (int64, error)
- func (_m *BTCRPCClient) GetBlockHash(blockHeight int64) (*chainhash.Hash, error)
- func (_m *BTCRPCClient) GetBlockHeader(blockHash *chainhash.Hash) (*wire.BlockHeader, error)
- func (_m *BTCRPCClient) GetBlockVerbose(blockHash *chainhash.Hash) (*btcjson.GetBlockVerboseResult, error)
- func (_m *BTCRPCClient) GetBlockVerboseTx(blockHash *chainhash.Hash) (*btcjson.GetBlockVerboseTxResult, error)
- func (_m *BTCRPCClient) GetNetworkInfo() (*btcjson.GetNetworkInfoResult, error)
- func (_m *BTCRPCClient) GetNewAddress(account string) (btcutil.Address, error)
- func (_m *BTCRPCClient) GetRawTransaction(txHash *chainhash.Hash) (*btcutil.Tx, error)
- func (_m *BTCRPCClient) GetRawTransactionVerbose(txHash *chainhash.Hash) (*btcjson.TxRawResult, error)
- func (_m *BTCRPCClient) GetTransaction(txHash *chainhash.Hash) (*btcjson.GetTransactionResult, error)
- func (_m *BTCRPCClient) ListUnspent() ([]btcjson.ListUnspentResult, error)
- func (_m *BTCRPCClient) ListUnspentMinMaxAddresses(minConf int, maxConf int, addrs []btcutil.Address) ([]btcjson.ListUnspentResult, error)
- func (_m *BTCRPCClient) SendRawTransaction(tx *wire.MsgTx, allowHighFees bool) (*chainhash.Hash, error)
- type BTCSigner
- type CometBFTClient
- func (c *CometBFTClient) Block(_ context.Context, _ *int64) (*coretypes.ResultBlock, error)
- func (c *CometBFTClient) BroadcastTxAsync(_ context.Context, _ tmtypes.Tx) (*coretypes.ResultBroadcastTx, error)
- func (c *CometBFTClient) BroadcastTxCommit(_ context.Context, _ tmtypes.Tx) (*coretypes.ResultBroadcastTxCommit, error)
- func (c *CometBFTClient) BroadcastTxSync(_ context.Context, _ tmtypes.Tx) (*coretypes.ResultBroadcastTx, error)
- func (c *CometBFTClient) SetBroadcastTxHash(hash string) *CometBFTClient
- func (c *CometBFTClient) SetError(err error) *CometBFTClient
- func (c *CometBFTClient) Tx(_ context.Context, _ []byte, _ bool) (*coretypes.ResultTx, error)
- type DummyObserver
- func (ob *DummyObserver) ChainParams() (_ observertypes.ChainParams)
- func (ob *DummyObserver) SetChainParams(_ observertypes.ChainParams)
- func (ob *DummyObserver) Start(_ context.Context)
- func (ob *DummyObserver) Stop()
- func (ob *DummyObserver) VoteOutboundIfConfirmed(_ context.Context, _ *cc.CrossChainTx) (bool, error)
- type DummySigner
- func (s *DummySigner) GetERC20CustodyAddress() (_ ethcommon.Address)
- func (s *DummySigner) GetGatewayAddress() (_ string)
- func (s *DummySigner) GetZetaConnectorAddress() (_ ethcommon.Address)
- func (s *DummySigner) SetERC20CustodyAddress(_ ethcommon.Address)
- func (s *DummySigner) SetGatewayAddress(_ string)
- func (s *DummySigner) SetZetaConnectorAddress(_ ethcommon.Address)
- func (s *DummySigner) TryProcessOutbound(_ context.Context, _ *crosschaintypes.CrossChainTx, ...)
- type EVMObserver
- type EVMRPCClient
- func (_m *EVMRPCClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
- func (_m *EVMRPCClient) BlockNumber(ctx context.Context) (uint64, error)
- func (_m *EVMRPCClient) CallContract(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
- func (_m *EVMRPCClient) CodeAt(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)
- func (_m *EVMRPCClient) EstimateGas(ctx context.Context, call ethereum.CallMsg) (uint64, error)
- func (_m *EVMRPCClient) FilterLogs(ctx context.Context, query ethereum.FilterQuery) ([]types.Log, error)
- func (_m *EVMRPCClient) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
- func (_m *EVMRPCClient) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)
- func (_m *EVMRPCClient) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)
- func (_m *EVMRPCClient) SendTransaction(ctx context.Context, tx *types.Transaction) error
- func (_m *EVMRPCClient) SubscribeFilterLogs(ctx context.Context, query ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
- func (_m *EVMRPCClient) SuggestGasPrice(ctx context.Context) (*big.Int, error)
- func (_m *EVMRPCClient) SuggestGasTipCap(ctx context.Context) (*big.Int, error)
- func (_m *EVMRPCClient) TransactionByHash(ctx context.Context, hash common.Hash) (*types.Transaction, bool, error)
- func (_m *EVMRPCClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
- func (_m *EVMRPCClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)
- type EVMSigner
- type Keyring
- func (m Keyring) Backend() string
- func (m Keyring) Delete(_ string) error
- func (m Keyring) DeleteByAddress(_ sdk.Address) error
- func (m Keyring) ExportPrivKeyArmor(_, _ string) (armor string, err error)
- func (m Keyring) ExportPrivKeyArmorByAddress(_ sdk.Address, _ string) (armor string, err error)
- func (m Keyring) ExportPubKeyArmor(_ string) (string, error)
- func (m Keyring) ExportPubKeyArmorByAddress(_ sdk.Address) (string, error)
- func (m Keyring) ImportPrivKey(_, _, _ string) error
- func (m Keyring) ImportPrivKeyHex(_, _, _ string) error
- func (m Keyring) ImportPubKey(_ string, _ string) error
- func (m Keyring) Key(uid string) (*ckeys.Record, error)
- func (m Keyring) KeyByAddress(_ sdk.Address) (*ckeys.Record, error)
- func (m Keyring) List() ([]*ckeys.Record, error)
- func (m Keyring) MigrateAll() ([]*ckeys.Record, error)
- func (m Keyring) NewAccount(_, _, _, _ string, _ ckeys.SignatureAlgo) (*ckeys.Record, error)
- func (m Keyring) NewMnemonic(_ string, _ ckeys.Language, _, _ string, _ ckeys.SignatureAlgo) (*ckeys.Record, string, error)
- func (m Keyring) Rename(_ string, _ string) error
- func (m Keyring) SaveLedgerKey(_ string, _ ckeys.SignatureAlgo, _ string, _, _, _ uint32) (*ckeys.Record, error)
- func (m Keyring) SaveMultisig(_ string, _ cryptotypes.PubKey) (*ckeys.Record, error)
- func (m Keyring) SaveOfflineKey(_ string, _ cryptotypes.PubKey) (*ckeys.Record, error)
- func (m Keyring) Sign(_ string, _ []byte) ([]byte, cryptotypes.PubKey, error)
- func (m Keyring) SignByAddress(_ sdk.Address, _ []byte) ([]byte, cryptotypes.PubKey, error)
- func (m Keyring) SupportedAlgorithms() (ckeys.SigningAlgoList, ckeys.SigningAlgoList)
- type LiteClient
- func (_m *LiteClient) GetBlockHeader(ctx context.Context, blockID ton.BlockIDExt, mode uint32) (tlb.BlockInfo, error)
- func (_m *LiteClient) GetConfigParams(ctx context.Context, mode liteapi.ConfigMode, params []uint32) (tlb.ConfigParams, error)
- func (_m *LiteClient) GetFirstTransaction(ctx context.Context, acc ton.AccountID) (*ton.Transaction, int, error)
- func (_m *LiteClient) GetMasterchainInfo(ctx context.Context) (liteclient.LiteServerMasterchainInfoC, error)
- func (_m *LiteClient) GetTransaction(ctx context.Context, acc ton.AccountID, lt uint64, hash ton.Bits256) (ton.Transaction, error)
- func (_m *LiteClient) GetTransactionsSince(ctx context.Context, acc ton.AccountID, lt uint64, hash ton.Bits256) ([]ton.Transaction, error)
- type MockJSONRPCClient
- func (e *MockJSONRPCClient) EthGetBlockByNumber(_ int, _ bool) (*ethrpc.Block, error)
- func (e *MockJSONRPCClient) EthGetTransactionByHash(_ string) (*ethrpc.Transaction, error)
- func (e *MockJSONRPCClient) Reset() *MockJSONRPCClient
- func (e *MockJSONRPCClient) WithBlock(block *ethrpc.Block) *MockJSONRPCClient
- func (e *MockJSONRPCClient) WithBlocks(blocks []*ethrpc.Block) *MockJSONRPCClient
- func (e *MockJSONRPCClient) WithTransaction(tx *ethrpc.Transaction) *MockJSONRPCClient
- func (e *MockJSONRPCClient) WithTransactions(txs []*ethrpc.Transaction) *MockJSONRPCClient
- type SignerLiteClient
- func (_m *SignerLiteClient) GetAccountState(ctx context.Context, accountID ton.AccountID) (tlb.ShardAccount, error)
- func (_m *SignerLiteClient) GetTransactionsSince(ctx context.Context, acc ton.AccountID, lt uint64, hash ton.Bits256) ([]ton.Transaction, error)
- func (_m *SignerLiteClient) SendMessage(ctx context.Context, payload []byte) (uint32, error)
- type SolanaObserver
- type SolanaRPCClient
- func (_m *SolanaRPCClient) GetAccountInfo(ctx context.Context, account solana.PublicKey) (*rpc.GetAccountInfoResult, error)
- func (_m *SolanaRPCClient) GetBalance(ctx context.Context, account solana.PublicKey, commitment rpc.CommitmentType) (*rpc.GetBalanceResult, error)
- func (_m *SolanaRPCClient) GetBlockTime(ctx context.Context, block uint64) (*solana.UnixTimeSeconds, error)
- func (_m *SolanaRPCClient) GetConfirmedTransactionWithOpts(ctx context.Context, signature solana.Signature, opts *rpc.GetTransactionOpts) (*rpc.TransactionWithMeta, error)
- func (_m *SolanaRPCClient) GetHealth(ctx context.Context) (string, error)
- func (_m *SolanaRPCClient) GetLatestBlockhash(ctx context.Context, commitment rpc.CommitmentType) (*rpc.GetLatestBlockhashResult, error)
- func (_m *SolanaRPCClient) GetRecentPrioritizationFees(ctx context.Context, accounts solana.PublicKeySlice) ([]rpc.PriorizationFeeResult, error)
- func (_m *SolanaRPCClient) GetSignaturesForAddressWithOpts(ctx context.Context, account solana.PublicKey, ...) ([]*rpc.TransactionSignature, error)
- func (_m *SolanaRPCClient) GetSlot(ctx context.Context, commitment rpc.CommitmentType) (uint64, error)
- func (_m *SolanaRPCClient) GetTransaction(ctx context.Context, txSig solana.Signature, opts *rpc.GetTransactionOpts) (*rpc.GetTransactionResult, error)
- func (_m *SolanaRPCClient) GetVersion(ctx context.Context) (*rpc.GetVersionResult, error)
- func (_m *SolanaRPCClient) SendTransactionWithOpts(ctx context.Context, transaction *solana.Transaction, opts rpc.TransactionOpts) (solana.Signature, error)
- type SolanaSigner
- type TONObserver
- type TONSigner
- type TSS
- func (s *TSS) BTCAddress(_ int64) (*btcutil.AddressWitnessPubKeyHash, error)
- func (s *TSS) EVMAddress() ethcommon.Address
- func (s *TSS) EVMAddressList() []ethcommon.Address
- func (s *TSS) Pause()
- func (s *TSS) PubKeyCompressedBytes() []byte
- func (s *TSS) Pubkey() []byte
- func (s *TSS) Sign(_ context.Context, data []byte, _ uint64, _ uint64, _ int64, _ string) ([65]byte, error)
- func (s *TSS) SignBatch(_ context.Context, _ [][]byte, _ uint64, _ uint64, _ int64) ([][65]byte, error)
- func (s *TSS) Unpause()
- func (s *TSS) WithPrivKey(privKey *ecdsa.PrivateKey) *TSS
- type ZetacoreClient
- func (_m *ZetacoreClient) Chain() chains.Chain
- func (_m *ZetacoreClient) GetAdditionalChains(ctx context.Context) ([]chains.Chain, error)
- func (_m *ZetacoreClient) GetAllOutboundTrackerByChain(ctx context.Context, chainID int64, order interfaces.Order) ([]types.OutboundTracker, error)
- func (_m *ZetacoreClient) GetBTCTSSAddress(ctx context.Context, chainID int64) (string, error)
- func (_m *ZetacoreClient) GetBlockHeight(ctx context.Context) (int64, error)
- func (_m *ZetacoreClient) GetCctxByNonce(ctx context.Context, chainID int64, nonce uint64) (*types.CrossChainTx, error)
- func (_m *ZetacoreClient) GetChainParams(ctx context.Context) ([]*observertypes.ChainParams, error)
- func (_m *ZetacoreClient) GetCrosschainFlags(ctx context.Context) (observertypes.CrosschainFlags, error)
- func (_m *ZetacoreClient) GetInboundTrackersForChain(ctx context.Context, chainID int64) ([]types.InboundTracker, error)
- func (_m *ZetacoreClient) GetKeyGen(ctx context.Context) (observertypes.Keygen, error)
- func (_m *ZetacoreClient) GetKeys() keysinterfaces.ObserverKeys
- func (_m *ZetacoreClient) GetLogger() *zerolog.Logger
- func (_m *ZetacoreClient) GetObserverList(ctx context.Context) ([]string, error)
- func (_m *ZetacoreClient) GetOutboundTracker(ctx context.Context, chain chains.Chain, nonce uint64) (*types.OutboundTracker, error)
- func (_m *ZetacoreClient) GetPendingNoncesByChain(ctx context.Context, chainID int64) (observertypes.PendingNonces, error)
- func (_m *ZetacoreClient) GetRateLimiterFlags(ctx context.Context) (types.RateLimiterFlags, error)
- func (_m *ZetacoreClient) GetRateLimiterInput(ctx context.Context, window int64) (*types.QueryRateLimiterInputResponse, error)
- func (_m *ZetacoreClient) GetSupportedChains(ctx context.Context) ([]chains.Chain, error)
- func (_m *ZetacoreClient) GetTSS(ctx context.Context) (observertypes.TSS, error)
- func (_m *ZetacoreClient) GetTSSHistory(ctx context.Context) ([]observertypes.TSS, error)
- func (_m *ZetacoreClient) GetUpgradePlan(ctx context.Context) (*upgradetypes.Plan, error)
- func (_m *ZetacoreClient) GetZetaHotKeyBalance(ctx context.Context) (math.Int, error)
- func (_m *ZetacoreClient) ListPendingCCTX(ctx context.Context, chainID int64) ([]*types.CrossChainTx, uint64, error)
- func (_m *ZetacoreClient) ListPendingCCTXWithinRateLimit(ctx context.Context) (*types.QueryListPendingCctxWithinRateLimitResponse, error)
- func (_m *ZetacoreClient) PostOutboundTracker(ctx context.Context, chainID int64, nonce uint64, txHash string) (string, error)
- func (_m *ZetacoreClient) PostVoteBlameData(ctx context.Context, _a1 *blame.Blame, chainID int64, index string) (string, error)
- func (_m *ZetacoreClient) PostVoteGasPrice(ctx context.Context, chain chains.Chain, gasPrice uint64, priorityFee uint64, ...) (string, error)
- func (_m *ZetacoreClient) PostVoteInbound(ctx context.Context, gasLimit uint64, retryGasLimit uint64, ...) (string, string, error)
- func (_m *ZetacoreClient) PostVoteOutbound(ctx context.Context, gasLimit uint64, retryGasLimit uint64, ...) (string, string, error)
- func (_m *ZetacoreClient) WithKeys(keys keyinterfaces.ObserverKeys) *ZetacoreClient
- func (_m *ZetacoreClient) WithPendingCctx(chainID int64, cctxs []*crosschaintypes.CrossChainTx) *ZetacoreClient
- func (_m *ZetacoreClient) WithPostVoteInbound(zetaTxHash string, ballotIndex string) *ZetacoreClient
- func (_m *ZetacoreClient) WithPostVoteOutbound(zetaTxHash string, ballotIndex string) *ZetacoreClient
- func (_m *ZetacoreClient) WithRateLimiterFlags(flags *crosschaintypes.RateLimiterFlags) *ZetacoreClient
- func (_m *ZetacoreClient) WithRateLimiterInput(in *crosschaintypes.QueryRateLimiterInputResponse) *ZetacoreClient
- func (_m *ZetacoreClient) WithZetaChain() *ZetacoreClient
Constants ¶
This section is empty.
Variables ¶
var TestKeyringPair cryptotypes.PrivKey
var TestPrivateKey *ecdsa.PrivateKey
TestPrivateKey is a random private key for testing
Functions ¶
func MockChainParams ¶
func MockChainParams(chainID int64, confirmation uint64) observertypes.ChainParams
func MockConnectorNonEth ¶
func MockERC20Custody ¶
func NewKeyring ¶
Types ¶
type BTCObserver ¶
type BTCObserver struct { DummyObserver // contains filtered or unexported fields }
BTCObserver is a mock of btc chain observer for testing
func NewBTCObserver ¶
func NewBTCObserver(chainParams *observertypes.ChainParams) *BTCObserver
func (*BTCObserver) ChainParams ¶
func (ob *BTCObserver) ChainParams() observertypes.ChainParams
func (*BTCObserver) SetChainParams ¶
func (ob *BTCObserver) SetChainParams(chainParams observertypes.ChainParams)
type BTCRPCClient ¶
BTCRPCClient is an autogenerated mock type for the BTCRPCClient type
func NewBTCRPCClient ¶
func NewBTCRPCClient(t interface { mock.TestingT Cleanup(func()) }) *BTCRPCClient
NewBTCRPCClient creates a new instance of BTCRPCClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*BTCRPCClient) CreateWallet ¶
func (_m *BTCRPCClient) CreateWallet(name string, opts ...rpcclient.CreateWalletOpt) (*btcjson.CreateWalletResult, error)
CreateWallet provides a mock function with given fields: name, opts
func (*BTCRPCClient) EstimateSmartFee ¶
func (_m *BTCRPCClient) EstimateSmartFee(confTarget int64, mode *btcjson.EstimateSmartFeeMode) (*btcjson.EstimateSmartFeeResult, error)
EstimateSmartFee provides a mock function with given fields: confTarget, mode
func (*BTCRPCClient) GenerateToAddress ¶
func (_m *BTCRPCClient) GenerateToAddress(numBlocks int64, address btcutil.Address, maxTries *int64) ([]*chainhash.Hash, error)
GenerateToAddress provides a mock function with given fields: numBlocks, address, maxTries
func (*BTCRPCClient) GetBalance ¶
func (_m *BTCRPCClient) GetBalance(account string) (btcutil.Amount, error)
GetBalance provides a mock function with given fields: account
func (*BTCRPCClient) GetBlockCount ¶
func (_m *BTCRPCClient) GetBlockCount() (int64, error)
GetBlockCount provides a mock function with given fields:
func (*BTCRPCClient) GetBlockHash ¶
func (_m *BTCRPCClient) GetBlockHash(blockHeight int64) (*chainhash.Hash, error)
GetBlockHash provides a mock function with given fields: blockHeight
func (*BTCRPCClient) GetBlockHeader ¶
func (_m *BTCRPCClient) GetBlockHeader(blockHash *chainhash.Hash) (*wire.BlockHeader, error)
GetBlockHeader provides a mock function with given fields: blockHash
func (*BTCRPCClient) GetBlockVerbose ¶
func (_m *BTCRPCClient) GetBlockVerbose(blockHash *chainhash.Hash) (*btcjson.GetBlockVerboseResult, error)
GetBlockVerbose provides a mock function with given fields: blockHash
func (*BTCRPCClient) GetBlockVerboseTx ¶
func (_m *BTCRPCClient) GetBlockVerboseTx(blockHash *chainhash.Hash) (*btcjson.GetBlockVerboseTxResult, error)
GetBlockVerboseTx provides a mock function with given fields: blockHash
func (*BTCRPCClient) GetNetworkInfo ¶
func (_m *BTCRPCClient) GetNetworkInfo() (*btcjson.GetNetworkInfoResult, error)
GetNetworkInfo provides a mock function with given fields:
func (*BTCRPCClient) GetNewAddress ¶
func (_m *BTCRPCClient) GetNewAddress(account string) (btcutil.Address, error)
GetNewAddress provides a mock function with given fields: account
func (*BTCRPCClient) GetRawTransaction ¶
GetRawTransaction provides a mock function with given fields: txHash
func (*BTCRPCClient) GetRawTransactionVerbose ¶
func (_m *BTCRPCClient) GetRawTransactionVerbose(txHash *chainhash.Hash) (*btcjson.TxRawResult, error)
GetRawTransactionVerbose provides a mock function with given fields: txHash
func (*BTCRPCClient) GetTransaction ¶
func (_m *BTCRPCClient) GetTransaction(txHash *chainhash.Hash) (*btcjson.GetTransactionResult, error)
GetTransaction provides a mock function with given fields: txHash
func (*BTCRPCClient) ListUnspent ¶
func (_m *BTCRPCClient) ListUnspent() ([]btcjson.ListUnspentResult, error)
ListUnspent provides a mock function with given fields:
func (*BTCRPCClient) ListUnspentMinMaxAddresses ¶
func (_m *BTCRPCClient) ListUnspentMinMaxAddresses(minConf int, maxConf int, addrs []btcutil.Address) ([]btcjson.ListUnspentResult, error)
ListUnspentMinMaxAddresses provides a mock function with given fields: minConf, maxConf, addrs
func (*BTCRPCClient) SendRawTransaction ¶
func (_m *BTCRPCClient) SendRawTransaction(tx *wire.MsgTx, allowHighFees bool) (*chainhash.Hash, error)
SendRawTransaction provides a mock function with given fields: tx, allowHighFees
type BTCSigner ¶
type BTCSigner = DummySigner
BTCSigner is a mock of bitcoin chain signer for testing
func NewBTCSigner ¶
func NewBTCSigner() *BTCSigner
type CometBFTClient ¶
func NewSDKClientWithErr ¶
func NewSDKClientWithErr(t *testing.T, err error, code uint32) *CometBFTClient
func (*CometBFTClient) Block ¶
func (c *CometBFTClient) Block(_ context.Context, _ *int64) (*coretypes.ResultBlock, error)
func (*CometBFTClient) BroadcastTxAsync ¶
func (c *CometBFTClient) BroadcastTxAsync(_ context.Context, _ tmtypes.Tx) (*coretypes.ResultBroadcastTx, error)
func (*CometBFTClient) BroadcastTxCommit ¶
func (c *CometBFTClient) BroadcastTxCommit( _ context.Context, _ tmtypes.Tx, ) (*coretypes.ResultBroadcastTxCommit, error)
func (*CometBFTClient) BroadcastTxSync ¶
func (c *CometBFTClient) BroadcastTxSync(_ context.Context, _ tmtypes.Tx) (*coretypes.ResultBroadcastTx, error)
func (*CometBFTClient) SetBroadcastTxHash ¶
func (c *CometBFTClient) SetBroadcastTxHash(hash string) *CometBFTClient
func (*CometBFTClient) SetError ¶
func (c *CometBFTClient) SetError(err error) *CometBFTClient
type DummyObserver ¶
type DummyObserver struct{}
func (*DummyObserver) ChainParams ¶
func (ob *DummyObserver) ChainParams() (_ observertypes.ChainParams)
func (*DummyObserver) SetChainParams ¶
func (ob *DummyObserver) SetChainParams(_ observertypes.ChainParams)
func (*DummyObserver) Start ¶
func (ob *DummyObserver) Start(_ context.Context)
func (*DummyObserver) Stop ¶
func (ob *DummyObserver) Stop()
func (*DummyObserver) VoteOutboundIfConfirmed ¶
func (ob *DummyObserver) VoteOutboundIfConfirmed(_ context.Context, _ *cc.CrossChainTx) (bool, error)
type DummySigner ¶
type DummySigner struct{}
func (*DummySigner) GetERC20CustodyAddress ¶
func (s *DummySigner) GetERC20CustodyAddress() (_ ethcommon.Address)
func (*DummySigner) GetGatewayAddress ¶
func (s *DummySigner) GetGatewayAddress() (_ string)
func (*DummySigner) GetZetaConnectorAddress ¶
func (s *DummySigner) GetZetaConnectorAddress() (_ ethcommon.Address)
func (*DummySigner) SetERC20CustodyAddress ¶
func (s *DummySigner) SetERC20CustodyAddress(_ ethcommon.Address)
func (*DummySigner) SetGatewayAddress ¶
func (s *DummySigner) SetGatewayAddress(_ string)
func (*DummySigner) SetZetaConnectorAddress ¶
func (s *DummySigner) SetZetaConnectorAddress(_ ethcommon.Address)
func (*DummySigner) TryProcessOutbound ¶
func (s *DummySigner) TryProcessOutbound( _ context.Context, _ *crosschaintypes.CrossChainTx, _ *outboundprocessor.Processor, _ string, _ interfaces.ChainObserver, _ interfaces.ZetacoreClient, _ uint64, )
type EVMObserver ¶
type EVMObserver struct { DummyObserver // contains filtered or unexported fields }
EVMObserver is a mock of evm chain observer for testing
func NewEVMObserver ¶
func NewEVMObserver(chainParams *observertypes.ChainParams) *EVMObserver
func (*EVMObserver) ChainParams ¶
func (ob *EVMObserver) ChainParams() observertypes.ChainParams
func (*EVMObserver) SetChainParams ¶
func (ob *EVMObserver) SetChainParams(chainParams observertypes.ChainParams)
type EVMRPCClient ¶
EVMRPCClient is an autogenerated mock type for the EVMRPCClient type
func NewEVMRPCClient ¶
func NewEVMRPCClient(t interface { mock.TestingT Cleanup(func()) }) *EVMRPCClient
NewEVMRPCClient creates a new instance of EVMRPCClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*EVMRPCClient) BlockByNumber ¶
BlockByNumber provides a mock function with given fields: ctx, number
func (*EVMRPCClient) BlockNumber ¶
func (_m *EVMRPCClient) BlockNumber(ctx context.Context) (uint64, error)
BlockNumber provides a mock function with given fields: ctx
func (*EVMRPCClient) CallContract ¶
func (_m *EVMRPCClient) CallContract(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)
CallContract provides a mock function with given fields: ctx, call, blockNumber
func (*EVMRPCClient) CodeAt ¶
func (_m *EVMRPCClient) CodeAt(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)
CodeAt provides a mock function with given fields: ctx, contract, blockNumber
func (*EVMRPCClient) EstimateGas ¶
EstimateGas provides a mock function with given fields: ctx, call
func (*EVMRPCClient) FilterLogs ¶
func (_m *EVMRPCClient) FilterLogs(ctx context.Context, query ethereum.FilterQuery) ([]types.Log, error)
FilterLogs provides a mock function with given fields: ctx, query
func (*EVMRPCClient) HeaderByNumber ¶
HeaderByNumber provides a mock function with given fields: ctx, number
func (*EVMRPCClient) PendingCodeAt ¶
PendingCodeAt provides a mock function with given fields: ctx, account
func (*EVMRPCClient) PendingNonceAt ¶
PendingNonceAt provides a mock function with given fields: ctx, account
func (*EVMRPCClient) SendTransaction ¶
func (_m *EVMRPCClient) SendTransaction(ctx context.Context, tx *types.Transaction) error
SendTransaction provides a mock function with given fields: ctx, tx
func (*EVMRPCClient) SubscribeFilterLogs ¶
func (_m *EVMRPCClient) SubscribeFilterLogs(ctx context.Context, query ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)
SubscribeFilterLogs provides a mock function with given fields: ctx, query, ch
func (*EVMRPCClient) SuggestGasPrice ¶
SuggestGasPrice provides a mock function with given fields: ctx
func (*EVMRPCClient) SuggestGasTipCap ¶
SuggestGasTipCap provides a mock function with given fields: ctx
func (*EVMRPCClient) TransactionByHash ¶
func (_m *EVMRPCClient) TransactionByHash(ctx context.Context, hash common.Hash) (*types.Transaction, bool, error)
TransactionByHash provides a mock function with given fields: ctx, hash
func (*EVMRPCClient) TransactionReceipt ¶
func (_m *EVMRPCClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
TransactionReceipt provides a mock function with given fields: ctx, txHash
func (*EVMRPCClient) TransactionSender ¶
func (_m *EVMRPCClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)
TransactionSender provides a mock function with given fields: ctx, tx, block, index
type EVMSigner ¶
type EVMSigner struct { DummySigner Chain chains.Chain ZetaConnectorAddress ethcommon.Address ERC20CustodyAddress ethcommon.Address }
EVMSigner is a mock of evm chain signer for testing
func NewEVMSigner ¶
func (*EVMSigner) GetERC20CustodyAddress ¶
func (*EVMSigner) GetZetaConnectorAddress ¶
func (*EVMSigner) SetERC20CustodyAddress ¶
func (*EVMSigner) SetZetaConnectorAddress ¶
type Keyring ¶
type Keyring struct { }
func (Keyring) ExportPrivKeyArmor ¶
func (Keyring) ExportPrivKeyArmorByAddress ¶
func (Keyring) ExportPubKeyArmorByAddress ¶
func (Keyring) ImportPrivKey ¶
func (Keyring) ImportPrivKeyHex ¶
func (Keyring) NewAccount ¶
func (Keyring) NewMnemonic ¶
func (Keyring) SaveLedgerKey ¶
func (Keyring) SaveMultisig ¶
func (Keyring) SaveOfflineKey ¶
func (Keyring) SignByAddress ¶
func (Keyring) SupportedAlgorithms ¶
func (m Keyring) SupportedAlgorithms() (ckeys.SigningAlgoList, ckeys.SigningAlgoList)
type LiteClient ¶
LiteClient is an autogenerated mock type for the LiteClient type
func NewLiteClient ¶
func NewLiteClient(t interface { mock.TestingT Cleanup(func()) }) *LiteClient
NewLiteClient creates a new instance of LiteClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*LiteClient) GetBlockHeader ¶
func (_m *LiteClient) GetBlockHeader(ctx context.Context, blockID ton.BlockIDExt, mode uint32) (tlb.BlockInfo, error)
GetBlockHeader provides a mock function with given fields: ctx, blockID, mode
func (*LiteClient) GetConfigParams ¶
func (_m *LiteClient) GetConfigParams(ctx context.Context, mode liteapi.ConfigMode, params []uint32) (tlb.ConfigParams, error)
GetConfigParams provides a mock function with given fields: ctx, mode, params
func (*LiteClient) GetFirstTransaction ¶
func (_m *LiteClient) GetFirstTransaction(ctx context.Context, acc ton.AccountID) (*ton.Transaction, int, error)
GetFirstTransaction provides a mock function with given fields: ctx, acc
func (*LiteClient) GetMasterchainInfo ¶
func (_m *LiteClient) GetMasterchainInfo(ctx context.Context) (liteclient.LiteServerMasterchainInfoC, error)
GetMasterchainInfo provides a mock function with given fields: ctx
func (*LiteClient) GetTransaction ¶
func (_m *LiteClient) GetTransaction(ctx context.Context, acc ton.AccountID, lt uint64, hash ton.Bits256) (ton.Transaction, error)
GetTransaction provides a mock function with given fields: ctx, acc, lt, hash
func (*LiteClient) GetTransactionsSince ¶
func (_m *LiteClient) GetTransactionsSince(ctx context.Context, acc ton.AccountID, lt uint64, hash ton.Bits256) ([]ton.Transaction, error)
GetTransactionsSince provides a mock function with given fields: ctx, acc, lt, hash
type MockJSONRPCClient ¶
type MockJSONRPCClient struct { Blocks []*ethrpc.Block Transactions []*ethrpc.Transaction }
MockJSONRPCClient is a mock implementation of the EVMJSONRPCClient interface
func NewMockJSONRPCClient ¶
func NewMockJSONRPCClient() *MockJSONRPCClient
NewMockJSONRPCClient creates a new mock JSON RPC client
func (*MockJSONRPCClient) EthGetBlockByNumber ¶
EthGetBlockByNumber returns a pre-loaded block or nil
func (*MockJSONRPCClient) EthGetTransactionByHash ¶
func (e *MockJSONRPCClient) EthGetTransactionByHash(_ string) (*ethrpc.Transaction, error)
EthGetTransactionByHash returns a pre-loaded transaction or nil
func (*MockJSONRPCClient) Reset ¶
func (e *MockJSONRPCClient) Reset() *MockJSONRPCClient
Reset clears the mock data
func (*MockJSONRPCClient) WithBlock ¶
func (e *MockJSONRPCClient) WithBlock(block *ethrpc.Block) *MockJSONRPCClient
---------------------------------------------------------------------------- Feed data to the mock JSON RPC client for testing ----------------------------------------------------------------------------
func (*MockJSONRPCClient) WithBlocks ¶
func (e *MockJSONRPCClient) WithBlocks(blocks []*ethrpc.Block) *MockJSONRPCClient
func (*MockJSONRPCClient) WithTransaction ¶
func (e *MockJSONRPCClient) WithTransaction(tx *ethrpc.Transaction) *MockJSONRPCClient
func (*MockJSONRPCClient) WithTransactions ¶
func (e *MockJSONRPCClient) WithTransactions(txs []*ethrpc.Transaction) *MockJSONRPCClient
type SignerLiteClient ¶
SignerLiteClient is an autogenerated mock type for the LiteClient type
func NewSignerLiteClient ¶
func NewSignerLiteClient(t interface { mock.TestingT Cleanup(func()) }) *SignerLiteClient
NewSignerLiteClient creates a new instance of SignerLiteClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SignerLiteClient) GetAccountState ¶
func (_m *SignerLiteClient) GetAccountState(ctx context.Context, accountID ton.AccountID) (tlb.ShardAccount, error)
GetAccountState provides a mock function with given fields: ctx, accountID
func (*SignerLiteClient) GetTransactionsSince ¶
func (_m *SignerLiteClient) GetTransactionsSince(ctx context.Context, acc ton.AccountID, lt uint64, hash ton.Bits256) ([]ton.Transaction, error)
GetTransactionsSince provides a mock function with given fields: ctx, acc, lt, hash
func (*SignerLiteClient) SendMessage ¶
SendMessage provides a mock function with given fields: ctx, payload
type SolanaObserver ¶
type SolanaObserver struct { DummyObserver // contains filtered or unexported fields }
SolanaObserver is a mock of solana chain observer for testing
func NewSolanaObserver ¶
func NewSolanaObserver(chainParams *observertypes.ChainParams) *SolanaObserver
func (*SolanaObserver) ChainParams ¶
func (ob *SolanaObserver) ChainParams() observertypes.ChainParams
func (*SolanaObserver) SetChainParams ¶
func (ob *SolanaObserver) SetChainParams(chainParams observertypes.ChainParams)
type SolanaRPCClient ¶
SolanaRPCClient is an autogenerated mock type for the SolanaRPCClient type
func NewSolanaRPCClient ¶
func NewSolanaRPCClient(t interface { mock.TestingT Cleanup(func()) }) *SolanaRPCClient
NewSolanaRPCClient creates a new instance of SolanaRPCClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SolanaRPCClient) GetAccountInfo ¶
func (_m *SolanaRPCClient) GetAccountInfo(ctx context.Context, account solana.PublicKey) (*rpc.GetAccountInfoResult, error)
GetAccountInfo provides a mock function with given fields: ctx, account
func (*SolanaRPCClient) GetBalance ¶
func (_m *SolanaRPCClient) GetBalance(ctx context.Context, account solana.PublicKey, commitment rpc.CommitmentType) (*rpc.GetBalanceResult, error)
GetBalance provides a mock function with given fields: ctx, account, commitment
func (*SolanaRPCClient) GetBlockTime ¶
func (_m *SolanaRPCClient) GetBlockTime(ctx context.Context, block uint64) (*solana.UnixTimeSeconds, error)
GetBlockTime provides a mock function with given fields: ctx, block
func (*SolanaRPCClient) GetConfirmedTransactionWithOpts ¶
func (_m *SolanaRPCClient) GetConfirmedTransactionWithOpts(ctx context.Context, signature solana.Signature, opts *rpc.GetTransactionOpts) (*rpc.TransactionWithMeta, error)
GetConfirmedTransactionWithOpts provides a mock function with given fields: ctx, signature, opts
func (*SolanaRPCClient) GetHealth ¶
func (_m *SolanaRPCClient) GetHealth(ctx context.Context) (string, error)
GetHealth provides a mock function with given fields: ctx
func (*SolanaRPCClient) GetLatestBlockhash ¶
func (_m *SolanaRPCClient) GetLatestBlockhash(ctx context.Context, commitment rpc.CommitmentType) (*rpc.GetLatestBlockhashResult, error)
GetLatestBlockhash provides a mock function with given fields: ctx, commitment
func (*SolanaRPCClient) GetRecentPrioritizationFees ¶
func (_m *SolanaRPCClient) GetRecentPrioritizationFees(ctx context.Context, accounts solana.PublicKeySlice) ([]rpc.PriorizationFeeResult, error)
GetRecentPrioritizationFees provides a mock function with given fields: ctx, accounts
func (*SolanaRPCClient) GetSignaturesForAddressWithOpts ¶
func (_m *SolanaRPCClient) GetSignaturesForAddressWithOpts(ctx context.Context, account solana.PublicKey, opts *rpc.GetSignaturesForAddressOpts) ([]*rpc.TransactionSignature, error)
GetSignaturesForAddressWithOpts provides a mock function with given fields: ctx, account, opts
func (*SolanaRPCClient) GetSlot ¶
func (_m *SolanaRPCClient) GetSlot(ctx context.Context, commitment rpc.CommitmentType) (uint64, error)
GetSlot provides a mock function with given fields: ctx, commitment
func (*SolanaRPCClient) GetTransaction ¶
func (_m *SolanaRPCClient) GetTransaction(ctx context.Context, txSig solana.Signature, opts *rpc.GetTransactionOpts) (*rpc.GetTransactionResult, error)
GetTransaction provides a mock function with given fields: ctx, txSig, opts
func (*SolanaRPCClient) GetVersion ¶
func (_m *SolanaRPCClient) GetVersion(ctx context.Context) (*rpc.GetVersionResult, error)
GetVersion provides a mock function with given fields: ctx
func (*SolanaRPCClient) SendTransactionWithOpts ¶
func (_m *SolanaRPCClient) SendTransactionWithOpts(ctx context.Context, transaction *solana.Transaction, opts rpc.TransactionOpts) (solana.Signature, error)
SendTransactionWithOpts provides a mock function with given fields: ctx, transaction, opts
type SolanaSigner ¶
type SolanaSigner struct { DummySigner GatewayAddress string }
SolanaSigner is a mock of solana chain signer for testing
func NewSolanaSigner ¶
func NewSolanaSigner() *SolanaSigner
func (*SolanaSigner) GetGatewayAddress ¶
func (s *SolanaSigner) GetGatewayAddress() string
func (*SolanaSigner) SetGatewayAddress ¶
func (s *SolanaSigner) SetGatewayAddress(address string)
type TONObserver ¶
type TONObserver struct { DummyObserver // contains filtered or unexported fields }
TONObserver is a mock of TON chain observer for testing
func NewTONObserver ¶
func NewTONObserver(chainParams *observertypes.ChainParams) *TONObserver
func (*TONObserver) ChainParams ¶
func (ob *TONObserver) ChainParams() observertypes.ChainParams
func (*TONObserver) SetChainParams ¶
func (ob *TONObserver) SetChainParams(chainParams observertypes.ChainParams)
type TONSigner ¶
type TONSigner struct { DummySigner GatewayAddress string }
TONSigner is a mock of TON chain signer for testing
func NewTONSigner ¶
func NewTONSigner() *TONSigner
func (*TONSigner) GetGatewayAddress ¶
func (*TONSigner) SetGatewayAddress ¶
type TSS ¶
type TSS struct { // set PrivKey if you want to use a specific private key PrivKey *ecdsa.PrivateKey // contains filtered or unexported fields }
TSS is a mock of TSS signer for testing
func NewDerivedTSS ¶
NewDerivedTSS creates a TSS where evmAddress and btcAdresses are always derived from the test private key
func NewTSSAthens3 ¶
func NewTSSAthens3() *TSS
func NewTSSMainnet ¶
func NewTSSMainnet() *TSS
func (*TSS) BTCAddress ¶
func (s *TSS) BTCAddress(_ int64) (*btcutil.AddressWitnessPubKeyHash, error)
func (*TSS) EVMAddress ¶
func (*TSS) EVMAddressList ¶
func (*TSS) Pause ¶
func (s *TSS) Pause()
---------------------------------------------------------------------------- methods to control the mock for testing ----------------------------------------------------------------------------
func (*TSS) PubKeyCompressedBytes ¶
PubKeyCompressedBytes returns 33B compressed pubkey
func (*TSS) Sign ¶
func (s *TSS) Sign(_ context.Context, data []byte, _ uint64, _ uint64, _ int64, _ string) ([65]byte, error)
Sign uses test key unrelated to any tss key in production
func (*TSS) SignBatch ¶
func (s *TSS) SignBatch(_ context.Context, _ [][]byte, _ uint64, _ uint64, _ int64) ([][65]byte, error)
SignBatch uses test key unrelated to any tss key in production
func (*TSS) WithPrivKey ¶
func (s *TSS) WithPrivKey(privKey *ecdsa.PrivateKey) *TSS
WithPrivKey sets the private key for the TSS
type ZetacoreClient ¶
ZetacoreClient is an autogenerated mock type for the ZetacoreClient type
func NewZetacoreClient ¶
func NewZetacoreClient(t interface { mock.TestingT Cleanup(func()) }) *ZetacoreClient
NewZetacoreClient creates a new instance of ZetacoreClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ZetacoreClient) Chain ¶
func (_m *ZetacoreClient) Chain() chains.Chain
Chain provides a mock function with given fields:
func (*ZetacoreClient) GetAdditionalChains ¶
GetAdditionalChains provides a mock function with given fields: ctx
func (*ZetacoreClient) GetAllOutboundTrackerByChain ¶
func (_m *ZetacoreClient) GetAllOutboundTrackerByChain(ctx context.Context, chainID int64, order interfaces.Order) ([]types.OutboundTracker, error)
GetAllOutboundTrackerByChain provides a mock function with given fields: ctx, chainID, order
func (*ZetacoreClient) GetBTCTSSAddress ¶
GetBTCTSSAddress provides a mock function with given fields: ctx, chainID
func (*ZetacoreClient) GetBlockHeight ¶
func (_m *ZetacoreClient) GetBlockHeight(ctx context.Context) (int64, error)
GetBlockHeight provides a mock function with given fields: ctx
func (*ZetacoreClient) GetCctxByNonce ¶
func (_m *ZetacoreClient) GetCctxByNonce(ctx context.Context, chainID int64, nonce uint64) (*types.CrossChainTx, error)
GetCctxByNonce provides a mock function with given fields: ctx, chainID, nonce
func (*ZetacoreClient) GetChainParams ¶
func (_m *ZetacoreClient) GetChainParams(ctx context.Context) ([]*observertypes.ChainParams, error)
GetChainParams provides a mock function with given fields: ctx
func (*ZetacoreClient) GetCrosschainFlags ¶
func (_m *ZetacoreClient) GetCrosschainFlags(ctx context.Context) (observertypes.CrosschainFlags, error)
GetCrosschainFlags provides a mock function with given fields: ctx
func (*ZetacoreClient) GetInboundTrackersForChain ¶
func (_m *ZetacoreClient) GetInboundTrackersForChain(ctx context.Context, chainID int64) ([]types.InboundTracker, error)
GetInboundTrackersForChain provides a mock function with given fields: ctx, chainID
func (*ZetacoreClient) GetKeyGen ¶
func (_m *ZetacoreClient) GetKeyGen(ctx context.Context) (observertypes.Keygen, error)
GetKeyGen provides a mock function with given fields: ctx
func (*ZetacoreClient) GetKeys ¶
func (_m *ZetacoreClient) GetKeys() keysinterfaces.ObserverKeys
GetKeys provides a mock function with given fields:
func (*ZetacoreClient) GetLogger ¶
func (_m *ZetacoreClient) GetLogger() *zerolog.Logger
GetLogger provides a mock function with given fields:
func (*ZetacoreClient) GetObserverList ¶
func (_m *ZetacoreClient) GetObserverList(ctx context.Context) ([]string, error)
GetObserverList provides a mock function with given fields: ctx
func (*ZetacoreClient) GetOutboundTracker ¶
func (_m *ZetacoreClient) GetOutboundTracker(ctx context.Context, chain chains.Chain, nonce uint64) (*types.OutboundTracker, error)
GetOutboundTracker provides a mock function with given fields: ctx, chain, nonce
func (*ZetacoreClient) GetPendingNoncesByChain ¶
func (_m *ZetacoreClient) GetPendingNoncesByChain(ctx context.Context, chainID int64) (observertypes.PendingNonces, error)
GetPendingNoncesByChain provides a mock function with given fields: ctx, chainID
func (*ZetacoreClient) GetRateLimiterFlags ¶
func (_m *ZetacoreClient) GetRateLimiterFlags(ctx context.Context) (types.RateLimiterFlags, error)
GetRateLimiterFlags provides a mock function with given fields: ctx
func (*ZetacoreClient) GetRateLimiterInput ¶
func (_m *ZetacoreClient) GetRateLimiterInput(ctx context.Context, window int64) (*types.QueryRateLimiterInputResponse, error)
GetRateLimiterInput provides a mock function with given fields: ctx, window
func (*ZetacoreClient) GetSupportedChains ¶
GetSupportedChains provides a mock function with given fields: ctx
func (*ZetacoreClient) GetTSS ¶
func (_m *ZetacoreClient) GetTSS(ctx context.Context) (observertypes.TSS, error)
GetTSS provides a mock function with given fields: ctx
func (*ZetacoreClient) GetTSSHistory ¶
func (_m *ZetacoreClient) GetTSSHistory(ctx context.Context) ([]observertypes.TSS, error)
GetTSSHistory provides a mock function with given fields: ctx
func (*ZetacoreClient) GetUpgradePlan ¶
func (_m *ZetacoreClient) GetUpgradePlan(ctx context.Context) (*upgradetypes.Plan, error)
GetUpgradePlan provides a mock function with given fields: ctx
func (*ZetacoreClient) GetZetaHotKeyBalance ¶
GetZetaHotKeyBalance provides a mock function with given fields: ctx
func (*ZetacoreClient) ListPendingCCTX ¶
func (_m *ZetacoreClient) ListPendingCCTX(ctx context.Context, chainID int64) ([]*types.CrossChainTx, uint64, error)
ListPendingCCTX provides a mock function with given fields: ctx, chainID
func (*ZetacoreClient) ListPendingCCTXWithinRateLimit ¶
func (_m *ZetacoreClient) ListPendingCCTXWithinRateLimit(ctx context.Context) (*types.QueryListPendingCctxWithinRateLimitResponse, error)
ListPendingCCTXWithinRateLimit provides a mock function with given fields: ctx
func (*ZetacoreClient) PostOutboundTracker ¶
func (_m *ZetacoreClient) PostOutboundTracker(ctx context.Context, chainID int64, nonce uint64, txHash string) (string, error)
PostOutboundTracker provides a mock function with given fields: ctx, chainID, nonce, txHash
func (*ZetacoreClient) PostVoteBlameData ¶
func (_m *ZetacoreClient) PostVoteBlameData(ctx context.Context, _a1 *blame.Blame, chainID int64, index string) (string, error)
PostVoteBlameData provides a mock function with given fields: ctx, _a1, chainID, index
func (*ZetacoreClient) PostVoteGasPrice ¶
func (_m *ZetacoreClient) PostVoteGasPrice(ctx context.Context, chain chains.Chain, gasPrice uint64, priorityFee uint64, blockNum uint64) (string, error)
PostVoteGasPrice provides a mock function with given fields: ctx, chain, gasPrice, priorityFee, blockNum
func (*ZetacoreClient) PostVoteInbound ¶
func (_m *ZetacoreClient) PostVoteInbound(ctx context.Context, gasLimit uint64, retryGasLimit uint64, msg *types.MsgVoteInbound) (string, string, error)
PostVoteInbound provides a mock function with given fields: ctx, gasLimit, retryGasLimit, msg
func (*ZetacoreClient) PostVoteOutbound ¶
func (_m *ZetacoreClient) PostVoteOutbound(ctx context.Context, gasLimit uint64, retryGasLimit uint64, msg *types.MsgVoteOutbound) (string, string, error)
PostVoteOutbound provides a mock function with given fields: ctx, gasLimit, retryGasLimit, msg
func (*ZetacoreClient) WithKeys ¶
func (_m *ZetacoreClient) WithKeys(keys keyinterfaces.ObserverKeys) *ZetacoreClient
func (*ZetacoreClient) WithPendingCctx ¶
func (_m *ZetacoreClient) WithPendingCctx(chainID int64, cctxs []*crosschaintypes.CrossChainTx) *ZetacoreClient
func (*ZetacoreClient) WithPostVoteInbound ¶
func (_m *ZetacoreClient) WithPostVoteInbound(zetaTxHash string, ballotIndex string) *ZetacoreClient
func (*ZetacoreClient) WithPostVoteOutbound ¶
func (_m *ZetacoreClient) WithPostVoteOutbound(zetaTxHash string, ballotIndex string) *ZetacoreClient
func (*ZetacoreClient) WithRateLimiterFlags ¶
func (_m *ZetacoreClient) WithRateLimiterFlags(flags *crosschaintypes.RateLimiterFlags) *ZetacoreClient
func (*ZetacoreClient) WithRateLimiterInput ¶
func (_m *ZetacoreClient) WithRateLimiterInput(in *crosschaintypes.QueryRateLimiterInputResponse) *ZetacoreClient
func (*ZetacoreClient) WithZetaChain ¶
func (_m *ZetacoreClient) WithZetaChain() *ZetacoreClient