terra

Mar 24, 2022

Changes in this version

+ const GasCacheTransactions

+ const GasLimit

+ const GasPriceFactor

+ const GasUpdatePeriodBlocks

+ var CosmosAssetMappings = []CosmosAssetMapping

+ var CosmosSuccessCodes = map[uint32]bool

+ var ErrEmptyTx = errors.New("empty tx")

+ var ErrInvalidMetrics = errors.New("metrics is empty or nil")

+ var ErrInvalidScanStorage = errors.New("scan storage is empty or nil")

+ type CosmosAssetMapping struct

+ CosmosDecimals int

+ CosmosDenom string

+ THORChainSymbol string

+ func GetAssetByCosmosDenom(denom string) (CosmosAssetMapping, bool)

+ func GetAssetByThorchainSymbol(symbol string) (CosmosAssetMapping, bool)

+ type CosmosBlockScanner struct

+ func NewCosmosBlockScanner(cfg config.BlockScannerConfiguration, scanStorage blockscanner.ScannerStorage, ...) (*CosmosBlockScanner, error)

+ func (c *CosmosBlockScanner) FetchMemPool(height int64) (types.TxIn, error)

+ func (c *CosmosBlockScanner) FetchTxs(height int64) (types.TxIn, error)

+ func (c *CosmosBlockScanner) GetBlock(height int64) (*tmtypes.Block, error)

+ func (c *CosmosBlockScanner) GetHeight() (int64, error)

+ type CosmosClient struct

+ func NewCosmosClient(thorKeys *thorclient.Keys, cfg config.ChainConfiguration, ...) (*CosmosClient, error)

+ func (c *CosmosClient) BroadcastTx(tx stypes.TxOutItem, txBytes []byte) (string, error)

+ func (c *CosmosClient) ConfirmationCountReady(txIn stypes.TxIn) bool

+ func (c *CosmosClient) GetAccount(pkey common.PubKey, _ *big.Int) (common.Account, error)

+ func (c *CosmosClient) GetAccountByAddress(address string, _ *big.Int) (common.Account, error)

+ func (c *CosmosClient) GetAddress(poolPubKey common.PubKey) string

+ func (c *CosmosClient) GetChain() common.Chain

+ func (c *CosmosClient) GetConfig() config.ChainConfiguration

+ func (c *CosmosClient) GetConfirmationCount(txIn stypes.TxIn) int64

+ func (c *CosmosClient) GetHeight() (int64, error)

+ func (c *CosmosClient) IsBlockScannerHealthy() bool

+ func (c *CosmosClient) OnObservedTxIn(txIn stypes.TxInItem, blockHeight int64)

+ func (c *CosmosClient) ReportSolvency(blockHeight int64) error

+ func (c *CosmosClient) ShouldReportSolvency(height int64) bool

+ func (c *CosmosClient) SignTx(tx stypes.TxOutItem, thorchainHeight int64) (signedTx []byte, err error)

+ func (c *CosmosClient) Start(globalTxsQueue chan stypes.TxIn, globalErrataQueue chan stypes.ErrataBlock, ...)

+ func (c *CosmosClient) Stop()

+ type CosmosMetaDataStore struct

+ func NewCosmosMetaDataStore() *CosmosMetaDataStore

+ func (b *CosmosMetaDataStore) Get(pk common.PubKey) CosmosMetadata

+ func (b *CosmosMetaDataStore) GetByAccount(acct int64) CosmosMetadata

+ func (b *CosmosMetaDataStore) SeqInc(pk common.PubKey)

+ func (b *CosmosMetaDataStore) Set(pk common.PubKey, meta CosmosMetadata)

+ type CosmosMetadata struct

+ AccountNumber int64

+ BlockHeight int64

+ SeqNumber int64

+ type MockAccountServiceClient interface

+ Account func(ctx context.Context, in *atypes.QueryAccountRequest, opts ...grpc.CallOption) (*atypes.QueryAccountResponse, error)

+ Accounts func(ctx context.Context, in *atypes.QueryAccountsRequest, opts ...grpc.CallOption) (*atypes.QueryAccountsResponse, error)

+ Params func(ctx context.Context, in *atypes.QueryParamsRequest, opts ...grpc.CallOption) (*atypes.QueryParamsResponse, error)

+ func NewMockAccountServiceClient() MockAccountServiceClient

+ type MockBankServiceClient interface

+ AllBalances func(ctx context.Context, in *btypes.QueryAllBalancesRequest, ...) (*btypes.QueryAllBalancesResponse, error)

+ Balance func(ctx context.Context, in *btypes.QueryBalanceRequest, opts ...grpc.CallOption) (*btypes.QueryBalanceResponse, error)

+ DenomMetadata func(ctx context.Context, in *btypes.QueryDenomMetadataRequest, ...) (*btypes.QueryDenomMetadataResponse, error)

+ DenomsMetadata func(ctx context.Context, in *btypes.QueryDenomsMetadataRequest, ...) (*btypes.QueryDenomsMetadataResponse, error)

+ Params func(ctx context.Context, in *btypes.QueryParamsRequest, opts ...grpc.CallOption) (*btypes.QueryParamsResponse, error)

+ SupplyOf func(ctx context.Context, in *btypes.QuerySupplyOfRequest, opts ...grpc.CallOption) (*btypes.QuerySupplyOfResponse, error)

+ TotalSupply func(ctx context.Context, in *btypes.QueryTotalSupplyRequest, ...) (*btypes.QueryTotalSupplyResponse, error)

+ func NewMockBankServiceClient() MockBankServiceClient

+ type MockTmServiceClient interface

+ GetBlockByHeight func(ctx context.Context, in *tmservice.GetBlockByHeightRequest, ...) (*tmservice.GetBlockByHeightResponse, error)

+ GetLatestBlock func(ctx context.Context, in *tmservice.GetLatestBlockRequest, ...) (*tmservice.GetLatestBlockResponse, error)

+ GetLatestValidatorSet func(ctx context.Context, in *tmservice.GetLatestValidatorSetRequest, ...) (*tmservice.GetLatestValidatorSetResponse, error)

+ GetNodeInfo func(ctx context.Context, in *tmservice.GetNodeInfoRequest, opts ...grpc.CallOption) (*tmservice.GetNodeInfoResponse, error)

+ GetSyncing func(ctx context.Context, in *tmservice.GetSyncingRequest, opts ...grpc.CallOption) (*tmservice.GetSyncingResponse, error)

+ GetValidatorSetByHeight func(ctx context.Context, in *tmservice.GetValidatorSetByHeightRequest, ...) (*tmservice.GetValidatorSetByHeightResponse, error)

+ func NewMockTmServiceClient() MockTmServiceClient

+ type SolvencyReporter func(int64) error