rpc

package
v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 11, 2025 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Clients 

type Clients struct {

	// Auth is a github.com/cosmos/cosmos-sdk/x/auth/types QueryClient
	Auth authtypes.QueryClient
	// Bank is a github.com/cosmos/cosmos-sdk/x/bank/types QueryClient
	Bank banktypes.QueryClient
	// Bank is a github.com/cosmos/cosmos-sdk/x/staking/types QueryClient
	Staking stakingtypes.QueryClient
	// Upgrade is a cosmossdk.io/x/upgrade/types QueryClient
	Upgrade upgradetypes.QueryClient

	// Authority is a github.com/0xPellNetwork/aegis/x/authority/types QueryClient
	Authority authoritytypes.QueryClient
	// Xmsg is a github.com/0xPellNetwork/aegis/x/xmsg/types QueryClient
	Xmsg xmsgtypes.QueryClient
	// Pevm is a github.com/0xPellNetwork/aegis/x/pevm/types QueryClient
	Pevm pevmtypes.QueryClient
	// Relayer is a github.com/0xPellNetwork/aegis/x/relayer/types QueryClient
	Relayer relayertypes.QueryClient
	// Lightclient is a github.com/0xPellNetwork/aegis/x/lightclient/types QueryClient
	Lightclient lightclienttypes.QueryClient

	// Ethermint is a github.com/0xPellNetwork/aegis/rpc/types QueryClient
	Ethermint *etherminttypes.QueryClient
	// EthermintFeeMarket is a github.com/pell-chain/ethermint/x/feemarket/types QueryClient
	EthermintFeeMarket feemarkettypes.QueryClient

	// Tendermint is a github.com/cosmos/cosmos-sdk/client/grpc/cmtservice QueryClient
	Tendermint cmtservice.ServiceClient
}

Clients contains RPC client interfaces to interact with PellCore

Clients also has some high level wrappers for the clients

func NewCometBFTClients 

func NewCometBFTClients(url string) (Clients, error)

NewCometBFTClients creates a Clients which uses cometbft abci_query as the transport

func NewGRPCClients 

func NewGRPCClients(url string, opts ...grpc.DialOption) (Clients, error)

NewGRPCClient creates a Clients which uses gRPC as the transport

func (*Clients) GetAllNodeAccounts 

func (c *Clients) GetAllNodeAccounts(ctx context.Context) ([]*types.NodeAccount, error)

GetAllNodeAccounts returns all node accounts

func (*Clients) GetAllOutTxTrackerByChain 

func (c *Clients) GetAllOutTxTrackerByChain(ctx context.Context, chainID int64, order interfaces.Order) ([]types.OutTxTracker, error)

GetAllOutboundTrackerByChain returns all outbound trackers for a chain

func (*Clients) GetAllXmsg 

func (c *Clients) GetAllXmsg(ctx context.Context) ([]*types.Xmsg, error)

GetAllCctx returns all cross chain transactions

func (*Clients) GetBallot 

func (c *Clients) GetBallot(ctx context.Context, ballotIdentifier string) (*types.QueryBallotByIdentifierResponse, error)

GetBallot returns a ballot by ID

func (*Clients) GetBallotByID 

func (c *Clients) GetBallotByID(ctx context.Context, id string) (*types.QueryBallotByIdentifierResponse, error)

GetBallotByID returns a ballot by ID

func (*Clients) GetBlockHeaderChainState 

func (c *Clients) GetBlockHeaderChainState(ctx context.Context, chainID int64) (*types.QueryChainStateResponse, error)

GetBlockHeaderChainState returns the block header chain state

func (*Clients) GetBlockHeight 

func (c *Clients) GetBlockHeight(ctx context.Context) (int64, error)

GetBlockHeight returns the pellchain block height

func (*Clients) GetChainIndex 

func (c *Clients) GetChainIndex(ctx context.Context, chainId int64) (*types.ChainIndex, error)

func (*Clients) GetChainParams 

func (c *Clients) GetChainParams(ctx context.Context) ([]*types.ChainParams, error)

GetChainParams returns all the chain params

func (*Clients) GetChainParamsForChainID 

func (c *Clients) GetChainParamsForChainID(ctx context.Context, externalChainID int64) (*types.ChainParams, error)

GetChainParamsForChainID returns the chain params for a given chain ID

func (*Clients) GetCrosschainFlags 

func (c *Clients) GetCrosschainFlags(ctx context.Context) (types.CrosschainFlags, error)

GetCrosschainFlags returns the crosschain flags

func (*Clients) GetCurrentTss 

func (c *Clients) GetCurrentTss(ctx context.Context) (types.TSS, error)

GetTSS returns the current TSS

func (*Clients) GetEVMTSSAddress 

func (c *Clients) GetEVMTSSAddress(ctx context.Context) (string, error)

GetEVMTSSAddress returns the current EVM TSS address.

func (*Clients) GetFeemarketParams 

func (c *Clients) GetFeemarketParams(ctx context.Context) (*types.Params, error)

func (*Clients) GetGasRechargeOperationIndex 

func (c *Clients) GetGasRechargeOperationIndex(ctx context.Context, chainId int64) (*types.GasRechargeOperationIndex, error)

GetGasRechargeOperationIndex returns the gas token increment index

func (*Clients) GetInboundTrackersForChain 

func (c *Clients) GetInboundTrackersForChain(ctx context.Context, chainID int64) ([]types.InTxTracker, error)

GetInboundTrackersForChain returns the inbound trackers for a chain

func (*Clients) GetKeyGen 

func (c *Clients) GetKeyGen(ctx context.Context) (types.Keygen, error)

GetKeyGen returns the keygen

func (*Clients) GetLastBlockHeight 

func (c *Clients) GetLastBlockHeight(ctx context.Context) ([]*types.LastBlockHeight, error)

GetLastBlockHeight returns the pellchain block height

func (*Clients) GetLastBlockHeightByChain 

func (c *Clients) GetLastBlockHeightByChain(ctx context.Context, chain chains.Chain) (*types.LastBlockHeight, error)

func (*Clients) GetLatestPellBlock 

func (c *Clients) GetLatestPellBlock(ctx context.Context) (*cmtservice.Block, error)

GetLatestPellBlock returns the latest pell block

func (*Clients) GetNodeInfo 

func (c *Clients) GetNodeInfo(ctx context.Context) (*cmtservice.GetNodeInfoResponse, error)

GetNodeInfo returns the node info

func (*Clients) GetNonceByChain 

func (c *Clients) GetNonceByChain(ctx context.Context, chain chains.Chain) (types.ChainNonces, error)

GetNonceByChain returns the nonce by chain

func (*Clients) GetObserverList 

func (c *Clients) GetObserverList(ctx context.Context) ([]string, error)

GetObserverList returns the list of observers

func (*Clients) GetOutTxTracker 

func (c *Clients) GetOutTxTracker(ctx context.Context, chain chains.Chain, nonce uint64) (*types.OutTxTracker, error)

GetOutboundTracker returns the outbound tracker for a chain and nonce

func (*Clients) GetPellRechargeOperationIndex 

func (c *Clients) GetPellRechargeOperationIndex(ctx context.Context, chainId int64) (*types.PellRechargeOperationIndex, error)

GetPellRechargeOperationIndex returns the pell token increment index

func (*Clients) GetPellTokenSupplyOnNode 

func (c *Clients) GetPellTokenSupplyOnNode(ctx context.Context) (sdkmath.Int, error)

func (*Clients) GetPendingNonces 

func (c *Clients) GetPendingNonces(ctx context.Context) (*types.QueryPendingNoncesAllResponse, error)

GetPendingNonces returns the pending nonces

func (*Clients) GetPendingNoncesByChain 

func (c *Clients) GetPendingNoncesByChain(ctx context.Context, chainID int64) (types.PendingNonces, error)

GetPendingNoncesByChain returns the pending nonces for a chain and current tss address

func (*Clients) GetRateLimiterFlags 

func (c *Clients) GetRateLimiterFlags(ctx context.Context) (types.RateLimiterFlags, error)

GetRateLimiterFlags returns the rate limiter flags

func (*Clients) GetRateLimiterInput 

func (c *Clients) GetRateLimiterInput(ctx context.Context, window int64) (*types.QueryRateLimiterInputResponse, error)

GetRateLimiterInput returns input data for the rate limit checker

func (*Clients) GetSupportedChains 

func (c *Clients) GetSupportedChains(ctx context.Context) ([]*chains.Chain, error)

GetSupportedChains returns the supported chains

func (*Clients) GetTssHistory 

func (c *Clients) GetTssHistory(ctx context.Context) ([]types.TSS, error)

GetTSSHistory returns the historical list of TSS

func (*Clients) GetUpgradePlan 

func (c *Clients) GetUpgradePlan(ctx context.Context) (*upgradetypes.Plan, error)

GetUpgradePlan returns the current upgrade plan. if there is no active upgrade plan, plan will be nil, err will be nil as well.

func (*Clients) GetVerificationFlags 

func (c *Clients) GetVerificationFlags(ctx context.Context) (types.VerificationFlags, error)

GetVerificationFlags returns the enabled chains for block headers

func (*Clients) GetXmsgByHash 

func (c *Clients) GetXmsgByHash(ctx context.Context, sendHash string) (*types.Xmsg, error)

func (*Clients) GetXmsgByNonce 

func (c *Clients) GetXmsgByNonce(ctx context.Context, chainID int64, nonce uint64) (*types.Xmsg, error)

func (*Clients) HasVoted 

func (c *Clients) HasVoted(ctx context.Context, ballotIndex string, voterAddress string) (bool, error)

HasVoted returns whether an observer has voted

func (*Clients) ListPendingXmsg 

func (c *Clients) ListPendingXmsg(ctx context.Context, chainID int64) ([]*types.Xmsg, uint64, error)

ListPendingXmsg returns a list of pending cctxs for a given chainID

  • The max size of the list is xmsgkeeper.MaxPendingXmsgs

func (*Clients) ListPendingXmsgWithinRatelimit 

func (c *Clients) ListPendingXmsgWithinRatelimit(ctx context.Context) (*types.QueryListPendingXmsgWithinRateLimitResponse, error)

ListPendingCCTXWithinRateLimit returns a list of pending cctxs that do not exceed the outbound rate limit

  • The max size of the list is crosschainkeeper.MaxPendingXmsgs
  • The returned `rateLimitExceeded` flag indicates if the rate limit is exceeded or not

func (*Clients) Prove 

func (c *Clients) Prove(ctx context.Context, blockHash string, txHash string, txIndex int64, proof *proofs.Proof, chainID int64) (bool, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.