kuji

Apr 7, 2024

Changes in this version

type KujiClient

+ func (c *KujiClient) GetBlockScannerHeight() (int64, error)

+ func (c *KujiClient) GetLatestTxForVault(vault string) (string, string, error)

Oct 3, 2023

Changes in this version

+ const GasCacheTransactions

+ const GasLimit

+ const GasPriceFactor

+ const GasPriceResolution

+ const GasUpdatePeriodBlocks

+ 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")

+ var KujiAssetMappings = []KujiAssetMapping

+ var KujiSuccessCodes = map[uint32]bool

+ type KujiAssetMapping struct

+ BASEChainSymbol string

+ KujiDecimals int

+ KujiDenom string

+ func GetAssetByKujiDenom(denom string) (KujiAssetMapping, bool)

+ func GetAssetByMayachainSymbol(symbol string) (KujiAssetMapping, bool)

+ type KujiBlockScanner struct

+ func NewKujiBlockScanner(cfg config.BifrostBlockScannerConfiguration, ...) (*KujiBlockScanner, error)

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

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

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

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

+ type KujiClient struct

+ func NewCosmosClient(thorKeys *mayaclient.Keys, cfg config.BifrostChainConfiguration, ...) (*KujiClient, error)

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

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

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

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

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

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

+ func (c *KujiClient) GetConfig() config.BifrostChainConfiguration

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

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

+ func (c *KujiClient) IsBlockScannerHealthy() bool

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

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

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

+ func (c *KujiClient) SignTx(tx stypes.TxOutItem, mayachainHeight int64) (signedTx []byte, checkpoint []byte, err error)

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

+ func (c *KujiClient) Stop()

+ type KujiMetadata struct

+ AccountNumber int64

+ BlockHeight int64

+ SeqNumber int64

+ type KujiMetadataStore struct

+ func NewKujiMetaDataStore() *KujiMetadataStore

+ func (b *KujiMetadataStore) Get(pk common.PubKey) KujiMetadata

+ func (b *KujiMetadataStore) GetByAccount(acct int64) KujiMetadata

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

+ func (b *KujiMetadataStore) Set(pk common.PubKey, meta KujiMetadata)

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

+ SpendableBalances func(ctx context.Context, in *btypes.QuerySpendableBalancesRequest, ...) (*btypes.QuerySpendableBalancesResponse, 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